ActiveMQ：如何使用自定义属性对队列中的消息重新排序

Question

我们在项目中使用 ActiveMQ，消息由不同的生产者同时写入到同一个队列中。因此，订单混乱。无论如何，消息可以在消费者消费之前在队列中重新排序

例如，生产者 A 生成消息 -> M1、M2、M3（自定义标头属性为 1、2、3） 生产者 B 生成消息 -> M4、M5、M6（自定义标头属性为 4、5、6）。

由于竞争条件，我们以 M1、M4、M5、M2、M3、M6 的形式将消息发送到队列。

我们能否使用自定义标头属性按所需顺序重新排序消息，例如：M1、M2、M3、M4、M5、M6？

注意：我们的项目中没有使用 Java。我们正在使用 Mulesoft 来生成和使用来自 ActiveMQ 的消息。

我见过this link，这与我们的问题类似，但是当我按照这些步骤操作时，链接中提供的解决方案不清楚或者无法正常工作。

Answer 1

如果首先无法确保消息以正确的顺序发送，那么Camel's resequencer 是一个很好的解决方案。这是一个简单的例子：

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="activemq:queue:unordered"/>
    <resequence>
      <simple>in.header.seqnum</simple>
      <to uri="activemq:queue:ordered" />
      <stream-config capacity="5000" timeout="4000"/>
    </resequence>
  </route>
</camelContext>

这条路由会从unordered队列中读取消息，然后根据消息头seqnum重新排序，然后发送到ordered队列。因此，您的应用程序应该从ordered 队列中读取重新排序的消息。

Camel documentation 非常详尽，因此您应该参考它以获取更多详细信息。