java - 针对特定属性组同步处理 jms 消息，但在其他组中同时处理 jms 消息

Question

我需要有关 JMS 队列和消息处理的帮助。

我有一个场景，需要针对特定​​属性组同步处理消息，但可以在不同属性组之间同时处理消息。

我了解了特定于每个属性的消息组和队列的一些知识。我的想法是，我想针对某个属性组进行同步处理，并且可能有 7000 个或更多这样的属性组。

我绝对不能拥有 7000 个队列。请提供任何建议。

谢谢

Answer 1

ActiveMQ 中队列和消息组的概念将达到此目的。

每个传入的 jms 消息都应设置 header “JMSXGroupID”。的值(value) header 应特定于该组。

现在，并发消费者可以监听队列了。 ActiveMQ 将确保具有相同组 header 值的消息将发送给同一个消费者。

引用:http://activemq.apache.org/message-groups.html

谢谢。