🍻 正在加载今日诗词....

SpringBoot集成Dubbo和Zookeeper

阅读数： 次
原创 字数统计: 3.2k字   |   预计阅读时长≈ 12分钟

dubbo 是阿里巴巴公司开源的一个高性能优秀的服务框架，一款高性能、轻量级的开源 Java RPC 框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。

zooKeeper 是一个分布式的，开放源码的分布式应用程序协调服务，它是一个为分布式应用提供一致性服务的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。

本文章根据狂神视频学习总结。

分布式理论

什么是分布式系统？

在《分布式系统原理与范型》一书中有如下定义：“分布式系统是若干独立计算机的集合，这些计算机对于用户来说就像单个相关系统”。

分布式系统是由一组通过网络进行通信、为了完成共同的任务而协调工作的计算机节点组成的系统。分布式系统的出现是为了用廉价的、普通的机器完成单个计算机无法完成的计算、存储任务。其目的是利用更多的机器，处理更多的数据。

分布式系统（distributed system）是建立在网络之上的软件系统。

首先需要明确的是，只有当单个节点的处理能力无法满足日益增长的计算、存储任务的时候，且硬件的提升（加内存、加磁盘、使用更好的 CPU）高昂到得不偿失的时候，应用程序也不能进一步优化的时候，我们才需要考虑分布式系统。因为，分布式系统要解决的问题本身就是和单机系统一样的，而由于分布式系统多节点、通过网络通信的拓扑结构，会引入很多单机系统没有的问题，为了解决这些问题又会引入更多的机制、协议，带来更多的问题。。。

Dubbo 文档

随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，急需一个治理系统确保架构有条不紊的演进。

在 Dubbo 的官网文档有这样一张图：

image-20201222170650151

单一应用架构

当网站流量很小时，只需一个应用，将所有功能都部署在一起，以减少部署节点和成本。此时，用于简化增删改查工作量的数据访问框架(ORM)是关键。

image-20201222170715949

适用于小型网站，小型管理系统，将所有功能都部署到一个功能里，简单易用。

缺点：

1、性能扩展比较难

2、协同开发问题

3、不利于升级维护

垂直应用架构

当访问量逐渐增大，单一应用增加机器带来的加速度越来越小，将应用拆成互不相干的几个应用，以提升效率。此时，用于加速前端页面开发的 Web 框架(MVC)是关键。

image-20201222170751429

通过切分业务来实现各个模块独立部署，降低了维护和部署的难度，团队各司其职更易管理，性能扩展也更方便，更有针对性。

缺点：公用模块无法重复利用，开发性的浪费

分布式服务架构

当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。此时，用于提高业务复用及整合的分布式服务框架(RPC)是关键。

image-20201222171026469

流动计算架构

当服务越来越多，容量的评估，小服务资源的浪费等问题逐渐显现，此时需增加一个调度中心基于访问压力实时管理集群容量，提高集群利用率。此时，用于提高机器利用率的资源调度和治理中心(SOA)[ Service Oriented Architecture]是关键。

image-20201222171113516

什么是 RPC

RPC【Remote Procedure Call】是指远程过程调用，是一种进程间通信方式，他是一种技术的思想，而不是规范。它允许程序调用另一个地址空间（通常是共享网络的另一台机器上）的过程或函数，而不用程序员显式编码这个远程调用的细节。即程序员无论是调用本地的还是远程的函数，本质上编写的调用代码基本相同。

也就是说两台服务器 A，B，一个应用部署在 A 服务器上，想要调用 B 服务器上应用提供的函数/方法，由于不在一个内存空间，不能直接调用，需要通过网络来表达调用的语义和传达调用的数据。为什么要用 RPC 呢？就是无法在一个进程内，甚至一个计算机内通过本地调用的方式完成的需求，比如不同的系统间的通讯，甚至不同的组织间的通讯，由于计算能力需要横向扩展，需要在多台机器组成的集群上部署应用。RPC 就是要像调用本地的函数一样去调远程函数。

推荐阅读文章：https://www.jianshu.com/p/2accc2840a1b

RPC 基本原理

image-20201222171426892

步骤解析

image-20201222171510025

RPC 两个核心模块：通讯，序列化。

测试环境搭建

Dubbo

Apache Dubbo |ˈdʌbəʊ| 是一款高性能、轻量级的开源 Java RPC 框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。

dubbo 官网 http://dubbo.apache.org/zh/

1.了解 Dubbo 的特性

2.查看官方文档

dubbo 基本概念

服务提供者（Provider）：暴露服务的服务提供方，服务提供者在启动时，向注册中心注册自己提供的服务。

服务消费者（Consumer）：调用远程服务的服务消费方，服务消费者在启动时，向注册中心订阅自己所需的服务，服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

注册中心（Registry）：注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者

监控中心（Monitor）：服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心

调用关系说明

l 服务容器负责启动，加载，运行服务提供者。

l 服务提供者在启动时，向注册中心注册自己提供的服务。

l 服务消费者在启动时，向注册中心订阅自己所需的服务。

l 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

l 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

l 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

Dubbo 环境搭建

看我的另一篇 dubbo 文章，我的那篇博客是搭建在 windows 上的，建议搭建在 linux 系统上，使用 docker 容器技术拉镜像即可。。

框架搭建

阿里巴巴提供了 dubbo 集成 springBoot 开源项目，可以到 GitHub 上https://github.com/alibaba/dubbo-spring-boot-starter 查看入门教程

基本集成步骤

创建父工程管理版本依赖

创建普通maven项目springboot-parent，项目结构只留pom.xml文件

image-20201222193258791

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
<!--父工程这里打包方式必须为pom-->
<packaging>pom</packaging>

<!--全局变量，管理版本-->
<properties>
    <java.version>1.8</java.version>
    <dubbo-spring-boot-starter-version>2.0.0</dubbo-spring-boot-starter-version>
    <zkclient.version>0.10</zkclient.version>
    <mybatis-spring-boot-starter-version>2.0.0</mybatis-spring-boot-starter-version>
</properties>

<!--管理SpringBoot父工程没有管理的依赖-->
<dependencyManagement>
    <dependencies>
        <!--Dubbo集成SpringBoot框架起步依赖-->
        <dependency>
            <groupId>com.alibaba.spring.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>${dubbo-spring-boot-starter-version}</version>
        </dependency>

        <!--zookeeper注册中心-->
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>${zkclient.version}</version>
        </dependency>

        <!--MyBatis集成Springboot框架起步依赖-->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>${mybatis-spring-boot-starter-version}</version>
        </dependency>
    </dependencies>
</dependencyManagement>

开发 Dubbo 服务接口

按照 Dubbo 官方开发建议，创建一个接口项目，该项目只定义接口和 model 类

项目名称：springboot-interface

创建普通 Maven 项目，dubbo 服务接口工程，指定父工程为 springboot-parent

image-20201222173806343

创建业务接口

略

开发 Dubbo 服务提供者

项目名称：springboot-provider

创建 SpringBoot 框架的 WEB 项目 ，指定父工程为 springboot-parent

我使用的是 springboot 2.3.3.RELEASE

加入 Dubbo 集成 SpringBoot 的起步依赖
1
2
3
4
5
<!--Dubbo集成SpringBoot框架起步依赖-->
<dependency>
    <groupId>com.alibaba.spring.boot</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
</dependency>
由于使用 zookeeper 作为注册中心，需加入 zookeeper 的客户端依赖
1
2
3
4
5
<!--zookeeper注册中心客户端依赖-->
<dependency>
    <groupId>com.101tec</groupId>
    <artifactId>zkclient</artifactId>
</dependency>
加入 MyBatis 和 MySQL 依赖
1
2
3
4
5
6
7
8
9
10
11
12
<!--MySQL驱动-->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.30</version>
</dependency>

<!--MyBatis集成Springboot框架起步依赖-->
<dependency>
    <groupId>org.mybatis.spring.boot</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
</dependency>
加入 Dubbo 接口依赖
1
2
3
4
5
6
<!--接口工程,自己创建的java工程-->
<dependency>
    <groupId>com.easyfund.springboot</groupId>
    <artifactId>springboot-interface</artifactId>
    <version>1.0.0</version>
</dependency>
在 Springboot 的核心配置文件
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
#设置内嵌Tomcat端口号
server.port=8081
#设置上下文根
server.servlet.context-path=/

#设置连接数据库信息
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/springboot?useUnicode=true&characterEncoding=UTF-8
spring.datasource.username=root
spring.datasource.password=123456

#设置dubbo配置
spring.application.name=springboot-provider
#设置当前工程为服务提供者
spring.dubbo.server=true
#指定注册中心
spring.dubbo.registry=zookeeper://localhost:2181

注意：Dubbo 的注解都是自定义的注解，由我们添加的 Dubbo 依赖中的类进行处理编写dubbo 配置是没有提示的

编写 Dubbo 的接口实现类
1
2
3
4
5
6
7
8
9
10
11
@Component @Service(interfaceName = "com.itjing.springboot.service.StudentService",version = "1.0.0",timeout = 15000)
public class StudentServiceImpl implements StudentService {

    @Autowired
    private StudentMapper studentMapper;

    @Override
    public Student queryStudent(Integer id) {
        return studentMapper.selectByPrimaryKey(id);
    }
}
在 SpringBoot 入口程序类上加开启 Dubbo 配置支持注解
1
2
3
4
5
6
7
8
9
@SpringBootApplication
@MapperScan(basePackages = "com.itjing.springboot.mapper") //扫描mapper包，创建代理对象
@EnableDubboConfiguration   //开启dubbo配置
@EnableTransactionManagement //开启事务支持
public class SpringbootProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(SpringbootProviderApplication.class, args);
    }
}
启动 Zookeeper 服务

1、启动 linux 服务器上的 Zookeeper

2、启动服务提供者项目主程序

开发 Dubbo 服务消费者

项目名称：springboot-consumer

创建 SpringBoot 框架的 web 项目 ，指定父工程为 springboot-parent
加入 Dubbo 集成 SpringBoot 框架的起步依赖

同服务提供者。

加入 zookeeper 的客户端依赖

同服务提供者。

加入 Dubbo 接口依赖

同服务提供者。

Springboot 的核心配置
1
2
3
4
5
6
7
8
9
10
11
#设置内嵌Tomcat端口号
server.port=8080

#设置上下文根
server.servlet.context-path=/

#设置dubbo配置
spring.application.name=springboot-consumer

#指定注册中心
spring.dubbo.registry=zookeeper://localhost:2181
编写一个 Controller 类，调用远程的 Dubbo 服务
1
2
3
4
5
6
7
8
9
10
11
12
13
14
@RestController
public class StudentController {

    @Reference(interfaceName = "com.itjing.springboot.service.StudentService",version = "1.0.0",check = false)
    private StudentService studentService;

    @RequestMapping(value = "/student")
    public Object queryStudent(Integer id) {

        Student student = studentService.queryStudent(id);

        return student;
    }
}
在 SpringBoot 入口程序类上加开启 Dubbo 配置支持注解
1
2
3
4
5
6
7
8
@SpringBootApplication
@EnableDubboConfiguration   //开启dubbo配置
public class SpringbootConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringbootConsumerApplication.class, args);
    }
}
测试

启动服务消费者项目主程序

访问运行即可

dubbo-admin 监控中心去看我的dubbo文章

ok , 这就是 SpingBoot + dubbo + zookeeper 实现分布式开发的应用，其实就是一个服务拆分的思想

本文作者： LiJing
发布时间： 2020-12-22
最后更新： 2024-06-24
本文标题： SpringBoot集成Dubbo和Zookeeper
本文链接： https://blog-yilia.xiaojingge.com/posts/1353c500.html
版权声明： 本作品采用 CC BY-NC-SA 4.0 许可协议进行许可。转载请注明出处！
知识共享许可协议
赏

谢谢你请我吃糖果

支付宝
微信
本站总访问量次 | 本站访客数人

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true

喜欢看书、打代码、吃吃吃！我从没被谁知道，所以也没被谁忘记。在别人的回忆中生活，并不是我的目的。我只不过是自己一个人在努力罢了。