菜鸟学堂 服务器常用软件 主机测评网在线工具
快捷导航
爱站统计广告　商业广告，理性选择
广告　商业广告，理性选择
广告　商业广告，理性选择
您的位置：首页 → 软件编程 → java → SpringBoot dubbo zookeeper分布式

SpringBoot中dubbo+zookeeper实现分布式开发的应用详解

 更新时间：2020年11月23日 10:02:11   作者：Listen-Y  
这篇文章主要介绍了SpringBoot中dubbo+zookeeper实现分布式开发的应用详解，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

Java技术迷

总体实现思路是启动一个生产者项目注册, 将所含服务注册到zookeeper的注册中心, 然后在启动一个消费者项目,将所需服务向zookeeper注册中心进行订阅, 等待注册中心的通知

注册中心基于负载均衡算法给消费者匹配到合适的生产者主机,然后通知消费者可以使用

实现生产者

导入zookeeper依赖包

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
<!-- 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>
登录后复制免费讲解

配置服务名字, 注册中心地址, 扫描被注册的包

?
1
2
3
4
5
6
7
server.port=8081
#当前应用名字
dubbo.application.name=provider-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#扫描指定包下服务
dubbo.scan.base-packages=com.demo.service
登录后复制免费讲解

实现一个接口,在接口中完成需求

?
1
2
3
4
public interface Translate {
 
  String translate(String str);
}
登录后复制免费讲解
?
1
2
3
4
public interface Translate {
 
  String translate(String str);
}
登录后复制免费讲解

实现一个消费者

导入依赖, 和生产者的依赖是相同的

配置服务名字,注册中心地址

?
1
2
3
4
5
6
server.port=8082
# 配置zookeeper
# 配置服务名字
dubbo.application.name=consumer.server
# 配置注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
登录后复制免费讲解

本来正常步骤是需要将服务提供者的接口打包，然后用pom文件导入，我们这里使用简单的方式，直接将服务的接口拿过来，路径必须保证正确，即和服务提供者相同

在这里插入图片描述实

现获取翻译服务

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
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

?
1
2
3
4
5
6
7
8
9
10
11
@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

翻译成功

到此这篇关于SpringBoot中dubbo+zookeeper实现分布式开发的应用详解的文章就介绍到这了,更多相关SpringBoot dubbo zookeeper分布式内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:
蓄力AI

微信公众号搜索 “ 脚本之家 ” ，选择关注

程序猿的那些事、送书等活动等着你

原文链接：https://blog.csdn.net/Shangxingya/article/details/109840365

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若内容造成侵权/违法违规/事实不符，请将相关资料发送至 reterry123@163.com 进行投诉反馈，一经查实，立即处理！

相关文章

  • java整数(秒数)转换为时分秒格式的示例

    java整数(秒数)转换为时分秒格式的示例

    这篇文章主要介绍了java整数(秒数)转换为时分秒格式的示例,需要的朋友可以参考下
    2014-04-04
  • PowerJob的IdGenerateService工作流程源码解读

    PowerJob的IdGenerateService工作流程源码解读

    这篇文章主要为大家介绍了PowerJob的IdGenerateService工作流程源码解读,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2024-01-01
  • SpringBoot集成geodesy实现距离计算功能

    SpringBoot集成geodesy实现距离计算功能

    Geodesy：大地测量学的神奇力量 Geodesy,又称大地测量学,是一门研究地球形状、大小及其重力场的学科,在地球距离计算中,它扮演着至关重要的角色,故本文给大家介绍了SpringBoot集成geodesy实现距离计算功能,感兴趣的朋友可以参考下
    2024-06-06
  • Stream distinct根据list某个字段去重的解决方案

    Stream distinct根据list某个字段去重的解决方案

    这篇文章主要介绍了Stream distinct根据list某个字段去重,stream的distinct去重方法，是根据 Object.equals，和 Object.hashCode这两个方法来判断是否重复的，本文给大家介绍的非常详细，需要的朋友可以参考下
    2023-05-05
  • Mybatis中如何使用sum对字段求和

    Mybatis中如何使用sum对字段求和

    这篇文章主要介绍了Mybatis中如何使用sum对字段求和，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-01-01
  • Java多线程系列之JDK并发包举例详解

    Java多线程系列之JDK并发包举例详解

    Java并发包提供了许多用于多线程编程的类和接口,这篇文章主要给大家介绍了关于Java多线程系列之JDK并发包的相关资料,文中通过代码介绍的非常详细,需要的朋友可以参考下
    2024-03-03
  • spring boot里增加表单验证hibernate-validator并在freemarker模板里显示错误信息(推荐)

    spring boot里增加表单验证hibernate-validator并在freemarker模板里显示错误信息(推

    这篇文章主要介绍了spring boot里增加表单验证hibernate-validator并在freemarker模板里显示错误信息的相关资料,需要的朋友可以参考下
    2018-01-01
  • MyBatis自定义resultMap三种映射关系示例详解

    MyBatis自定义resultMap三种映射关系示例详解

    这篇文章主要介绍了MyBatis自定义resultMap三种映射关系,本文通过示例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2023-08-08
  • java HashMap,TreeMap与LinkedHashMap的详解

    java HashMap,TreeMap与LinkedHashMap的详解

    这篇文章主要介绍了 java HashMap,TreeMap与LinkedHashMap的详解的相关资料,这里提供实例代码，帮助大家学习理解 这部分的内容，需要的朋友可以参考下
    2016-11-11
  • SpringBoot中整合MyBatis-Plus的方法示例

    SpringBoot中整合MyBatis-Plus的方法示例

    这篇文章主要介绍了SpringBoot中整合MyBatis-Plus的方法示例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-09-09

最新评论