springboot整合dubbo实现RPC服务远程调用

一、dubbo简介

1.什么是dubbo

Apache Dubbo是一款微服务开发框架，他提供了RPC通信与微服务治理两大关键能力。有着远程发现与通信的能力，可以实现服务注册、负载均衡、流量调度等服务治理诉求。

2.dubbo基本工作原理

在这里插入图片描述

  • Contaniner:容器
  • Provider：服务提供者
  • Consumer：服务消费者
  • Registry：注册中心
  • Monitor：统计服务调用次数和调用时间的监控中心

3.具体介绍参考官方文档

文档|Apache Dubbo

二、准备dubbo-admin（管理控制台）和zookeeper（注册中心）

1.下载注册中心

docker pull zookeeper//拉取zookeeper镜像docker run -d \
​	-p 2181:2181 \
​	-v /mydata/zookeeper/data:/data  \
​	--name zookeeper \zookeeper:latest这里我的端口号为2181，我的服务器地址为192.168.31.130yml配置文件里dubbo配置应该为：dubbo.registry.address=zookeeper://192.168.31.130:2181

-d：后台启动
-p：暴露端口号
-v：数据卷挂载
–name：指定容器名称

2.下载安装dubbo-admin（dubbo的管理控制台）

docker pull dubbo-admin //拉取镜像//运行镜像
docker run -it -d \--name dubbo-admin \-v /mydata/zookeeper/dubbo-admin/data:/data \-p 9952:8080 \-e dubbo.registry.address=zookeeper://192.168.31.130:2181 \-e dubbo.admin.root.password=root -e dubbo.admin.guest.password=root \chenchuxin/dubbo-admin:latest

三、SpringBoot整合dubbo+zookeeper

分布式微服务主要是将应用的各项功能拆分成不同的模块，(根据不同的功能模块划分成不同的项目)发布在不同的服务器上，然后将需要向外提供的服务api做成分包，模块之间的相互调用通过分包api完成，dubbo的作用在于我们只需要将服务提供者的接口暴露给dubbo托管，服务消费者只要向registry注册中心注册并指定需要调用的服务，即可完成服务间调用，无需关心服务提供者的内部结构是怎样的，用户也感知不到调用了任何外部服务。

创建一个空项目，并创建commons-api、dubbo-provider、dubbo-consumer三个模块

在这里插入图片描述

3.1 在commons-api模块创建Account实体类和AccountService接口

@Data
@AllArgsConstructor
@NoArgsConstructor
public class Account implements Serializable {private int id;private String username;private double money;
}

package liao.com.service;
import liao.com.entity.Account;
import org.apache.ibatis.annotations.Param;
import java.util.List;
public interface AccountService {/*** @Description:获取所有账户信息* @Params: []* @return java.util.List<liao.com.entity.Account>*/List<Account> getAllAccounts();/*** @Description:根据用户名获取账户余额* @Params: [username]* @return double*/Account getMoney(String username);/*** @Description:增加账户余额* @Params: [username, money]* @return int*/int updateAddMoney(@Param("username") String username, @Param("money") double money);/*** @Description:减少账户余额* @Params: [username, money]* @return int*/int updateSubMoney(@Param("username") String username, @Param("money") double money);
}

最后记得install打包到本地maven仓库里，provider服务提供者和consumer服务消费者需要用到

3.2创建provider服务提供者

3.2.1添加pom.xml依赖：
		<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><!--        数据库--><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.2.2</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.20</version></dependency><!-- Dubbo Spring Boot Starter --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.8</version></dependency><dependency><!--zookerper版本一定要匹配！ --><groupId>org.apache.dubbo</groupId><artifactId>dubbo-registry-zookeeper</artifactId><version>2.7.8</version></dependency><!--这个是commons-api的maven依赖--><dependency><groupId>liao.com</groupId><artifactId>commons-api</artifactId><version>0.0.1-SNAPSHOT</version></dependency>
3.2.2application.properties文件
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.url=jdbc:mysql://localhost:3306/demo?userSSL=true&useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driverserver.port=8887
mybaits.mapper-locations=classpath:dao/*.xml
mybatis.type-aliases-package=liao.com.entity
mybatis.configration-log-impl=org.apache.ibatis.logging.stdout.StdOutImpldubbo.application.name=dubbo-provider-service
dubbo.registry.address=zookeeper://192.168.31.130:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20887
dubbo.scan.base-packages=liao.com
dubbo.registry.timeout=30000
3.2.3AccountDao.xml文件
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="liao.com.dao.AccountDao"><select id="getAccountByName" resultType="liao.com.entity.Account" parameterType="String">select id, username, money from account where username = #{username}</select><update id="updateAddMoney">update account set money = money + #{money} where username = #{username}</update><update id="updateSubMoney">update account set money = money - #{money} where username = #{username}</update><select id="getAllAccounts" resultType="liao.com.entity.Account">select id, username, money from account</select>
</mapper>
3.2.4创建AccountDao
package liao.com.dao;import liao.com.entity.Account;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;import java.util.List;/*** @author: lehu* @Description:账户类接口* @Params:* @return* @date 2024-04-13 02:38*/@Mapper
@Repository
public interface AccountDao {/*** @Description:获取所有账户信息* @Params: []* @return java.util.List<liao.com.entity.Account>*/List<Account> getAllAccounts();/*** @Description:根据用户名获取账户余额* @Params: [username]* @return double*//*@Select("SELECT id, username,money FROM account WHERE username = #{username}")*/Account getMoney(String username);/*** @Description:增加账户余额* @Params: [username, money]* @return int*//*@Select("UPDATE account SET money = money + #{param2} WHERE username = #{param1}")*/int updateAddMoney(@Param("username") String username, @Param("money") double money);/*** @Description:减少账户余额* @Params: [username, money]* @return int*/int updateSubMoney(@Param("username") String username, @Param("money") double money);
}
3.2.5创建AccountServiceImpl

//@DubboService注解标识该服务是服务提供者provider
@DubboService(version = "1.0.0")
//实现的AccountService接口导入Commons-api模块下的
public class AccountServiceImplPlus implements AccountService {@Resourceprivate AccountDao accountDao;@Overridepublic List<Account> getAllAccounts() {return accountDao.getAllAccounts();}@Overridepublic Account getMoney(String username) {return accountDao.getAccountByName(username);}@Overridepublic int updateAddMoney(String username, double money) {return accountDao.updateAddMoney(username, money);}@Overridepublic int updateSubMoney(String username, double money) {return accountDao.updateSubMoney(username, money);}}

3.3创建consumer服务消费者

依赖和provider服务提供者一样
application.properties配置文件也类似

创建AccountController

@RestController
@Slf4j
public class AccountController {//@Reference代表是服务消费者，这里的AccountService接口也是导入的Commons-api模块里的@Reference(version = "1.0.0")private AccountService accountService;@RequestMapping("/getAccounts")public List<Account> getAccounts() {List<Account> allAccounts = accountService.getAllAccounts();log.info("allAccounts:{}", allAccounts);return allAccounts;}@RequestMapping("/getMoenyByUsername")public void addAccount(String username, String param1, double param2) {Account account = accountService.getMoney(username);log.info("account:{}", account);if (account.getMoney() > 10000) {accountService.updateAddMoney(param1, param2);}}@RequestMapping("/getAccountByUsername")public Account getAccountByUsername(@Param("username") String username) {Account account = accountService.getMoney(username);log.info("account:{}", account);return account;}@RequestMapping("/addAccount")public String addAccount(@Param("username") String username, @Param("money") Double money) {int i = accountService.updateAddMoney(username, money);if (i > 0) {return "success";} else {return "fail";}}@RequestMapping("/subAccount")public String subAccount(@Param("username") String username, @Param("money") Double money) {int i = accountService.updateSubMoney(username, money);if (i > 0) {return "success";} else {return "fail";}}}
3.3测试

先启动服务提供者，再启动服务消费者
用postman测试一下基于Dubbo+Zookeeper的RPC远程服务调用

查询所有账户信息：
在这里插入图片描述

根据用户名来查询Account账户信息：
在这里插入图片描述

根据用户名来给用户转账：
在这里插入图片描述
再来查询不良帅的余额：
在这里插入图片描述

四、在zookeeper客户端命令查看dubbo服务的生产者与消费者

在这里插入图片描述
现在我的zookeeper注册中心部署在docker容器里，需要通过命令：docker exec -it 容器id /bin/bash进入容器内部
在这里插入图片描述

4.1进入容器内部后切换到bin目录下

docker exec -it 容器id /bin/bash //进入容器内部
cd bin //切换到bin目录

4.2 执行命令./zkCli.sh

./zkCli.sh

4.3 在命令行输入ls /dubbo,即可查到dubbo服务对外提供的接口，如下图：

在这里插入图片描述

4.4 查看消费者命令：

ls /dubbbo/liao.com.service.AccountService/consumers

会看到消费者的信息，截图如下：
在这里插入图片描述

4.5 查看生产者命令：

ls /dubbo/liao.com.common.CommonService/providers

会看到生产者的信息，截图如下：
在这里插入图片描述

OK结束！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/822129.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

[AI]-(第0期)：认知深度学习

[AI]-(第0期)：认知深度学习

深度学习是一种人工智能&#xff08;AI&#xff09;方法&#xff0c;用于教计算机以受人脑启发的方式处理数据。 深度学习模型可以识别图片、文本、声音和其他数据中的复杂模式&#xff0c;从而生成准确的见解和预测。 您可以使用深度学习方法自动执行通常需要人工智能完成的…
阅读更多...
【C++】set 类 和 map 类

【C++】set 类 和 map 类

1. 关联式容器 关联式容器也是用来存储数据的&#xff0c;与序列式容器不同的是&#xff0c;其里面存储的是<key, value>结构的 键值对&#xff0c;在数据检索时比序列式容器效率更高 2. 键值对 用来表示具有一一对应关系的一种结构&#xff0c;该结构中一般只包含…
阅读更多...
Pytorch(GPU版本)简介、安装与测试运行

Pytorch(GPU版本)简介、安装与测试运行

目录 Pytorch简介Pytorch安装查看CUDA版本Pytorch命令安装Pytorch测试运行Pytorch简介 PyTorch是一个开源的Python机器学习库，基于Torch，用于自然语言处理等应用程序。PyTorch既可以看作加入了GPU支持的numpy，同时也可以看成一个拥有自动求导功能的强大的深度神经网络。 2…
阅读更多...
Linux进阶篇：Centos7安装与配置mysql（rpm安装方式）

Linux进阶篇：Centos7安装与配置mysql（rpm安装方式）

Linux服务搭建篇&#xff1a;Centos7安装与配置mysql&#xff08;rpm安装方式&#xff09; MySQL是一个开源的关系型数据库管理系统&#xff0c;由瑞典MySQL AB公司开发&#xff0c;现在属于Oracle公司。MySQL是最流行的关系型数据库管理系统之一&#xff0c;在WEB应用方面&am…
阅读更多...
【架构-14】数据库性能优化方式

【架构-14】数据库性能优化方式

数据库出现性能瓶颈对外的表现为&#xff1a; 大量请求阻塞SQL操作变慢存储出现问题 为解决上述出现的问题&#xff0c;因此推出了一系列的数据库性能优化方式。 数据库性能优化是提高数据库系统性能和响应时间的关键任务。以下是一些常见的 数据库性能优化方式&#xff1a; …
阅读更多...
锂电池充放电管理-单片机通用

锂电池充放电管理-单片机通用

锂电池充放电管理-单片机通用 一、锂电池充放电检测的原理二、power.c的实现三、power.h的实现四、锂电池检测和充电电路 一、锂电池充放电检测的原理 ①两节锂电池通过电阻分压检测ADC&#xff0c;再根据电压划分电量等级&#xff1b;②充电使用的是锂电池充电IC方案&#xf…
阅读更多...
【问题解决分享】银河麒麟高级服务器操作系统oom分析

【问题解决分享】银河麒麟高级服务器操作系统oom分析

1.问题现象描述 服务器数据库被oomkill掉&#xff0c;但是mem查看只占用了不到60%。 2.问题分析 2.1.oom现象分析 从下面的日志信息&#xff0c;可以看到chmod进程是在内核采用GFP_KERNEL|__GFP_COMP分配order3也就是2的3次方&#xff0c;8个连续页的时候&#xff0c;因进入…
阅读更多...
Hadoop大数据处理技术-安装配置篇

Hadoop大数据处理技术-安装配置篇

2024/4/16 ​Hadoop学习前的准备 1&#xff09;首先安装虚拟机 VMWare 虚拟机&#xff1a;因为它不是一个硬件 而是用软件做出来的 模拟真机 所以叫做虚拟机 但实际上它里面也可以安装Linux和Windows 实际它的实现 虚拟机中想要实现某个操作时 将需求发给Windows 调用Windo…
阅读更多...
十大排序——7.希尔排序

十大排序——7.希尔排序

下面我们来看一下希尔排序 目录 1.介绍 2.代码实现 3.总结与思考 1.介绍 希尔排序是插入排序的一种优化&#xff0c;可以理解为是一种分组的插入排序。 希尔排序的要点&#xff1a; 简单来说&#xff0c;就是分组实现插入&#xff0c;每组元素的间隙称为gap&#xff0c;…
阅读更多...
leetcode-合并两个有序链表

leetcode-合并两个有序链表

目录 题目 图解 方法一 方法二 代码(解析在注释中) 方法一 ​编辑方法二 题目 将两个升序链表合并为一个新的 升序 链表并返回。新链表是通过拼接给定的两个链表的所有节点组成的。 示例 1&#xff1a; 输入&#xff1a;l1 [1,2,4], l2 [1,3,4] 输出&#xff1a;[1,1…
阅读更多...
OpenStack镜像管理与制作

OpenStack镜像管理与制作

一、OpenStack镜像服务 1、什么是镜像 镜像通常是指一系列文件或一个磁盘驱动器的精确副本。虚拟机所使用的虚拟磁盘&#xff0c;实际上是一种特殊格式的镜像文件。云环境下尤其需要镜像。镜像就是一个模板&#xff0c;类似于VMware的虚拟机模板&#xff0c;其预先安装基本的…
阅读更多...
MySql数据库从0-1学习-第五天事务和索引

MySql数据库从0-1学习-第五天事务和索引

事务 事务 是一组操作的集合&#xff0c;它是一个不可分割的工作单位。事务会把所有的操作作为一个整体一起向系统提交或撤销操作请求&#xff0c;即这些操作 要么同时成功&#xff0c;要么同时失败。 注意事项,默认事务是自动提交的,也就是说,当执行一条DML语句,MySql会立即隐…
阅读更多...
计算机网络的七层模型

计算机网络的七层模型

序 OSl(Open System Interconnect)&#xff0c;即开放式系统互联。一般都叫OSI参考模型。在网络编程中最重要的模型就是OSI七层网络模型和TCP/IP四层网络模型 一、OSI七层参考模型以及功能概述 二、各层的具体职能以及实际应用 1.应用层&#xff1a; OSI参考模型中最接近用…
阅读更多...
【高端电流检测IC储能产品应用方案】耐压45V侧轨的电流检测芯片FP137 应用于电脑电源，开关电源以及多口快充充电器，户外移动电源，适配器，电池充电器等

【高端电流检测IC储能产品应用方案】耐压45V侧轨的电流检测芯片FP137 应用于电脑电源，开关电源以及多口快充充电器，户外移动电源，适配器，电池充电器等

近年来&#xff0c;随着电子产品的飞速发展&#xff0c;对电流检测精度和可靠性的要求也越来越高。特别是在电脑电源、开关电源以及多口快充充电器、户外移动电源、适配器、电池充电器等领域&#xff0c;对电流检测技术的需求更是日益增长。 电流检测芯片是一种关键的电子元器…
阅读更多...
day02|最小花费爬梯子

day02|最小花费爬梯子

最小花费爬梯子 比如 有一个数组 【2 5 20】我们直接选择从1号梯子&#xff08;从零编号&#xff09;跳两格就出去了。 算法原理 我们可以得出楼顶其实是数组的最后一个元素的下一个位置。对于最值问题我们可以尝试使用dpdp我们首先应该定义状态方差的含义&#xff0c;一般以…
阅读更多...
stm32实现hid鼠标

stm32实现hid鼠标

启动CubelMX 选择芯片&#xff08;直接输入stm32f103zet6) 设置时钟 如下图 usb设置 配置usb设备 调试端口设置 配置时钟 项目输出设置 打开工程&#xff08;后记&#xff1a;此工程含有中文不能编译通过) 配置项目 配置调试器 编译无法通过 删除路径中的中文&#xff0c;以及…
阅读更多...
[大模型]InternLM2-7B-chat Xtuner Qlora 微调

[大模型]InternLM2-7B-chat Xtuner Qlora 微调

InternLM2-7B-chat Xtuner Qlora 微调 Xtuner介绍 XTuner是上海人工智能实验室开发的低成本大模型训练工具箱&#xff0c;XTuner 是一个高效、灵活、全能的轻量化大模型微调工具库。只要8G。最低只需 8GB 显存&#xff0c;就可以微调InternLM2-7B模型&#xff0c;打造专属于你…
阅读更多...
强强联手|AI赋能智能工业化，探索AI在工业领域的应用

强强联手|AI赋能智能工业化，探索AI在工业领域的应用

随着人工智能&#xff08;AI&#xff09;技术的不断发展和应用&#xff0c;AI在各个领域展现出了巨大的潜力和价值。在工业领域&#xff0c;AI的应用也越来越受到关注。AI具备了丰富的功能和强大的性能&#xff0c;为工业领域的发展带来了巨大的机遇和挑战。 YesPMP是专业的互联…
阅读更多...
复习回顾ES6基础篇（一小时学会es6）

复习回顾ES6基础篇（一小时学会es6）

基本语法 多行注释 /* 这里的所有内容 都是注释。 */单行注释 // 这是一条注释。变量定义 var x "" //定义范围变量 let y "" //定义局部变量 const z "" //定义常量运算符 变量类型 流程语句 if (condition) {/* 条件为真时运行的代…
阅读更多...
【位运算 子集状态压缩】982按位与为零的三元组

【位运算 子集状态压缩】982按位与为零的三元组

算法可以发掘本质&#xff0c;如&#xff1a; 一&#xff0c;若干师傅和徒弟互有好感&#xff0c;有好感的师徒可以结对学习。师傅和徒弟都只能参加一个对子。如何让对子最多。 二&#xff0c;有无限多1X2和2X1的骨牌&#xff0c;某个棋盘若干格子坏了&#xff0c;如何在没有坏…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023