如何解决我应该如何在 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 举报,一经查实,本站将立刻删除。