【java框架】SpringBoot(5)--SpringBoot整合分布式Dubbo+Zookeeper
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