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

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

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

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

项目链接在最后

 

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

 　　org.apache.dubbo
　　 dubbo-spring-boot-starter
　　 2.7.8

 

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().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().eq(User::getName, name));
    return i>0?"成功":"失败";
}

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

 

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

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

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

接下来实现bank1的相关操作

bank1引入以下依赖

    org.apache.dubbo
    dubbo-spring-boot-starter
    2.7.8

        

    com.example
    bank2
    0.0.1-SNAPSHOT
    compile

然后在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().eq(User::getName, from));
    user.setAmount(user.getAmount()-amount);
    user1Mapper.update(user,new LambdaQueryWrapper().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配置，接下来进行配置，在两个项目的配置文件中直接添加下列内容

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

 

12.后续教程：https://www.cnblogs.com/leafstar/p/17641358.html