我应该如何在 redisson 中使用 RReliableTopic?

问题描述

在以下示例代码中,RTopic 运行良好,但当我向主题发布新消息时,RReliable 主题不会调用侦听器方法。 我还在不同的项目中测试了发布和订阅方法,但没有任何区别。 Redisson 3.14.0 版本

Config redissonConfig = new Config();
redissonConfig.useSingleServer().setAddress("redis://192.168.1.1:6379")
                .setUsername("test").setPassword("test")  ;
    
RedissonClient redissonClient = Redisson.create(redissonConfig);
    
MessageListener<Object> listener = (channel,message) -> {
      System.out.println(message);
};
**RTopic** topic = redissonClient.getTopic("mytopic");
topic.addListener(Object.class,listener);
System.out.println(topic.countSubscribers());
topic.publish("RTopic works");
    
**RReliabletopic** rtopic = redissonClient.getReliabletopic("rtopic");
rtopic.addListener(Object.class,listener);
System.out.println(rtopic.countSubscribers());
rtopic.publish("RReliabletopic works");

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)