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.rhkb.cn/news/311845.html

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

相关文章

Linux内核之WRITE_ONCE用法实例(四十八)

Linux内核之WRITE_ONCE用法实例(四十八)

简介&#xff1a; CSDN博客专家&#xff0c;专注Android/Linux系统&#xff0c;分享多mic语音方案、音视频、编解码等技术&#xff0c;与大家一起成长&#xff01; 优质专栏&#xff1a;Audio工程师进阶系列【原创干货持续更新中……】&#x1f680; 优质专栏&#xff1a;多媒…
阅读更多...
分析ARP解析过程

分析ARP解析过程

1、实验环境 主机A和主机B连接到交换机&#xff0c;并与一台路由器互连&#xff0c;如图7.17所示&#xff0c;路由器充当网关。 图7.17 实验案例一示意图 2、需求描述 查看 ARP 相关信息,熟悉在PC 和 Cisco 设备上的常用命令,设置主机A和主机B为同一个网段网关设置为路由接…
阅读更多...
【Conda基础命令】使用conda创建、查看、删除虚拟环境及可能的报错处理

【Conda基础命令】使用conda创建、查看、删除虚拟环境及可能的报错处理

文章目录 前言&#xff08;1&#xff09; 在默认路径下创建一个新的虚拟环境&#xff08;2&#xff09; 查看已有的虚拟环境&#xff08;3&#xff09; 删除已有的虚拟环境&#xff08;谨慎操作&#xff09;&#xff08;4&#xff09;激活虚拟环境&#xff08;5&#xff09;退出…
阅读更多...
OpenCV轻松入门（八）——图片卷积

OpenCV轻松入门（八）——图片卷积

对图像和滤波矩阵进行逐个元素相乘再求和的操作就相当于将一个二维的函数移动到另一个二维函数的所有位置&#xff0c;这个操作就叫卷积。 卷积需要4个嵌套循环&#xff0c;所以它并不快&#xff0c;除非我们使用很小的卷积核。这里一般使用3x3或者5x5 图像滤波 图像滤波是尽…
阅读更多...
P9241 [蓝桥杯 2023 省 B] 飞机降落

P9241 [蓝桥杯 2023 省 B] 飞机降落

原题链接&#xff1a;[蓝桥杯 2023 省 B] 飞机降落 - 洛谷 目录 1. 题目描述 2. 思路分析 3. 代码实现 1. 题目描述 2. 思路分析 dfs全排列的变形题。 因为最后问飞机是否降落&#xff0c;并且一架飞机降落完毕时另一架飞机才能降落。所以我们设置dfs的两个变量cnt为安全…
阅读更多...
通过adb 命令打印安装在第三方模拟器上的log

通过adb 命令打印安装在第三方模拟器上的log

1&#xff0c;环境&#xff1a;Windows 11 &#xff0c;第三方模拟器 网易的MuMu 步骤&#xff1a; 1&#xff0c;打开cmd&#xff0c;输入 adb connect 172.0.0.1:7555 2&#xff0c;在cmd&#xff0c;再次输入adb logcat 回车
阅读更多...
案例分析-redis

案例分析-redis

案例需求&#xff1a;在7002这个slave节点执行手动故障转移&#xff0c;重新夺回master地位 步骤如下&#xff1a; 1&#xff09;利用redis-cli连接7002这个节点 2&#xff09;执行cluster failover命令 如图&#xff1a; 效果&#xff1a; 4.5.RedisTemplate访问分片集群 …
阅读更多...
一个文生视频MoneyPrinterTurbo项目解析

一个文生视频MoneyPrinterTurbo项目解析

最近抖音剪映发布了图文生成视频功能，同时百家号也有这个功能，这个可以看做是一个开源的实现，一起看看它的原理吧~ 一句话提示词 大模型生成文案 百家号生成视频效果 MoneyPrinterTurbo生成视频效果 天空为什么是蓝色的？ 天空之所以呈现蓝色，是因为大气中的分子和小粒子会…
阅读更多...
死磕GMSSL通信-java/Netty系列（二）

死磕GMSSL通信-java/Netty系列（二）

死磕GMSSL通信-java/Netty系列（二） 在上一篇文章中，我们探讨了如何利用C/C++实现国密通信。而本文将聚焦于Java环境下，特别是基于Netty框架，如何实现与国密系统的安全通信。为了确保新项目遵循最新的国密标准，我们将优先推荐使用GB/T 38636-2020（TLCP）协议。对于Java开…
阅读更多...
怎么转行做产品经理？

怎么转行做产品经理？

小白转产品经理第一点要先学基础理论知识&#xff0c;学了理论再去实践&#xff0c;转行&#xff0c;跳槽&#xff01; 学理论比较好的就是去报NPDP的系统班&#xff0c;考后也会有面试指导课、职场晋升课程&#xff0c;对小白来说非常合适了~&#xff08;B站&#xff1a;不爱…
阅读更多...
微软正式发布Copilot for Security

微软正式发布Copilot for Security

微软公司近日宣布&#xff0c;其备受期待的安全自动化解决方案——Copilot for Security现已全面上市&#xff0c;面向全球用户开放。这一创新工具的推出标志着微软在提升企业安全防护能力方面迈出了重要一步&#xff0c;同时也为安全专业人士提供了强大的支持。 Copilot for …
阅读更多...
图数据库Neo4J入门——Neo4J下载安装+Cypher基本操作+《西游记》人物关系图实例

图数据库Neo4J入门——Neo4J下载安装+Cypher基本操作+《西游记》人物关系图实例

这里写目录标题 一、效果图二、环境准备三、数据库设计3.1 人物节点设计3.2 关系设计 四、操作步骤4.1 下载、安装、启动Neo4J服务4.1.1 配置Neo4J环境变量4.1.2 启动Neo4J服务器4.1.3 启动Ne04J客户端 4.2 创建节点4.3 创建关系&#xff08;从已有节点创建关系&#xff09;4.4…
阅读更多...
百度智能云万源全新一代智能计算操作系统发布：引领AI新纪元，开启智能未来

百度智能云万源全新一代智能计算操作系统发布：引领AI新纪元，开启智能未来

随着科技的迅猛发展&#xff0c;人工智能&#xff08;AI&#xff09;逐渐渗透到我们生活的每个角落&#xff0c;为人类社会带来前所未有的变革。在这场科技革命的浪潮中&#xff0c;百度作为中国AI领域的领军企业&#xff0c;始终站在技术创新的前沿&#xff0c;不断引领行业发…
阅读更多...
数字电路（四，五章总结）

数字电路（四，五章总结）

四.组合逻辑电路设计 由波形图列真值表&#xff0c;之 后画出卡诺图&#xff0c;写出最简逻辑表达式。 卡诺图化简的时候圈住的部分如果某个字母有0又有1的话这个字母删掉&#xff0c;写出其他两个字母。 如下图中黄圈A有0又有1则删除A&#xff0c;这样黄圈代表BC;同理绿圈代…
阅读更多...
35、链表-LRU缓存

35、链表-LRU缓存

思路&#xff1a; 首先要了解LRU缓存的原理&#xff0c;首先定下容量&#xff0c;每次get请求和put请求都会把当前元素放最前/后面&#xff0c;如果超过容量那么头部/尾部元素就被移除&#xff0c;所以最近最少使用的元素会被优先移除&#xff0c;保证热点数据持续存在。 不管放…
阅读更多...
【Java】@RequestMapping注解在类上使用

【Java】@RequestMapping注解在类上使用

RequestMapping 是 Spring Web 应用程序中最常被用到的注解之一。这个注解会将 HTTP 请求映射到控制器&#xff08;controller类&#xff09;的处理方法上。 Request Mapping 基础用法 在 Spring MVC 应用程序中&#xff0c;RequestDispatcher (在 Front Controller 之下) 这…
阅读更多...
MapReduce 机理

MapReduce 机理

1.hadoop 平台进程 Namenode进程: 管理者文件系统的Namespace。它维护着文件系统树(filesystem tree)以及文件树中所有的文件和文件夹的元数据(metadata)。管理这些信息的文件有两个&#xff0c;分别是Namespace 镜像文件(Namespace image)和操作日志文件(edit log)&#xff…
阅读更多...
命令模式

命令模式

命令模式&#xff1a;将一个请求封装为一个对象&#xff0c;从而使你可用不同的请求对客户进行参数化&#xff1b;对请求排队或记录请求日志&#xff0c;以及支持可撤销的操作。 命令模式的好处&#xff1a; 1、它能较容易地设计一个命令队列&#xff1b; 2、在需要的情况下&a…
阅读更多...
【Phytium】飞腾D2000 UEFI/EDK2 适配 RTC(IIC SD3077)

【Phytium】飞腾D2000 UEFI/EDK2 适配 RTC(IIC SD3077)

文章目录 0. env1. 软件2. 硬件 10. 需求1. 硬件2. 软件 20. DatasheetCPURTC 30. 调试步骤1. 硬件环境搭建2. UEFI 开发环境搭建3. 修改步骤1. UEFI 中使能RTC驱动、配置RTC信息等1.1 使能RTC驱动1.2 修改RTC对应的IIC配置信息1.3 解决驱动冲突1.4 验证波形 2. 修改对应RTC驱动…
阅读更多...
1、MYSQL系列-深入理解Mysql索引底层数据结构与算法

1、MYSQL系列-深入理解Mysql索引底层数据结构与算法

索引的本质 索引是帮助MySQL高效获取数据的排好序的数据结构 索引数据结构 二叉树红黑树Hash表BTree B-Tree B-Tree 叶节点具有相同的深度&#xff0c;叶节点的指针为空&#xff0c;所有索引元素不重复&#xff0c;节点中的数据索引从左到右递增排列 BTree(B-Tree变种) 非叶…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023