多个tomcat中的spring集成应用程序中的重复消息处理

Question

我有 spring web/集成应用程序。为了在后台运行长时间运行的进程，我使用了 MongoDbMessageStore 支持的队列，并且每秒轮询一次队列。

我尝试从在两个 tomcat 实例上运行的同一应用程序将消息（每个实例 1000 条消息）发送到网关。我验证了服务器 1 处理的消息没有被服务器 2 处理，反之亦然。我看到了存储在 mongo 集合中的文档。它具有 UUID（消息 id）和 _group_complete，但我无法得出结论，如果应用程序在具有单个 momgodb 实例的多个实例上运行，spring 如何避免重复消息处理。

感谢您的帮助。

Answer 1

因为MongoDbMessageStore 使用findAndRemove 操作。

这是分布式环境的预期行为。

如果你说相反的话会更糟。