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

这篇具有很好参考价值的文章主要介绍了Mybatis-Plus+Nacos+Dubbo进行远程RPC调用保姆级教程。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

本文通过简单的示例代码和说明,让读者能够了解Mybatis-Plus+Nacos+Dubbo进行远程RPC调用的简单使用 

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

之前的教程 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如下

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

 代码如下

@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中添加以下接口

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

对服务进行稍微修改如下

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

 接下来将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注解

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

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

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

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

 

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

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

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

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

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

 

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

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

 

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

 

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

 

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

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

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

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

 

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

 

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

 

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

 

12.后续教程:https://www.cnblogs.com/leafstar/p/17641358.html文章来源地址https://www.toymoban.com/news/detail-654835.html

到了这里,关于Mybatis-Plus+Nacos+Dubbo进行远程RPC调用保姆级教程的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Mybatis-Plus如何进行时间日期的比较

    获取数据库中跟当前日期相等的记录时,还是调用eq方法,所以实体类包括数据库中的类型是Date,而不是DateTime,否则只能获取相同时刻的数据。 Mybatis-Plus的时间比较是基于数据库的函数进行的,而不是字符串的比较。在Mybatis-Plus中,可以使用Wrapper对象的 ge、gt、le、lt 方法

    2024年02月11日
    浏览(44)
  • 针对mockito框架在单元测试中出现Mybatis-Plus链式调用的解决方案

    1、 调用其他service层方法 2、 调用本service层方法 3、其他问题

    2024年01月24日
    浏览(42)
  • mybatis-plus 数据字段进行加解密入库,且加密字段支持模糊搜索

    1. 开发框架、环境 springboot+mybatis-plus+mysql5.7(oracle应该也是可以的,没有测试,但实现思路是都可以满足,懒得测oracle了,哈哈) 2. 需求介绍(背景) 需求很简单: 就是将数据存储到数据库,并且将敏感数据字段进行加密处理保存(比如:身份证,手机号,银行卡 等等)

    2024年02月09日
    浏览(54)
  • 重写RuoYi-Cloud所有功能 整合 SpringCloudAlibaba Dubbo Mybatis-Plus MQ OSS ES Xxl-Job Docker 全方位升级 定期同步

    转载于:https://blog.csdn.net/weixin_40461281/article/details/122837923 RuoYi-Cloud-Plus  微服务通用权限管理系统  重写 RuoYi-Cloud 全方位升级(不兼容原框架) 系统演示: 传送门 分布式集群版本(功能一致) 功能介绍 使用技术 文档地址 特性注意事项 微服务权限管理系统 RuoYi-Cloud-Plus RuoYi-Clo

    2024年02月08日
    浏览(42)
  • MyBatis-Plus 更新(update)方法,属性参数为空时进行更新与不进行更新的设置

    解决方案: 在实体类上使用@TableField注解 FieldStrategy的源码中,一共有4种策略类型。 附上mybatis-plus官网链接地址: https://baomidou.com/pages/223848/#fieldstrategy 有兴趣的小伙伴可以点击看看

    2024年02月11日
    浏览(79)
  • MyBatis-plus中的两种快捷操作数据库方式:1、mapper调用 2、ActiveRecord方式(简称AR) 二者的使用和区别介绍

            在使用MyBatis操作数据库时,需要频繁的写mapper层dao接口以及对应的配置文件和SQL语句,当功能方法繁杂,业务逻辑不复杂的时候,我们可以使用MyBatis的升级版MyBatis-Plus来代替我们写这些繁琐的配置文件和简单的SQL。 (1)书写或使用MP生成数据库表对应的实体类。

    2024年02月07日
    浏览(67)
  • 【Mybatis-Plus】Mybatis-Plus快速入门

    Mybatis-Plus是基于Mybatis的数据库操作组件,其实现的功能完全是Mybatis的功能拓展,不改变Mybatis的使用方式,可以兼容Mybatis的操作方式。 创建一个数据库、一个表进行基础操作: 创建一个Spring项目,项目通过Spring Initlizer创建,不导入任何依赖包,在POM.xml文件中进行依赖导入

    2024年02月07日
    浏览(46)
  • Dubbo之消费端服务RPC调用

    在消费端服务是基于接口调用Provider端提供的服务,所以在消费端并没有服务公共接口的实现类。 利用注解@DubboReference将目标接口CountryService作为CountryController类的字段属性,在解析类CountryController时获取全部字段属性并单独关注解析存在注解@DubboReference的字段属性。 通过步骤

    2024年03月12日
    浏览(48)
  • Mybatis-Plus 进阶开发 -- Mybatis-Plus 入门教程(二)

    为了巩固所学的知识,作者尝试着开始发布一些学习笔记类的博客,方便日后回顾。当然,如果能帮到一些萌新进行新技术的学习那也是极好的。作者菜菜一枚,文章中如果有记录错误,欢迎读者朋友们批评指正。 (博客的参考源码可以在我主页的资源里找到,如果在学习的

    2024年02月10日
    浏览(51)
  • Mybatis-Plus通用枚举功能 [MyBatis-Plus系列] - 第493篇

    历史文章( 文章 累计490+) 《国内最全的Spring Boot系列之一》 《国内最全的Spring Boot系列之二》 《

    2024年02月08日
    浏览(39)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包