SpringBoot(9)-Dubbo+Zookeeper

embedded/2024/11/27 7:41:03/

目录

一、了解分布式系统

二、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/embedded/140840.html

相关文章

18:(标准库)DMA二:DMA+串口收发数据

DMA串口收发数据 1、DMA串口发送数据2、DMA中断串口接收定长数据包3、串口空闲中断DMA接收不定长数据包 1、DMA串口发送数据 当串口的波特率大于115200时&#xff0c;可以通过DMA1进行数据搬运&#xff0c;以防止数据的丢失。如上图所示&#xff1a;UART1的Tx发送请求使用DMA1的…

搜维尔科技:研究人员如何使用SenseGlove Nova触觉反馈手套远程操作机器人手

研究人员如何使用SenseGlove Nova触觉反馈手套远程操作机器人手 搜维尔科技&#xff1a;研究人员如何使用SenseGlove Nova触觉反馈手套远程操作机器人手

Web 表单开发全解析:从基础到高级掌握 HTML 表单设计

文章目录 前言一、什么是 Web 表单?二、表单元素详解总结前言 在现代 Web 开发中,表单 是用户与后端服务交互的重要桥梁。无论是用户登录、注册、搜索,还是提交反馈,表单都无处不在。在本文中,我们将从基础入手,全面解析表单的核心知识点,并通过示例带你轻松掌握表单开…

001 MATLAB介绍

前言&#xff1a; 软件获取渠道有很多&#xff0c;难点也就是百度网盘下载慢&#xff1b; 线上版本每月有时间限制。 01 MATLAB介绍 性质&#xff1a; MATLAB即Matrix Laboratory 矩阵实验室的意思&#xff0c;是功能强大的计算机高级语言, 已广泛应用于各学科研究部门、…

《硬件架构的艺术》笔记(九):电磁兼容性能设计指南

简介 电子线路易于接收来自其他发射器的辐射信号&#xff0c;这些EMI&#xff08;电磁干扰&#xff09;使得设备内毗邻的元件不能同时工作。这就有必要进行电磁兼容设计以避免系统内有害的电磁干扰。 确保设备不产生多余的辐射&#xff0c;设备也不易受到射频辐射的干扰&…

华纳云:服务器网络延迟问题可能由哪些因素引起?

服务器网络延迟是许多在线服务性能问题的根源&#xff0c;可能会导致网站加载缓慢、数据传输延迟甚至服务中断。网络延迟可能由多种原因引起&#xff0c;如硬件问题、网络配置错误、带宽不足或外部因素等。了解如何识别和解决这些问题对于确保服务器稳定性和提高用户体验至关重…

【已解决】ensp启动报错“启动设备AR1失败”

如果你在尝试过报错弹窗提供的解决办法之后依旧没有解决问题【比如hyper-v、网络连接的配置这些】&#xff0c;这篇文章或许会有帮助。 我的拓扑结构如下&#xff1a;&#xff08;这是问题解决后启动了的截图&#xff09; 第一次启动时报错&#xff1a;“启动设备AR1失败”&am…

SQL on Hadoop

SQL_on_Hadoop SQL on Hadoop 概述 Hadoop 提供了一种分布式存储和计算的平台&#xff0c;为了解决传统关系型数据库无法处理海量数据的问题&#xff0c;通过扩展 SQL 的方式在 Hadoop 上执行分布式查询&#xff0c;称之为 SQL on Hadoop。根据架构的不同&#xff0c;分为四种…