【java框架】SpringBoot(5)--SpringBoot整合分布式Dubbo+Zookeeper

1.理论概述

1.1.分布式

分布式系统是若干独立计算机的集合，这些计算机对于用户来讲就像单个系统。

由多个系统集成成一个整体，提供多个功能，组合成一个板块，用户在使用上看起来是一个服务。（比如淘宝网）。

起源

分布式系统出现的原因是：用多个廉价的、普通的机器完成单个计算机无法完成的计算、存储任务

分布式使用

只有单个节点处理能力无法满足日益增长的计算、存储任务的时候，且硬件的提升（内存、磁盘、CPU）高昂得不偿失的时候，应用程序也不能进一步优化的时候，才考虑分布式。

因为分布式系统是建立在网络之上的软件系统，网络是不安全不稳定的，所以会带来单系统没有的问题，为了解决这些问题，又引入更多的机制、协议，带来更多的问题。

集群与分布式区别

【集群】：多个相同的微服务，提供同一个功能

【分布式】：多个不同功能的微服务，提供不同的功能

1.2.RPC

Remote Procedure Call 远程过程调用

远程调用另外一台机器上的方法，RPC只是一种理论，不是协议。

1.3.Dubbo

概念

Dubbo是一个高性能、轻量级、开源的Java RPC框架。

提供三大核心能力：面向接口的远程方法调用、智能容错和负载均衡、服务自动注册与发现。

执行流程

调用关系说明：

0. 服务容器负责启动，加载，运行服务提供者。
1. 服务提供者在启动时，向注册中心注册自己提供的服务。
2. 服务消费者在启动时，向注册中心订阅自己所需的服务。
3. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
4. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
5. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

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-adminsrcmain esources目录下

②打包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