SpringBoot中dubbo+zookeeper实现分布式开发的应用详解
作者:Listen-Y 时间:2023-09-13 19:04:45
总体实现思路是启动一个生产者项目注册, 将所含服务注册到zookeeper的注册中心, 然后在启动一个消费者项目,将所需服务向zookeeper注册中心进行订阅, 等待注册中心的通知
注册中心基于负载均衡算法给消费者匹配到合适的生产者主机,然后通知消费者可以使用
实现生产者
导入zookeeper依赖包
<!-- Dubbo Spring Boot Starter -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.7.3</version>
</dependency>
<!--zookeeper的包-->
<!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>
<!-- 引入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>
<!--排除这个slf4j-log4j12-->
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>
配置服务名字, 注册中心地址, 扫描被注册的包
server.port=8081
#当前应用名字
dubbo.application.name=provider-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#扫描指定包下服务
dubbo.scan.base-packages=com.demo.service
实现一个接口,在接口中完成需求
public interface Translate {
String translate(String str);
}
public interface Translate {
String translate(String str);
}
实现一个消费者
导入依赖, 和生产者的依赖是相同的
配置服务名字,注册中心地址
server.port=8082
# 配置zookeeper
# 配置服务名字
dubbo.application.name=consumer.server
# 配置注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
本来正常步骤是需要将服务提供者的接口打包,然后用pom文件导入,我们这里使用简单的方式,直接将服务的接口拿过来,路径必须保证正确,即和服务提供者相同
现获取翻译服务
package com.demo.service;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;
@Service //使用Spring的Service添加组件
public class Translation {
@Reference //远程引用指定的服务,他会按照全类名进行匹配,看谁给注册中心注册了这个全类名
private Translate translate;
public String getTranslation(String str) {
return translate.translate(str);
}
}
实现controller
@RestController
public class TranslateController {
@Autowired
Translation translation;
@RequestMapping("/tran/{str}")
public String tran(@PathVariable("str")String str) {
return translation.getTranslation(str);
}
}
测试
首先启动zookeeper服务器和dubbo进入到监控页面中
切记不要关闭服务器和dubbo开启生产者这个springboot项目
上图显示就是生产者注册成功, 我们可以点击ip查看详情
启动消费者这个springboot项目
访问地址, 但是要注意我们消费者的tomcat启动端口已经换成8082
翻译成功
来源:https://blog.csdn.net/Shangxingya/article/details/109840365
标签:SpringBoot,dubbo,zookeeper,分布式
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
android手机获取唯一标识的方法
2022-05-28 19:24:38
浅谈Java获得多线程的返回结果方式(3种)
2023-04-02 05:37:36
android 字体颜色选择器(ColorPicker)介绍
2021-10-05 01:13:31
Spring容器中添加bean的5种方式
2023-03-23 03:03:15
解决spring boot2集成activiti6踩过的坑
2022-03-31 16:46:06
java Timer测试定时调用及固定时间执行代码示例
2023-12-09 14:36:44
c# mutex互斥量的深入解析
2022-03-13 02:38:42
Android中js和原生交互的示例代码
2022-12-25 16:04:57
详解C#对XML、JSON等格式的解析
2022-06-04 22:45:50
![](https://img.aspxhome.com/file/2023/5/68615_0s.jpg)
新手了解java IO基础知识
2023-10-20 22:19:45
![](https://img.aspxhome.com/file/2023/2/125332_0s.jpg)
浅谈JDK9的特性之JVM的xlog
2022-07-20 12:00:45
C#设置软件开机自动运行的方法(修改注册表)
2022-08-27 21:05:46
Spring Boot @Conditional注解用法示例介绍
2023-04-18 22:51:51
浅析Java设计模式编程中的单例模式和简单工厂模式
2021-10-13 15:27:54
![](https://img.aspxhome.com/file/2023/3/69103_0s.gif)
基于JavaSwing设计和实现的酒店管理系统
2022-03-31 12:12:14
![](https://img.aspxhome.com/file/2023/2/71202_0s.jpg)
Java实现常见排序算法的优化
2022-05-20 13:08:37
java多线程Thread的实现方法代码详解
2022-01-03 01:02:28
剑指Offer之Java算法习题精讲数组与字符串
2021-05-24 19:21:45
![](https://img.aspxhome.com/file/2023/0/77370_0s.png)
Java框架解说之BIO NIO AIO不同IO模型演进之路
2021-06-20 22:56:31
![](https://img.aspxhome.com/file/2023/6/75026_0s.png)
IDEA插件开发之环境搭建过程图文详解
2022-01-17 14:04:08
![](https://img.aspxhome.com/file/2023/2/110792_0s.png)