本文通过简单的示例代码和说明,让读者能够了解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如下

 代码如下

@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:
#    protoco