【发布时间】:2012-01-10 17:37:59
【问题描述】:
我想编写一个应用程序,使用 Active MQ 作为一个生产者多个消费者的队列。 我找到了http://activemq.apache.org/multiple-consumers-on-a-queue.html 它可以通过创建会话来完成,但这没有提供任何示例。谁能给我一个如何做到这一点的示例。
谢谢
【问题讨论】:
-
使用多个消费者(和多个生产者)与一个生产者和一个消费者的代码相同。区别在于您一次创建/拥有多少个。
-
@PeterLawrey 所以你的意思是如果我只是创建更多的接收器就足够了。但是,哪个消费者会收到消息呢?因为我只想创建一个队列和不同的用户从中获取消息。我有一个用于接收消息的 MDB。
-
下一个免费消费者收到消息。执行此操作的策略是可调整的,但您很少需要更改。
-
所以假设我想要两个消费者,然后我创建两个消息驱动 Bean(MDB1、MDB2)和一个用于发送消息的生产者。在生产者代码中,我可以创建两个可以工作的会话。会话数等于消费者数??