任何人都可以指出有关如何在 activemq 中实现单个消费者多个生产者的参考吗?或者可以给出一个非常简单的实现。这将非常有帮助。
谢谢
如果你需要保证一条消息只能被一个消费者消费,那么这就是点对点的通信模型,可以使用 ActiveMQ 中的 JMS Queue 来实现。
许多生产者可以将消息发送到同一个队列。只有一个活跃的消费者会收到来自队列的消息。
这不需要特殊的实现。这是 MessageBrokers 的核心业务。您唯一需要确定的是:
如果您决定为您的生产者提供一个 ID,请确保它们彼此不同。您不能有多个具有相同 ID 的生产者。消费者也是如此。
Matt Raible 的AppFuse项目是一个很好的框架项目,它使用不同的库来实现。您可以选择一个使用 Spring 并引入 ActiveMQ,正如 Bharati Raja 在他的博客文章jms with appfuse1x中所解释的那样。