SpringBoot(9)-Dubbo+Zookeeper

news/2024/11/27 1:57:21/

目录

一、了解分布式系统

二、RPC

三、Dubbo

四、SpringBoot+Dubbo+Zookeeper

4.1 框架搭建

 4.2 实现RPC


一、了解分布式系统

分布式系统:由一组通过网络进行通信,为了完成共同的任务而协调工作的计算机节点组成的系统

二、RPC

RPC:远程过程调用,是一种进程间通信方式。

它允许程序调用另一个地址空间的函数

RPC的两个核心模块:通讯,序列化

三、Dubbo

Apache Dubbo是一款高性能、轻量级的开源Java PRC框架

它提供了三大核心能力:

  • 面向接口的远程方法调用
  • 智能容错和负载均衡
  • 服务的自动注册和发现

 

关系说明:

服务容器负责启动,加载,运行服务提供者

服务提供者在启动时,向注册中心注册自己提供的服务

服务消费者在启动时,向注册中心订阅自己需要的服务

注册中心返回服务提供者地址列表给消费者,若有变更,注册中心将基于长连接推送变更数据给消费者

服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用

服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心

四、SpringBoot+Dubbo+Zookeeper

4.1 框架搭建

1、启动zookeeper

2、IDEA创建一个空项目,创建两个springboot模块,勾选web依赖(分别代表服务提供者和消费者)

3、provider-server

编写service接口

编写实现类

 4、consumer-server

编写service

 4.2 实现RPC

1、导入相关依赖(Dubbo+Zookeeper)

注意:服务提供者和消费者均需要导入!

<!-- Dubbo Spring Boot Starter -->
<dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.3</version>
</dependency><!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
<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><!--排除这个slf4j-log4j12--><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion></exclusions>
</dependency>

2、服务提供者

①在springboot的配置文件中(application.properties),配置dubbo相关属性

#当前应用名字
dubbo.application.name=provider-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#扫描指定包下服务
dubbo.scan.base-packages=com.kuang.provider.service

②在service实现类中配置服务的注解

@Service:项目一启动,就自动注册到注册中心!

 3、服务消费者

①在springboot的配置文件中(application.properties),配置dubbo相关属性

#当前应用名字
dubbo.application.name=consumer-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

②在service实现类中配置服务的注解

4、测试类编写

 

5、启动测试

开启zookeeper,开启服务者(提供者、消费者),消费者进行消费测试 


http://www.ppmy.cn/news/1550210.html

相关文章

如果在docker 容器中安装ros遇到的问题

1.在容器内部无法修改时间&#xff0c;需要在宿主机外边修改时钟。修改时钟&#xff1a; hwclock --systohc或者执行 date -s "2024-11-24 19:25:10"2.容器内部内置有opencv4.5版本&#xff0c;需要卸载&#xff0c;重新安装4.2.0版本。记录折腾好久的卸载过程。 …

websocket是什么?

一、定义 Websocket是一种在单个TCP连接上进行全双工通信的协议&#xff0c;它允许服务器主动向客户端推送数据&#xff0c;而不需要客户端不断的轮询服务器来获取数据 与http协议不同&#xff0c;http是一种无状态的&#xff0c;请求&#xff0c;响应模式的协议(单向通信)&a…

CSS回顾-CSS样式优先级规则详解

一、引言 在之前梳理 CSS 选择器的文章&#xff08;CSS 回顾 - CSS 选择器详解&#xff09;中&#xff0c;我们对 CSS 选择器有了全面的认识。此刻&#xff0c;不妨思考这样一个问题&#xff1a;倘若众多不同类型的选择器均针对 h1 标签设定样式&#xff0c;究竟会呈现何种结果…

蓝网科技临床浏览系统存在SQL注入漏洞

漏洞描述 蓝网科技临床浏览系统是一个专门用于医疗行业的软件系统&#xff0c;主要用于医生、护士和其他医疗专业人员在临床工作中进行信息浏览、查询和管理。在deleteStudy.php中的接口处存在SQL注入漏洞&#xff0c;未经身份验证的恶意攻击者利用 SQL 注入漏洞获取数据库中的…

Jtti:如何知晓服务器的压力上限?具体的步骤和方法

了解服务器的压力上限(也称为性能极限或容量)是确保系统在高负载下仍能稳定运行的重要步骤。这通常通过压力测试(也称为负载测试或性能测试)来实现。以下是详细的步骤和方法来确定服务器的压力上限&#xff1a; 1. 定义测试目标和指标 在进行压力测试前&#xff0c;明确测试目标…

【Mybatis】@Param注解 resultMap手动映射

文章目录 一、映射文件参数二、查询映射2-1 一对一2-2 一对多2-3 总结 一、映射文件参数 Param 注解官方文档解释 1、单个参数&#xff08;对象&#xff09;不使用注解 public int save(User user);<!-- 添加用户 --> <insert id"save" parameterType&quo…

tcp/ip异常断开调试笔记——lwip

问题一&#xff1a;异常掉线 异常断开模拟 1、单片机端做服务端&#xff08;只监听一个客户端&#xff09;&#xff0c;电脑做客户端连接 2、尝试连接确定通信正常&#xff0c;断开网线。电脑客户端点击断开 3、经过一段时间&#xff08;超过tcp/ip 3次握手时间&#xff09…

【C++篇】深度解析 C++ List 容器:底层设计与实现揭秘

文章目录 须知 &#x1f4ac; 欢迎讨论&#xff1a;如果你在学习过程中有任何问题或想法&#xff0c;欢迎在评论区留言&#xff0c;我们一起交流学习。你的支持是我继续创作的动力&#xff01; &#x1f44d; 点赞、收藏与分享&#xff1a;觉得这篇文章对你有帮助吗&#xff1…