由于我找不到任何明确解释如何在实际的分布式设置中使用rqueue的内容,这与默认的单示例示例不同,我希望这里有人能解释我的错误。
我有多个microservices示例,它们都使用具有相同redis连接的redisson,以便从rqueue检索元素。它是一个通过端口转发到kubernetes服务的单一连接,由一个3节点redis sentinel集群支持(redis 6.0.9通过helm chart部署)。如果每个服务在rqueue上执行一个poll(),并且它们都接收相同的对象。
redissonClient.<Job>getQueue(queueKey).poll();
在我的理解中,这种情况不应该发生,而且另一个服务示例也不应该轮询以前轮询过的元素。
只有当我从同一个服务示例执行轮询时,队列才能按预期工作。这可能只是我不知道的配置问题吗?
如果这个问题没有提供足够的信息或背景,我将很乐意加强它相应的!
提前谢谢你的帮助!
暂无答案!
目前还没有任何答案,快来回答吧!