activeMQ 如何使用多个生产者和一个消费者?
How to use multiple producers and one consumer with activeMQ?
所以我正在尝试在我的 java 项目中使用 ActiveMQ(我以前从未使用过类似的东西,但我已经阅读过它是如何工作的)。
该应用程序在 5 个不同的节点上运行,并在每个节点上创建应发送到同一队列的消息。
这是我认为它应该如何工作:我有一个 class 创建这些消息;这些消息是在这些节点中的任何一个中创建的;所以这个 class 作为一个线程工作,应该是 "the producer",将每条消息发送到同一个队列。(因此我有多个生产者)
消费者 class 始终在同一节点上运行。
这种方法对我有用吗?队列是线程安全的吗?
是的,您的方法应该没有任何问题。所有消息代理都支持多个并发生产者向同一个队列发送消息。应该没有线程安全问题。
所以我正在尝试在我的 java 项目中使用 ActiveMQ(我以前从未使用过类似的东西,但我已经阅读过它是如何工作的)。
该应用程序在 5 个不同的节点上运行,并在每个节点上创建应发送到同一队列的消息。
这是我认为它应该如何工作:我有一个 class 创建这些消息;这些消息是在这些节点中的任何一个中创建的;所以这个 class 作为一个线程工作,应该是 "the producer",将每条消息发送到同一个队列。(因此我有多个生产者) 消费者 class 始终在同一节点上运行。
这种方法对我有用吗?队列是线程安全的吗?
是的,您的方法应该没有任何问题。所有消息代理都支持多个并发生产者向同一个队列发送消息。应该没有线程安全问题。