Dubbo架构
Dubbo是Java的RPC框架，具有三大核心功能：面向接口的远程方法调用，智能容错和负载均衡，以及服务的自动注册和发现
Dubbo架构图：
节点角色说明：
| 节点 | 说明 |
| Provider | 需要暴露服务的服务提供方 |
| Consumer | 调用远程服务的服务消费方 |
| Registry | 服务注册与发现的注册中心 |
| Monitor | 统计服务次数和调用时间的监控中心 |
| Container | 服务运行容器 |
调用关系说明：
0. Container负责启动、加载、运行Provider
1. Provider在启动时，向Registry注册自己提供的服务
2. Consumer在启动时，向Registry订阅自己所需的服务
3. Registry返回Provider地址列表给Consumer，若地址有变更，将基于长连接推送变更数据给Consumer
4. Consumer从Provider地址列表中，基于软负载均衡算法，选一台Provider进行调用
5. Consumer和Provider在内存中累计调用次数和调用时间，定时每分钟发一次统计数据到Monitor
模块目录说明：
1. API：存放service接口以及实体类、数据传输对象等
2. Consumer：消费者目录，远程调用Provider提供的接口实现，即交互层
3. Provider：生产者目录，提供给Consumer的接口实现类
Dubbo整合
写个SpringBoot整合Dubbo的demo，清晰明了地了解这几层分层的含义，以及Dubbo的相关配置
1）API层
UserInfo实体类
1 @ToString
2 @AllArgsConstructor
3 @NoArgsConstructor
4 @Data
5 public class userInfo implements Serializable {
6 /**
7 * Serializable 序列化
8 * 实体类必须实现序列化接口
9 **/
10 private Long id;
11 private String userName;
12 private Integer userId;
13 private String userEmail;
14 private String userAddress;
15 private String userGender;
16 } UserInfoService接口
1 public interface UserInfoService {
2 public List<userInfo> getUserInfo();
3 } 2）Provider层
pom.xml添加相关依赖
1 <dependencies>
2 <!-- 添加api依赖 -->
3 <dependency>
4 <groupId>com.tttori</groupId>
5 <artifactId>api</artifactId>
6 <version>0.0.1-SNAPSHOT</version>
7 <scope>compile</scope>
8 </dependency>
9
10 <!-- dubbo依赖 -->
11 <dependency>
12 <groupId>com.alibaba.boot</groupId>
13 <artifactId>dubbo-spring-boot-starter</artifactId>
14 <version>0.2.0</version>
15 </dependency>
16
17 <!-- zookeeper cli端 -->
18 <dependency>
19 <groupId>org.apache.curator</groupId>
20 <artifactId>curator-framework</artifactId>
21 <version>2.13.0</version>
22 </dependency>
23 </dependencies> dubbo-config.xml配置dubbo
ServiceImpl类使用@Service("x")注解，其中x与配置中ref一致
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<!-- 声明服务名dubbo-provider -->
<dubbo:application name="dubbo-provider"/>
<!-- 声明zookeeper注册中心，暴露服务地址127.0.0.1:2181 -->
<dubbo:registry id="tttori" protocol="zookeeper" address="127.0.0.1:2181"/>
<!-- 使用dubbo协议，暴露服务端口随机 -->
<dubbo:protocol name="dubbo" port="-1"/>
<!-- 暴露服务接口,ref指向实现对象 -->
<dubbo:service interface="com.tttori.api.service.UserInfoService" ref="userInfoService" registry="tttori" timeout="5000"/>
<dubbo:consumer check="false" timeout="5000"/>
</beans> UserInfoServiceImpl提供服务的接口实现类
1 @Service("userInfoService") //dubbo包下的Service 暴露服务
2 @Component //POJO实例化入容器中
3 public class UserInfoServiceImpl implements UserInfoService{
4 @Override
5 public List<userInfo> getUserInfo(){
6 userInfo userinfo1 = new userInfo(1001L,"Jack",1413112,"[email protected]","China","M");
7 userInfo userinfo2 = new userInfo(1002L,"Dell",1414116,"[email protected]","China","M");
8 return Arrays.asList(userinfo1,userinfo2);
9 }
10 } ProviderApplication主启动类
1 @SpringBootApplication
2 @ComponentScan(basePackages = {
3 "com.tttori.provider.serviceImpl"
4 })
5 @MapperScan(basePackages = {"com.tttori.provider.mapper"})
6 @ImportResource(locations = {"classpath:dubbo-config.xml"})
7 @EnableScheduling
8 public class ProviderApplication {
9
10 public static void main(String[] args) {
11 SpringApplication.run(ProviderApplication.class, args);
12
13 try {
14 System.in.read();
15 } catch (IOException e) {
16 e.printStackTrace();
17 }
18 }
19
20 } 3）Consumer层
pom.xml添加API的依赖
1 <dependencies>
2 <!-- api依赖 -->
3 <dependency>
4 <groupId>com.maziyao</groupId>
5 <artifactId>api</artifactId>
6 <version>0.0.1-SNAPSHOT</version>
7 <scope>compile</scope>
8 </dependency>
9 ...
10 </dependencies> 1 <?xml version="1.0" encoding="UTF-8"?>
2 <beans xmlns="http://www.springframework.org/schema/beans"
3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4 xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
5 xsi:schemaLocation="http://www.springframework.org/schema/beans
6 http://www.springframework.org/schema/beans/spring-beans.xsd
7 http://code.alibabatech.com/schema/dubbo
8 http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
9
10 <!-- 配置服务名 -->
11 <dubbo:application name="dubbo-consumer"/>
12
13 <!-- 指定注册中心地址 -->
14 <dubbo:registry id="tttori" address="zookeeper://127.0.0.1:2181"/>
15
16 <!-- 订阅接口，生成远程服务代理 -->
17 <dubbo:reference id="userInfoService" interface="com.tttori.api.service.UserInfoService" registry="tttori"/>
18
19 </beans> UserController交互层
@RestController //控制层
public class UserController {
@Autowired
UserService UserService;
@ResponseBody //返回Json数据
@RequestMapping("/info")
public List<userInfo> getInfo(){
/**
* Consumer接口实现类调用远程服务Provider接口
**/
return userService.getUserInfo();
}
} ConsumerApplication启动类
1 @SpringBootApplication
2 @ImportResource(locations = {"classpath:dubbo-config.xml"})
3 public class ConsumerApplication {
4
5 public static void main(String[] args) {
6 SpringApplication.run(ConsumerApplication.class, args);
7 }
8
9 } 总结
SpringBoot整合Dubbo步骤
1）pom.xml
0. Provider和Consumer配置Dubbo相关的Starter（ZK）
2）dubbo-config.xml
0. dubbo.application.name 声明当前服务名
1. dubbo.protocol.name 指定通信规则，dubbo协议
2. dubbo.registry.protocol.address 声明注册中心，暴露服务地址
3. dubbo.service.interface.ref.registry 暴露服务接口（Provider）
4. dubbo.registry.interface.ref.registry 订阅服务接口（Consumer）
3）暴露服务
服务实现类使用@Service和@Component注释
![Java小案例——随机数猜测随机数猜测[图]](data:image/gif;base64,R0lGODlhAQABAIAAAP///wAAACwAAAAAAQABAAACAkQBADs=)