Dubbo简介
Dubbo是Alibaba开源的分布式服务框架，它最大的特点是按照分业务的架构，使用这种方式可以使各个业务之间解耦合（或者最大限度地松耦合）。
简单来说Dubbo:
- 一款分布式服务框架
- 高性能和透明化的RPC远程服务调用方案
- SOA服务治理方案
Dubbo架构
这里写图片描述
Provider: 暴露服务的服务提供方。
Consumer: 调用远程服务的服务消费方。
Registry: 服务注册与发现的注册中心。
Monitor: 统计服务的调用次数和调用时间的监控中心。
调用流程
- 服务容器负责启动，加载，运行服务提供者。
- 服务提供者在启动时，向注册中心注册自己提供的服务。
- 服务消费者在启动时，向注册中心订阅自己所需的服务。
- 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
- 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
- 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。
SpringBoot整合Dubbo
项目整体架构
这里写图片描述
这里还用到了Zookeeper注册中心,所以需要到Zookeeper官网下载压缩包，下载后进行解压，然后启动Zookeeper，点击解压包下的bin/zkServer.cmd:
这里还用到了zookeeper的可视化工具ZK UI。
服务监控中心搭建：dubbo-admin的下载，地址：https://github.com/Linliuxing/dubbo-admin
直接下载zip包，解压后将dubbo-admin下的内容全部拷贝到本地tomcat的webapps下
在运行tomcat之前，先将zookeeper启动，如果不配置监控中心（WEB-INF/dubbo.properties，内容如下），
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.admin.root.password=root
dubbo.admin.guest.password=guest
默认启动tomcat即可,http://localhost:8080/dubbo-admin, 登录时输入root/root
这里写图片描述
SpringBoot添加Dubbo和Zookeeper依赖：
<!--spring-boot-starter-dubbo-->
<dependency>
<groupId>com.gitee.reger</groupId>
<artifactId>spring-boot-starter-dubbo</artifactId>
<version>1.1.1</version>
</dependency>
<!-- 引入zookeeper，去除其中的log4j，否则会因为日志原因导致堆栈溢出 -->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.10</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>
springboot-dubbo-api：
- 定义服务接口ProviderService ：
public interface ProviderService {
String sayHello(String name);
}
springboot-dubbo-provider：
- application.yml配置信息：
server:
port: 8081
spring:
dubbo:
application:
name: service-provider
base-package: com.lin.service # dubbo服务发布者所在的包
registry:
address: 192.168.0.116 # zookeeper注册中心的地址
port: 2181 # zookeeper注册中心的端口
protocol: zookeeper
register: true
protocol:
name: dubbo
port: 20880
accesslog: true
provider:
retries: 1
delay: -1
- 服务实现类：
@Service(version = "1.0.0")
@Component
public class ProviderServiceImpl implements ProviderService {
@Override
public String sayHello(String name) {
return "Hello "+name;
}
}
springboot-dubbo-consumer：
- application.yml配置信息：
server:
port: 8082
spring:
dubbo:
application:
name: service-consumer
base-package: com.lin.service # dubbo服务调用者所在的包
registry:
address: 192.168.0.116 # zookeeper注册中心的地址
port: 2181 # zookeeper注册中心的端口
protocol: zookeeper
subscribe: true
protocol:
name: dubbo
host: 192.168.0.116
consumer:
timeout: 1000
check: false # 服务启动时检查被调用服务是否可用
retries: 2 # 服务调用重试次数
- 调用服务提供者的服务：
@RestController
public class Consumer {
// 使用兼容注入，可以使用dubbo原生注解@Reference注入
@Reference(version = "1.0.0")
public ProviderService service;
@GetMapping(value = "/hello/{name}")
public String hello(@PathVariable String name){
return service.sayHello(name);
}
}
测试：
- 浏览器访问消费者的接口，返回的是提供者的处理请求：
这里写图片描述
- 查看服务提供者和消费者是否注册到Zookeeper注册中心：
这里写图片描述
-
查看服务提供者和消费者是否注册到服务监控中心：
这里写图片描述
这里写图片描述
- 查看springboot-dubbo-provider的Zookeeper打印信息：
这里写图片描述
