文章目录
- Dubbo + Zookeeper + Dubbo Admin 服务注册发现实战
- 0 环境配置
- 1 项目搭建
- 2 添加依赖
- 3 注册生产者
- 4 注册消费者
- 5 测试成功
- 6 可视化查看
Dubbo + Zookeeper + Dubbo Admin 服务注册发现实战
0 环境配置
Zookeeper 安装配置可参考文章:【踩坑三次】新版Zookeeper安装与配置:闪退、错误: 找不到或无法加载主类QuorumPeerMain、ZooKeeper audit is disabled
Dubbo Admin 安装配置可参考文章:【踩坑四次】Dubbo-admin 安装与配置详细教程 + 排错解析
1 项目搭建
创建一个空项目,便于我们之后可同时进行两个模块文件的编写
创建两模块,均为Spring项目,且初始都引入Spring Web依赖
编写测试用的类和接口,并修改两个模块项目的配置文件中的端口号,如8001,8002
2 添加依赖
首先声明,我们需要导入 dubbo 的SpringBoot依赖,zookeeper 的SpringBoot依赖。
我们去 Maven 仓库,查找依赖,首先模糊查询,查询出两个主要下载源,因为根据前文我们讲过 Dubbo 的发展史,如今已被 Apache 维护和管理,况且我们下载的 Dubbo 也是在 Apache 官网下的,且我们又是通过SpringBoot项目集成,因此,我们理所当然就该使用下图红框中的版本
我们选一个使用人数较多,且版本不是特别新的依赖使用
<!-- 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.8</version>
</dependency>
之后我们去导入 zookeeper 的相关依赖,经查阅,我们需要搜索zkclient
<!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>
注意,我们在整合 springboot,添加依赖的时候,会遇到日志冲突的问题,需先排除自带的 zookeeper,并且,单独引入 zookeeper 时还需排除其自带的日志依赖,否则启动报错,和 spring 自带的日志冲突了。
这是新版 zookeeper 的一个坑,解决方法是添加如下代码
<!--日志会冲突-->
<!--引入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>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>
因此,我们整理一下上面所用的依赖,方便今后再使用:
【汇总:SpringBoot 整合 Dubbo + Zookeeper 所需依赖】
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.7.8</version>
</dependency>
<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>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>
3 注册生产者
首先需要在配置文件中添加显示配置
application.properties
server.port=8001
# 服务应用名
dubbo.application.name=provider-server
# 注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
# 哪些服务要被注册
dubbo.scan.base-packages=com.zlc.service
在服务实现类中,使用 @DubboService 注解将此服务进行注册,以前的版本用的是 @Service 注解,稍不注意就可能使用成 Spring 中的 @Service,导致在排错上可能又会花较多时间,如今新版终于改了!
4 注册消费者
同样,首先需要在配置文件中添加必要显示配置
application.properties
server.port=8002
# 消费者去哪里取服务,需要暴露自己名字
dubbo.application.name=consumer-server
# 注册中心的地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
编写消费者实现类
5 测试成功
在消费者项目中,编写测试类测试(当然,事先记得启动Zookeeper、Dubbo Admin),userService.buyTicket() 可以成功执行,证明消费者可以在注册中心拿到 TicketService 服务
6 可视化查看
查看成功(补充:由图可见,虽然我们是在接口实现类上添加的 @DubboService 注解,但最终注册的服务名是以其接口进行命名的)