Mybatis-Plus+Nacos+Dubbo进行远程RPC调用保姆级教程-6ren

Mybatis-Plus+Nacos+Dubbo进行远程RPC调用保姆级教程

转载作者：我是一只小鸟更新时间：2023-08-19 21:56:50

默认你已经看过我之前的教程了，并且拥有上个教程完成的项目，。

之前的教程 https://www.cnblogs.com/leafstar/p/17638782.html 。

项目链接在最后。

。

1.在bank1的pom文件中引入以下依赖。

                          <dependency>
 　　<groupId>org.apache.dubbo</groupId>
　　 <artifactId>dubbo-spring-boot-starter</artifactId>
　　 <version>2.7.8</version>
</dependency>

。

2.使用dubboService一般是需要在Service层上进行，现在我们假设bank2的Bank2Service（还没有新建）提供dubboService 。

新建Bank2Service如下。

代码如下。

                          
                            @Autowired
                            

                          
                          
                            private
                          
                          
                             User2Mapper user2Mapper;
@Override

                          
                          
                            public
                          
                           String addAmount(String name,
                          
                            int
                          
                          
                             amount){
    User user
                          
                          =
                          
                            null
                          
                          
                            ;
    user 
                          
                          = user2Mapper.selectOne(
                          
                            new
                          
                           LambdaQueryWrapper<User>
                          
                            ().eq(StringUtils.isEmpty(name), User::getName, name));
    
                          
                          
                            if
                          
                           (user==
                          
                            null
                          
                          
                            ){
        
                          
                          
                            throw
                          
                          
                            new
                          
                           RuntimeException("name为空或用户不存在"
                          
                            );
    }
    user.setAmount(user.getAmount()
                          
                          +
                          
                            amount);
    
                          
                          
                            int
                          
                           i = user2Mapper.update(user, 
                          
                            new
                          
                           LambdaQueryWrapper<User>
                          
                            ().eq(User::getName, name));
    
                          
                          
                            return
                          
                           i>0?"成功":"失败"
                          
                            ;
}

这样我们的Bank2Service就同时提供RPC服务和本地服务了。

。

3.接下来我们来模拟跨行转账。

bank1的用户小明有1000元，向bank2的用户小红，原来有800元，转帐100元。

我们现在已经写好了bank2的账户增加金额服务。

接下来实现bank1的相关操作。

bank1引入以下依赖。

                          <dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>2.7.8</version>
</dependency>
        
<dependency>
    <groupId>com.example</groupId>
    <artifactId>bank2</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <scope>compile</scope>
</dependency>

然后在bank1的controller里面添加bank2的远程服务。

                        @DubboReference
                        

                        private Bank2Service bank2Service;
                        

                        在其controller里面添加以下接口

                          @GetMapping("/transfer"
                          
                            )

                          
                          
                            public
                          
                           String transfer(String from,
                          
                            int
                          
                          
                             amount,String to){
    
                          
                          
                            //
                          
                          
                            默认参数不为空，不在校验
    
                          
                          
                            //
                          
                          
                            from账户减少金额
                          
                          
    User user = user1Mapper.selectOne(
                          
                            new
                          
                           LambdaQueryWrapper<User>
                          
                            ().eq(User::getName, from));
    user.setAmount(user.getAmount()
                          
                          -
                          
                            amount);
    user1Mapper.update(user,
                          
                          
                            new
                          
                           LambdaQueryWrapper<User>
                          
                            ().eq(User::getName, from));
    
                          
                          
                            //
                          
                          
                            to账户添加金额
                          
                          
                                bank2Service.addAmount(to,amount);
    
                          
                          
                            return
                          
                           "转账成功"
                          
                            ;
}

。

4.将两个项目重新运行。

此时会报这个错误。

@Service interfaceClass() or interfaceName() or interface class must be present.

我们需要把bank2的Service实现一个接口，利用这个接口进行RPC调用。

bank2中添加以下接口。

对服务进行稍微修改如下。

接下来将bank1下controller原来写的。

                        @DubboReference
                        

                        private Bank2Service bank2Service;
                        

                        改成

                        @DubboReference
                        

                        private Bank2Interface bank2Service;

5.重启项目，报错如下。

                        
                           No registry config found or it's not a valid config! The registry config is: <dubbo:registry />

因为我们没有dubbo配置，接下来进行配置，在两个项目的配置文件中直接添加下列内容。

                          
                            dubbo:
  #指定当前服务
  #  application:
  #    name: bank1
  #    qos
                          
                          -enable: 
                          
                            false
                          
                          
                            
  #注册中心
  registry:
    protocol: nacos
    address: 
                          
                          127.0.0.1:8848
                          
                            
  #配置consumer启动时检查，check为false时，启动不检查,超时配置
  #consumer中配置的是全局配置
  # 幂等【操作多少次结果都是一样的，如：查询、删除、修改】，在设计系统是应该设置成幂等的
  # 非幂等操作【和幂等对立，每次操作的结果不一样，如：新增，修改】，不能设置成重试
  consumer:
    check: 
                          
                          
                            false
                          
                          
                            
    #重试次数，不算第一次
    retries: 
                          
                          3
                          
                            
    timeout: 
                          
                          6000
                          
                            
    # filter: logDubboConsumerFilter
  #指定通信规则
  protocol:
    name: dubbo
    port: 
                          
                          8806
                          
                             #暴露服务端口（默认20880，不同的服务消费者端口不能重复）
    threadpool: cached
  #暴露服务
  provider:
    filter: 
                          
                          -
                          
                            exception
    loadbalance: leastactive
    timeout: 
                          
                          6000
                          
                            
  #监控中心
#  monitor:
#    protocol: registry

在bank2的启动类上加上@EnableDubbo注解。

至此，项目基本搭建完成，重启项目，如果遇到端口错误，请往下看。

nacos中出现下图代表服务注册成功。

。

6.可能遇到一个非常奇怪的问题，bank1的nacos配置和bootstrap.yml配置的端口皆是8080，但是bank1就是不使用8080端口而是使用bank2的配置端口。

可能是bootstrap文件会先于application文件加载。bank1的bootstrap.yml被bank2的application.yml覆盖.

解决办法，在bank1的bootstrap.yml同级目录下新建application.yml，在里面指定端口号即可.

在此也感谢某位不愿透露姓名的热心大哥的帮助。最后如下图。

。

7.ok,重启项目，一切就绪。开始测试，调用下面get接口，也可以直接把网址放到浏览器中调用。

。

观察数据库，确实小明成功减少100，小红增加了100，。

。

8.至此，我们成功模拟了两个不同数据库下的微服务，不同网络下的微服务，通过dubbo进行RPC远程调用.

。

9.验证，在两个bank项目的配置文件中添加以下配置。

                          mybatis-
                          
                            plus:
  configuration:
    log
                          
                          -impl: org.apache.ibatis.logging.stdout.StdOutImpl

重新调用接口，可以看出两个项目都有输出，说明确实是bank1引用了bank2的服务，而不是在bank1内部调用的bank2 。

。

10.如果你想到这样可能会导致数据不一致等问题，请看后续文章~~ 。

。

11.截止目前项目 https://wwta.lanzoub.com/id4BU15p6usb，后续会上传git 。

最后此篇关于Mybatis-Plus+Nacos+Dubbo进行远程RPC调用保姆级教程的文章就讲到这里了,如果你想了解更多关于Mybatis-Plus+Nacos+Dubbo进行远程RPC调用保姆级教程的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！。

文章推荐： React请求机制优化思路

文章推荐： MyBatisMapper映射处理CLOB和BLOB类型

文章推荐：使用“断点组”来简化调试

文章推荐： .NET周刊【8月第2期2023-08-14】

Javascript AJAX 调用 Jquery 调用
为了让我的代码几乎完全用 Jquery 编写，我想用 Jquery 重写 AJAX 调用。这是从网页到 Tomcat servlet 的调用。我目前情况的类似代码: var http = new
Java 调用 C 调用 Java
我想使用 JNI 从 Java 调用 C 函数。在 C 函数中，我想创建一个 JVM 并调用一些 Java 对象。当我尝试创建 JVM 时，JNI_CreateJavaVM 返回 -1。所以，我想知
javascript - 调用 javascript 函数以从无法按预期工作的表单进行 AJAX 调用
环顾四周，我发现从 HTML 调用 Javascript 函数的最佳方法是将函数本身放在 HTML 中，而不是外部 Javascript 文件。所以我一直在网上四处寻找，找到了一些简短的教程，我可以根
ajax - 为什么我不能从 Angular 调用 ajax 调用
我有这个组件: import {Component} from 'angular2/core'; import {UserServices} from '../services/UserService
openssl - 如果客户端使用 BIO_* 调用，是否需要服务器上的 BIO_* 调用？
我正在尝试用 C 实现一个简单的 OpenSSL 客户端/服务器模型，并且对 BIO_* 调用的使用感到好奇，与原始 SSL_* 调用相比，它允许一些不错的功能。我对此比较陌生，所以我可能会完全错误
javascript - 根据先前的 Ajax 调用，根据用户确认执行 Ajax 调用
我正在处理有关异步调用的难题: 一个 JQuery 函数在用户点击时执行，然后调用一个 php 文件来检查用户输入是否与数据库中已有的信息重叠。如果是这样，则应提示用户确认是否要继续或取消，如果他单击
java - 验证私有(private)构造函数未使用 JMockit 调用/调用
我有以下类(class)。 public Task { public static Task getInstance(String taskName) { return new
c++ - 调用 QSound 调用，它们之间有延迟 Qt C++
嘿，我正在构建一个小游戏，我正在通过制作一个数字 vector 来创建关卡，该数字 vector 通过枚举与 1-4 种颜色相关联。问题是循环(在 Simon::loadChallenge 中)我将颜
Java 异步 api 调用 - 即发即忘 http 调用
我有一个java spring boot api(数据接收器)，客户端调用它来保存一些数据。一旦我完成了数据的持久化，我想进行另一个 api 调用(应该处理持久化的数据 - 数据聚合器)，它应该自行异
c# - 如何从 Paypal 调用 DoDirectPayment API 调用
首先，这涉及桌面应用程序而不是 ASP .Net 应用程序。我已经为我的项目添加了一个 Web 引用，并构建了各种数据对象，例如 PayerInfo、Address 和 CreditCard。但问题
f# - 如何从 FAKE 调用/调用 F# 编译器 fsc？
我如何告诉 FAKE 编译 .fs文件使用 fsc ? 解释如何传递参数的奖励积分，如 -a和 -target:dll . 编辑:我应该澄清一下，我正在尝试在没有 MSBuild/xbuild/.sl
javascript - render 没有被一个 api 调用，而是被另一个 api 调用
我使用下划线模板配置了一个简单的主干模型和 View 。两个单独的 API 使用完全相同的配置。 API 1 按预期工作。要重现该问题，请注释掉 API 1 的 URL，并取消注释 API 2 的
php - OOP 或 MySQL 调用。生成对象还是直接从 MySQL 调用？
我不确定什么是更好的做法或更现实的做法。我希望从头开始创建目录系统，但不确定最佳方法是什么。我想我在需要显示信息时使用对象，例如 info.php?id=100。有这样的代码用于显示 Game.cl
python - child 调用 parent ， parent 调用 child ......或不
from datetime import timedelta class A: def __abs__(self): return -self class B1(A):
java - 调用/调用 void 方法(Java 作业 - 生命游戏示例)
我在操作此生命游戏示例代码中的数组时遇到问题。情况: “生命游戏”是约翰·康威发明的一种细胞自动化技术。它由一个细胞网格组成，这些细胞可以根据数学规则生存/死亡/繁殖。该网格中的活细胞和死细胞通过
调用 read() 返回 0 但缓冲区已更改，调用 fread() 读取相同偏移量时不会发生
如果我像这样调用 read() 来读取文件: unsigned char buf[512]; memset(buf, 0, sizeof(unsigned char) * 512); int fd;
调用 "start"启动程序，调用 "stop"关闭 C 中的当前实例
我用 C 编写了一个简单的服务器，并希望调用它的功能与调用其他 C 守护程序的功能相同(例如使用 ./ftpd start 调用它并使用 ./ftpd stop 关闭该实例)。显然我遇到的问题是我不知
powershell - 可以从 cmd 调用 headless，但不能从 powershell 调用 headless
在 dos 中，当我粘贴此命令时它会起作用: "C:\Program Files (x86)\Google\Chrome\Application\chrome.exe" https://google.
powershell - 可以从 cmd 调用 headless，但不能从 powershell 调用 headless
在 dos 中，当我粘贴此命令时它会起作用: "C:\Program Files (x86)\Google\Chrome\Application\chrome.exe" https://google.
python - 调用 python3 显示错误，调用 python 启动 python2.7
我希望能够从 cmd 在我的 Windows 10 计算机上调用 python3。我已重新安装 Python3.7 以确保选择“添加到路径”选项，但仍无法调用 python3 并使 CMD 启动 P

我是一只小鸟

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

Mybatis-Plus+Nacos+Dubbo进行远程RPC调用保姆级教程