【Redisson】Redisson--分布式远程服务（Remote Service）

r囧r小猫 2023-10-13 11:03 35阅读 0赞

Redisson系列文章：

*  [【Redisson】Redisson–基础入门][Redisson_Redisson]
 *  [【Redisson】Redisson–布隆(Bloom Filter)过滤器][Redisson_Redisson_Bloom Filter]
 *  [【Redisson】Redisson–分布式锁的使用（推荐使用）][Redisson_Redisson 1]
 *  [【分布式锁】Redisson分布式锁底层原理][Redisson]
 *  [【Redisson】Redisson–限流器][Redisson_Redisson 2]

#### 文章目录 ####

*  一、Redisson使用远程服务
 *  二、服务端(生产端)实战
 *  三、客户端(消费端）实战
 *  四、响应模式附录

## 一、Redisson使用远程服务 ##

当前有两台服务器连接的是同一个Redisson中间件，这两台服务器叫它们A节点与B节点吧。A节点可以发布一些API接口，也实现了它们，并向Redisson服务中心注册。B节点向Redisson注册中心订阅这些API接口，因此它可以向Redisson服务器发送这些请求，这些请求最终会被注册中心转发到A节点。这样，B节点就能够通过Redisson注册中心与A节点通信，从而实现远程服务调用功能。

分布式远程服务（Remote Service）提供了两种类型的RRemoteService实例：

服务端（远端）实例 - 用来执行远程方法（工作者实例即worker instance）. 例如

RRemoteService remoteService = redisson.getRemoteService();
    SomeServiceImpl someServiceImpl = new SomeServiceImpl();
     
    // 在调用远程方法以前，应该首先注册远程服务
    // 只注册了一个服务端工作者实例，只能同时执行一个并发调用
    remoteService.register(SomeServiceInterface.class, someServiceImpl);
     
    // 注册了12个服务端工作者实例，可以同时执行12个并发调用
    remoteService.register(SomeServiceInterface.class, someServiceImpl, 12);

客户端（本地）实例 - 用来请求远程方法. 例如：

RRemoteService remoteService = redisson.getRemoteService();
    SomeServiceInterface service = remoteService.get(SomeServiceInterface.class);
     
    String result = service.doSomeStuff(1L, "secondParam", new AnyParam());

## 二、服务端(生产端)实战 ##

1.  首先服务器端会定义一个接口IMailService，并实现它IMailServiceImpl。这里注意的是，IMailService与MailDto都是在API模块里面的，方便打包并发布。MailDto需要实现序列化接口，因为需要存放在Redis中并

public interface IMailService {
        
     
        MailDto queryMail(Long id);
    }
     
    @Service
    public class IMailServiceImpl implements IMailService {
        
     
        @Autowired
        private MailMapper mailMapper;
     
        @Override
        public MailDto queryMail(Long id) {
        
            Mail mail = mailMapper.selectByPrimaryKey(id);
            MailDto dto = new MailDto();
            if (mail != null) {
        
                BeanUtils.copyProperties(mail, dto);
            }
            return dto;
        }
    }

1.  向Redisson注册中心发布API。CommandLineRunner接口的功能是在SpringBoot项目启动的时候执行相关的功能。

@Component
    public class RemoteServiceInit implements CommandLineRunner {
        
        private static final Logger LOGGER = 
                               LoggerFactory.getLogger(RemoteServiceInit.class);
     
        @Autowired
        private RedissonClient redisson;
     
        @Autowired
        private IMailService iMailService;
     
        @Override
        public void run(String... strings) throws Exception {
        
            LOGGER.info("初始化Redisson远程调度");
            RRemoteService remoteService = redisson.getRemoteService();
            //初始化5个并发实例
            remoteService.register(IMailService.class, iMailService, 5);
        }
    }

## 三、客户端(消费端）实战 ##

生产端的IMailService与MailDto最好定义在API模块，方便打包发布。打包成jar以后，导入到消费端项目B中。消费端项目B需要与生产端连接相同的Redisson服务器。

@Service
    public class RemoteMailService {
        
     
        @Autowired
        private RedissonClient redisson;
     
        public MailDto queryMail(Long id) {
        
            //获取Redisson远程服务
            RRemoteService remoteService = redisson.getRemoteService();
            //应答回执超时1秒钟，远程执行超时30秒钟
            RemoteInvocationOptions options = RemoteInvocationOptions.defaults();
            //拿到生产端的接口
            IMailService iMailService = remoteService.get(IMailService.class,options);
            //调用
            return iMailService.queryMail(id);
        }
    }

![在这里插入图片描述][4fa51040a2a14927809d79d9154f7c1e.png]

Redisson远程服务

## 四、响应模式附录 ##

涉及到网络传输，所以可能有传输失败的情况。更多的应答模式如下。

noResult()是指远程调用的方法，不需要有返回值。noAck（）表示消费端不需要要服务端响应。

// 应答回执超时1秒钟，远程执行超时30秒钟
    RemoteInvocationOptions options = RemoteInvocationOptions.defaults();
     
    // 无需应答回执，远程执行超时30秒钟
    RemoteInvocationOptions options = RemoteInvocationOptions.defaults().noAck();
     
    // 应答回执超时1秒钟，不等待执行结果
    RemoteInvocationOptions options = RemoteInvocationOptions.defaults().noResult();
     
    // 应答回执超时1分钟，不等待执行结果
    RemoteInvocationOptions options = RemoteInvocationOptions.defaults().
                                            expectAckWithin(1, TimeUnit.MINUTES).noResult();
     
    // 发送即不管（Fire-and-Forget）模式，无需应答回执，不等待结果
    RemoteInvocationOptions options = RemoteInvocationOptions.defaults().noAck().noResult();
     
    RRemoteService remoteService = redisson.getRemoteService();
    YourService service = remoteService.get(YourService.class, options);

下面的这段代码是我自己实测的。

expectResultWithin(15,TimeUnit.SECONDS)表示，如果生产端服务器能够接通的话，在15秒之内需要返回数据，否则报异常No response after 15000ms for request。

expectAckWithin(10,TimeUnit.SECONDS)表示，生产端服务器需要在10秒内有响应，否则报异常No ACK response after 10000ms for request。

public MailDto queryMail(Long id) {
        
     
            RRemoteService remoteService = redisson.getRemoteService();
            //应答回执超过5秒钟，不等待执行结果
            RemoteInvocationOptions options = RemoteInvocationOptions.defaults().
                    expectResultWithin(15, TimeUnit.SECONDS).expectAckWithin(10,TimeUnit.SECONDS);
            Long start = System.currentTimeMillis();
            IMailService iMailService = remoteService.get(IMailService.class,options);
            MailDto result = null;
            try {
        
                 result =  iMailService.queryMail(id);
            }catch (Exception e){
        
                System.out.println(e.getMessage());
            }
            Long end = System.currentTimeMillis();
            System.out.println(end - start);
            return result;
        }

[Redisson_Redisson]: https://writer.blog.csdn.net/article/details/131525498
[Redisson_Redisson_Bloom Filter]: https://writer.blog.csdn.net/article/details/130690257
[Redisson_Redisson 1]: https://writer.blog.csdn.net/article/details/130613740
[Redisson]: https://writer.blog.csdn.net/article/details/130793760
[Redisson_Redisson 2]: https://writer.blog.csdn.net/article/details/131530310
[4fa51040a2a14927809d79d9154f7c1e.png]: https://img-blog.csdnimg.cn/4fa51040a2a14927809d79d9154f7c1e.png