1.理论概述
1.1.分布式
分布式系统是若干独立计算机的集合,这些计算机对于用户来讲就像单个系统。
由多个系统集成成一个整体,提供多个功能,组合成一个板块,用户在使用上看起来是一个服务。(比如淘宝网)。
起源
分布式系统出现的原因是:用多个廉价的、普通的机器完成单个计算机无法完成的计算、存储任务
分布式使用
只有单个节点处理能力无法满足日益增长的计算、存储任务的时候,且硬件的提升(内存、磁盘、CPU)高昂得不偿失的时候,应用程序也不能进一步优化的时候,才考虑分布式。
因为分布式系统是建立在网络之上的软件系统,网络是不安全不稳定的,所以会带来单系统没有的问题,为了解决这些问题,又引入更多的机制、协议,带来更多的问题。
集群与分布式区别

【集群】:多个相同的微服务,提供同一个功能
【分布式】:多个不同功能的微服务,提供不同的功能
1.2.RPC
Remote Procedure Call 远程过程调用
远程调用另外一台机器上的方法,RPC只是一种理论,不是协议。

1.3.Dubbo
概念
Dubbo是一个高性能、轻量级、开源的Java RPC框架。
提供三大核心能力:面向接口的远程方法调用、智能容错和负载均衡、服务自动注册与发现。
执行流程

调用关系说明:
- 服务容器负责启动,加载,运行服务提供者。
- 服务提供者在启动时,向注册中心注册自己提供的服务。
- 服务消费者在启动时,向注册中心订阅自己所需的服务。
- 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。
- 服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。
- 服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。
2.Linux下安装zookeeper和dubbo-admin
软件说明
zookeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。 (==类似于Eureka==)。
dubbo-admin是管理控制台,可以实现服务监控 (即查看注册中心情况),不安装也是可以的。
2.1.下载并安装zookeeper
①到zookeeper官网镜像:https://mirror.bit.edu.cn/apache/zookeeper/,下载zookeeper

注意3.5.x版本以上需要下载:
- apache-zookeeper-3.5.9-bin.tar.gz 15-Jan-2021 03:46 9.2M
tar.gz是源码包,执行启动无法运行
②下载完毕后通过Xftp发送到Linux服务器上的home目录下(目录可根据个人喜好),解压并进入conf目录下复制配置文件;
- cp zoo.zoo_sample.cfg zoo.cfg
③需要同步修改zoo.cfg文件:

④返回上一层目录并进入bin子目录,执行命令:./zkServer.sh start
启动zookeeper

操作zookeeper其余命令:
- ./zkServer.sh stop
- ./zkServer.sh restart
- ./zkServer.sh status
启动zookeeper过程中可能由于远端Linux云服务器防火墙未关闭报:java.net.NoRouteToHostException: No route to host dubbo-admin,
需要关闭防火墙:解决方法
2.2.下载安装dubbo-admin
①下载dubbo-admin并修改配置:
进入GitHub下载:https://github.com/apache/dubbo-admin/tree/master
解压并修改application.properties文件,配置文件在dubbo-admin\src\main\resources
目录下

②打包dubbo-admin项目,将dubbo-admin项目编译打成jar包:
在项目目录下执行cmd命令:

打包:
- 输入命令:mvn clean package -Dmaven.test.skip=true
将项目target目录下生成的jar上传到Linux系统并执行java -jar dubbo-admin-0.0.1-SNAPSHOT.jar &
命令,开放7001端口,在浏览器便可访问。

初始登录账户和密码都是root
3.SpringBoot整合Dubbo+Zookeeper
3.1.创建服务提供者provider
①先创建一个空项目,在空项目下以SpringBoot为基础创建一个子模块。

②导入dubbo、zookeeper相关依赖包:
- <!-- 导入依赖 Dubbo + Zookeeper -->
- <!-- https://mvnrepository.com/artifact/org.apache.dubbo/dubbo-spring-boot-starter -->
- <dependency>
- <groupId>org.apache.dubbo</groupId>
- <artifactId>dubbo-spring-boot-starter</artifactId>
- <version>2.7.3</version>
- </dependency>
- <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
- <dependency>
- <groupId>com.github.sgroschupf</groupId>
- <artifactId>zkclient</artifactId>
- <version>0.1</version>
- </dependency>
- <!-- 日志冲突 -->
- <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-framework -->
- <dependency>
- <groupId>org.apache.curator</groupId>
- <artifactId>curator-framework</artifactId>
- <version>2.12.0</version>
- </dependency>
- <!-- https://mvnrepository.com/artifact/org.apache.curator/curator-recipes -->
- <dependency>
- <groupId>org.apache.curator</groupId>
- <artifactId>curator-recipes</artifactId>
- <version>2.12.0</version>
- </dependency>
- <!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper -->
- <!--zookeeper的版本与自己安装的保持一致-->
- <dependency>
- <groupId>org.apache.zookeeper</groupId>
- <artifactId>zookeeper</artifactId>
- <version>3.5.9</version>
- <exclusions>
- <exclusion>
- <groupId>org.slf4j</groupId>
- <artifactId>slf4j-log4j12</artifactId>
- </exclusion>
- </exclusions>
- </dependency>
application.properties配置:
- server.port=8001
- #服务应用名字
- dubbo.application.name=provider-server
- #注册中心地址
- dubbo.registry.address=zookeeper://139.155.203.191:2181
- #哪些包下面的服务需要被注册
- dubbo.scan.base-packages=com.fengye.service
或yml格式:
- server:
- port: 8080
- dubbo:
- # 服务应用名字
- application:
- name: provider-server
- # 注册中心地址(zookeeper地址)
- registry:
- address: zookeeper://ip:2181
- # 哪些服务要被注册
- scan:
- base-packages: com.fengye.service
③创建接口并实现接口提供服务(模拟售票):
- //接口
- public interface TicketService {
- public String buyTicket();
- }
- @Component //使用dubbo后尽量不要使用Service注解
- @Service //标识可以被dubbo扫描到,项目启动后就注册到注册中心
- public class TicketServiceImpl implements TicketService {
- @Override
- public String buyTicket() {
- return "成功购票一张";
- }
- }
④启动此服务,便可以在dubbo-admin中发现服务:

3.2.创建服务消费者consumer
①第一步、第二步与provider模块创建、导入依赖坐标相同;
配置application.properties:
- server.port=8002
- #消费者去哪里取服务需要暴露自己的名称
- dubbo.application.name=consumer-service
- #配置注册中心的地址
- dubbo.registry.address=zookeeper://139.155.203.191:2181
②创建消费者接口(必须和服务提供者接口方法名一样,表示引用远端、执行方法调用):
- public interface TicketService {
- //定义和远端服务提供者provider相同的接口名称
- public String buyTicket();
- }
③创建消费者UserServie:
- @Service
- public class UserService {
- //在消费者中使用dubbo订阅远程服务:使用dubbo提供的@Refence注解
- @Reference
- private TicketService ticketService;
- public void getTicket(){
- String ticket = ticketService.buyTicket();
- System.out.println("从注册中心拿到:" + ticket);
- }
- }
④启动消费者服务,可以看到服务在dubbo-admin中已经注册:

3.3.测试消费者远程调用服务者拿数据
①在消费者方本地创建测试方法,执行方法:
- @SpringBootTest
- class ConsumerServerApplicationTests {
- @Autowired
- private UserService userService;
- @Test
- void contextLoads() {
- //获取售票数据
- userService.getTicket();
- }
- }
成功调用可以看到远端服务提供者方法已被调用:

本博客写作参考文档相关:
https://dubbo.apache.org/zh/docs/v2.7/user/preface/architecture/
https://www.kuangstudy.com/bbs/1355164021359243266
https://www.kuangstudy.com/bbs/1371400397700218882
示例代码已上传至Github地址:
https://github.com/devyf/SpringBoot_Study/springboot_dubbo_zk