我有基于JBoss的JMS实现(准确地说,是基于JBoss4.2的JBossMQ )。有5个集群,每个集群有很少的节点。每个集群中的一个节点充当主节点。在5个集群中,其中一个集群应该将消息发布到持久主题,而其他4个集群消费这些消息。发布和消费仅由每个集群的主节点完成。
我想设计一种机制,使发布者知道消息被所有订阅者使用,或者订阅者知道它已经使用了发布者产生的所有消息。如何才能做到这一点?
发布于 2014-07-10 21:35:48
原则上,您使用JMS系统的目的是不关心这一点,只按您需要的方式进行配置。您可以将状态信息保存在数据库等共享资源中,但我不会这么做。最好使用JMS系统的监视器特性来跟踪它。如果您的应用程序确实需要了解消息的成功处理情况,那么您可以使用一个队列,在该队列中,处理确认将返回给发送者。
对于可能与JBoss一起使用的HornetQ,您将找到一个clustered topic here示例。
https://stackoverflow.com/questions/24675873
复制相似问题