如何将消息从 Activemq 推送到消费者

Question

我是Activemq和Java的新手，看了教程，有点懂了。谁能帮我解决以下任务。

假设我们在 Activemq 的 Queue/Topic 中有 10 条消息。我们正在从数据库中获取消息，我们已经做到了。

我想编写 2 个 Java 应用程序（使用 JMS 接收来自 activemq 的消息），它们将充当 Activemq 中的消费者。我想要实现的是，每当Activemq 从数据库获取消息时，activemq 应该检查是否有任何消费者是免费的。如果任何消费者是免费的，activemq 应该将消息推送给消费者，一旦消费者收到它就会自己做处理。

那么我的 java 代码应该如何实现呢？

还有如何设置预取限制？

谁能帮帮我。

谢谢。

Answer 1

很高兴知道在 AMQ 代理和数据库之间有一个生产者，它不断地将消息推送到 AMQ。

回答你的问题。可以有多个消费者在任何目的地（队列/主题）上监听。 ActiveMQ 代理将消息推送给任何消费者（可以自定义分发）。正如我在上一个问题中回答的那样，AMQ 将使用prefetch limit（假设是 N）在开始等待获取ack 之前发送这么多消息。如果一个消费者很忙，那么它的本地缓冲区中只能有 N 条消息在等待，AMQ 代理会自动选择另一个消费者来推送消息。