目录
一、了解分布式系统
二、RPC
三、Dubbo
四、SpringBoot+Dubbo+Zookeeper
4.1 框架搭建
4.2 实现RPC
一、了解分布式系统
分布式系统:由一组通过网络进行通信,为了完成共同的任务而协调工作的计算机节点组成的系统
二、RPC
RPC:远程过程调用,是一种进程间通信方式。
它允许程序调用另一个地址空间的函数
RPC的两个核心模块:通讯,序列化
三、Dubbo
Apache Dubbo是一款高性能、轻量级的开源Java PRC框架
它提供了三大核心能力:
- 面向接口的远程方法调用
- 智能容错和负载均衡
- 服务的自动注册和发现
关系说明:
服务容器负责启动,加载,运行服务提供者
服务提供者在启动时,向注册中心注册自己提供的服务
服务消费者在启动时,向注册中心订阅自己需要的服务
注册中心返回服务提供者地址列表给消费者,若有变更,注册中心将基于长连接推送变更数据给消费者
服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用
服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心
四、SpringBoot+Dubbo+Zookeeper
4.1 框架搭建
1、启动zookeeper
2、IDEA创建一个空项目,创建两个springboot模块,勾选web依赖(分别代表服务提供者和消费者)
3、provider-server
编写service接口
编写实现类
4、consumer-server
编写service
4.2 实现RPC
1、导入相关依赖(Dubbo+Zookeeper)
注意:服务提供者和消费者均需要导入!
<!-- 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>
<!-- 引入zookeeper -->
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>2.12.0</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>2.12.0</version>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.14</version>
<!--排除这个slf4j-log4j12-->
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>
2、服务提供者
①在springboot的配置文件中(application.properties),配置dubbo相关属性
#当前应用名字
dubbo.application.name=provider-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#扫描指定包下服务
dubbo.scan.base-packages=com.kuang.provider.service
②在service实现类中配置服务的注解
@Service:项目一启动,就自动注册到注册中心!
3、服务消费者
①在springboot的配置文件中(application.properties),配置dubbo相关属性
#当前应用名字
dubbo.application.name=consumer-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
②在service实现类中配置服务的注解
4、测试类编写
5、启动测试
开启zookeeper,开启服务者(提供者、消费者),消费者进行消费测试