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.hqwc.cn/news/624976.html

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

相关文章

Spring Boot 处理过滤器(filter )中抛出的异常

Spring Boot 处理过滤器(filter )中抛出的异常

前言&#xff1a; 在改造老项目登录功能的时候&#xff0c;使用了过滤器对 token 进行有效性验证&#xff0c;验证通过继续进行业务请求&#xff0c;验证不通过则抛出校验异常。 过程&#xff1a; 技术方案拟定后&#xff0c;就着手开始改造&#xff0c;一切都很顺畅&#x…
阅读更多...
机器学习-11-基于多模态特征融合的图像文本检索

机器学习-11-基于多模态特征融合的图像文本检索

总结 本系列是机器学习课程的系列课程&#xff0c;主要介绍机器学习中图像文本检索技术。此技术把自然语言处理和图像处理进行了融合。 参考 2024年&#xff08;第12届&#xff09;“泰迪杯”数据挖掘挑战赛 图像特征提取&#xff08;VGG和Resnet特征提取卷积过程详解&…
阅读更多...
【ARFoundation自学01】搭建AR框架，检测平面点击位置克隆物体

【ARFoundation自学01】搭建AR框架，检测平面点击位置克隆物体

Unity开发ARFoundation相关应用首先安装ARFoundation包 然后设置XR 1.基础AR场景框架搭建 2.一个基本的点击克隆物体到识别的平面脚本 挂在XROrigin上 脚本AppController 脚本说明书 ## 业务逻辑 AppController 脚本旨在实现一个基本的 AR 应用程序功能&#xff1a;用户通过…
阅读更多...
Redis的Stream 和 实现队列的方式【List、SortedSet、发布订阅、Stream、Java】

Redis的Stream 和 实现队列的方式【List、SortedSet、发布订阅、Stream、Java】

Redis队列与Stream、Redis 6多线程详解 Redis队列与StreamStream总述常用操作命令生产端消费端单消费者消费组消息消费 Redis队列几种实现的总结基于List的 LPUSHBRPOP 的实现基于Sorted-Set的实现PUB/SUB&#xff0c;订阅/发布模式基于Stream类型的实现与Java的集成 消息队列问…
阅读更多...
MaxCompute 近实时增全量处理一体化新架构和使用场景介绍

MaxCompute 近实时增全量处理一体化新架构和使用场景介绍

随着当前数据处理业务场景日趋复杂&#xff0c;对于大数据处理平台基础架构的能力要求也越来越高&#xff0c;既要求数据湖的大存储能力&#xff0c;也要求具备海量数据高效批处理能力&#xff0c;同时还可能对延时敏感的近实时链路有强需求&#xff0c;本文主要介基于 MaxComp…
阅读更多...
复习回顾ES6基础篇（一小时学会es6）

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

基本语法 多行注释 /* 这里的所有内容 都是注释。 */单行注释 // 这是一条注释。变量定义 var x "" //定义范围变量 let y "" //定义局部变量 const z "" //定义常量运算符 变量类型 流程语句 if (condition) {/* 条件为真时运行的代…
阅读更多...
02_Fixture定位,Caliper卡尺工具,几何学工具

02_Fixture定位,Caliper卡尺工具,几何学工具

Fixture定位工具 需求: 测量工件的尺寸 使用Caliper(卡尺)工具 这个时候需要借助Fixture工具 VisionPro中的图像空间 “” 图像的当前空间&#xff0c;即CogImage中的“SelectedSpaceName”表示的名字空间 “#” 像素空间&#xff0c;即坐标原点为图片左上角的坐标空间&am…
阅读更多...
在Linux操作系统中，修改文件目录权限常用的命令操作

在Linux操作系统中，修改文件目录权限常用的命令操作

修改文件的属主或者是属组 命令chown 用户名.用户组名&#xff0c;文件路径 如上图所示&#xff0c;使用命令 chown martin.caiwu /opt/test/1.txt 将文件1.txt的属主修改为martin 。 将文件1.txt的属组修改为caiwu 如上图所示&#xff0c;使用命令chown .jishu /opt/test/…
阅读更多...
【深度学习】【机器学习】用神经网络进行入侵检测，NSL-KDD数据集，基于机器学习（深度学习）判断网络入侵，网络攻击，流量异常【3】

【深度学习】【机器学习】用神经网络进行入侵检测，NSL-KDD数据集，基于机器学习（深度学习）判断网络入侵，网络攻击，流量异常【3】

之前用NSL-KDD数据集做入侵检测的项目是&#xff1a; 【1】https://qq742971636.blog.csdn.net/article/details/137082925 【2】https://qq742971636.blog.csdn.net/article/details/137170933 有人问我是不是可以改代码&#xff0c;我说可以。 训练 我将NSL_KDD_Final_1.i…
阅读更多...
微软正式发布Copilot for Security

微软正式发布Copilot for Security

微软公司近日宣布&#xff0c;其备受期待的安全自动化解决方案——Copilot for Security现已全面上市&#xff0c;面向全球用户开放。这一创新工具的推出标志着微软在提升企业安全防护能力方面迈出了重要一步&#xff0c;同时也为安全专业人士提供了强大的支持。 Copilot for …
阅读更多...
【机器学习】贝叶斯算法在机器学习中的应用与实例分析

【机器学习】贝叶斯算法在机器学习中的应用与实例分析

贝叶斯算法在机器学习中的应用与实例分析 一、贝叶斯算法原理及重要性二、朴素贝叶斯分类器的实现三、贝叶斯网络在自然语言处理中的应用四、总结与展望 在人工智能的浪潮中&#xff0c;机器学习以其独特的魅力引领着科技领域的创新。其中&#xff0c;贝叶斯算法以其概率推理的…
阅读更多...
Kafka、RabbitMQ、Pulsar、RocketMQ基本原理和选型

Kafka、RabbitMQ、Pulsar、RocketMQ基本原理和选型

Kafka、RabbitMQ、Pulsar、RocketMQ基本原理和选型 1. 消息队列1.1 消息队列使用场景1.2. 消息队列模式1.2.1 点对点模式&#xff0c;不可重复消费1.2.2 发布/订阅模式 2. 选型参考2.1. Kafka2.1.1 基本术语2.1.2. 系统框架2.1.3. Consumer Group2.1.4. 存储结构2.1.5. Rebalan…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023