12.3. 初始化监听器

Redisson Node提供了在启动完成后,执行RedissonNodeInitializer指定的初始化监听器的机制。这个机制可以用在启动完成时执行注册在类路径(classpath)中分布式远程服务的实现,或其他必要业务逻辑。比如,通知其他订阅者关于一个新节点上线的通知:

  1. public class MyRedissonNodeInitializer implements RedissonNodeInitializer {
  2. @Override
  3. public void onStartup(RedissonNode redissonNode) {
  4. RMap<String, Integer> map = redissonNode.getRedisson().getMap("myMap");
  5. // ...
  6. // 或
  7. redisson.getRemoteService("myRemoteService").register(MyRemoteService.class, new MyRemoteServiceImpl(...));
  8. // 或
  9. reidsson.getTopic("myNotificationTopic").publish("New node has joined. id:" + redissonNode.getId() + " remote-server:" + redissonNode.getRemoteAddress());
  10. }
  11. }