跨集群的 JMS 消息跟踪

Question

我有基于 JBoss 的 JMS 实现（准确地说是 JBoss4.2 上的 JBossMQ）。有 5 个集群，每个集群有几个节点。每个集群中的一个节点充当主节点。在 5 个集群中，一个集群应该向持久主题发布消息，而其他 4 个集群使用这些消息。发布和消费仅由每个集群的主节点完成。

我想设计一种机制，让发布者知道消息已被所有订阅者消费，或者订阅者知道它已经消费了发布者产生的所有消息。如何实现？

Answer 1

原则上，您使用 JMS 系统是为了不关心这些，只按照您需要的方式配置它。您可以将状态信息保存在数据库等共享资源中，但我不会这样做。更好地使用 JMS 系统的监控功能来跟踪它。如果您的应用程序确实需要知道消息的成功处理，那么您可以有一个队列，其中进程确认返回给发送者。

对于可能与 JBoss 一起使用的 HornetQ，您会找到一个 clustered topic here 的示例。