一、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());

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

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

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

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

@Component
public class RemoteServiceInit implements CommandLineRunner {private static final Logger LOGGER = LoggerFactory.getLogger(RemoteServiceInit.class);@Autowiredprivate RedissonClient redisson;@Autowiredprivate IMailService iMailService;@Overridepublic 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 {@Autowiredprivate 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);}
}

在这里插入图片描述

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;}