跨多个队列的ActiveMQ消息组使用者选择？

Question

ActiveMQ消息组是跨多个使用者进行负载平衡的一个非常好的特性。简而言之：消息流根据消息中嵌入的组标识符(JMSXGroupID)在单个队列的多个使用者之间进行分区。（因此，使用者1将获得jmsxgroupid=A的所有消息，使用者2将获得jmsxgroupid=B的所有消息，依此类推）

现在，假设您有两个队列:a和B，并假设在流经这两个队列的消息中使用一致的JMSXGroupIDS分类法。代理为jmsxgroupid=abcon queueA选择的使用者是否与代理为jmsxgroupid=abcon queueB选择的连接相同？

但是，我们能模拟这种行为吗？例如，复合目的地上的使用者可能是一个可行的解决方案--确保a和B上的所有使用者都在复合目的地上使用a、B并且您可能正在进行业务--但是ActiveMQ似乎不支持从复合目的地使用。

我找到的唯一解决方案是简单地将A和B的消息推送到一个队列上--将其称为AB--并在该队列上拥有一个专用使用者。您现在必须区分“A消息”和“B消息”，但是您可以轻松地使用标题来区分。

然而，这个解决方案闻起来很滑稽。（您现在必须假设生产者会尽职尽责地为他们的消息应用特殊的头，或者修改您的有效负载。）是否有一种解决方案可以确保使用者跨越两个单独的队列a和B总是登陆在同一个连接上？

Answer 1

正如您所正确计算的那样，消息组仅应用于单个队列。多个队列之间没有协调。

通常，当您使用消息组时，您试图确保消息的顺序不仅是传递，而且是处理--也就是说，特定实体的所有事件都是按顺序处理的。魔鬼总是在您的用例的细节中，但是将所有相关的消息放在一个队列中会给您带来您想要的结果。为了以不同的方式处理它们，您需要将某种多路复用逻辑放入客户机中，以便根据消息负载做出决定--您所说的众所周知的头是解决方案的一个很好的候选方案。

为了绕过确保客户机显式设置此选项的前提条件，您可以编写一段Camel路由逻辑来代表您执行此选项--只有添加到ActiveMQ5.9中的Broker：组件才能做到这一点。这个想法将是生产者看到两个独立的队列--A和B；当消息被放入时，路由逻辑将从这些队列中读取，适当地设置头部，并将它们重新路由到C。路由逻辑实际上是作为拦截器工作的。

<route id="ConflateA">
  <from uri="broker:queue:A"/>
  <setHeader headerName="OriginalMessageSource">
    <constant>A</constant>
  </setHeader>
  <to uri="broker:queue:C"/>
</route>

然后可以在复用逻辑中使用OriginalMessageSource标头。