使用 HornetQ 强制消息顺序

Question

我已经设置了一个 jms 服务器，其中 HornetQ 作为 JMS 提供者（队列）。

我有一个应用程序充当生产者，另一个应用程序（不同的计算机）充当消费者。

我知道 JMS 规范不能保证传递的顺序，但我正在寻找一种方法来做到这一点：完全按照消息发送的顺序接收消息，即使它是特定于提供商。

有什么想法吗？

Answer 1

显然，这可以通过禁用消费者缓存来实现。这是通过更改 hornetq-jms.xml 来完成的：

   <connection-factory name="ConnectionFactory">
      <connectors>
         <connector-ref connector-name="netty-connector"/>
      </connectors>
      <entries>
         <entry name="ConnectionFactory"/>
      </entries>

      <consumer-window-size>0</consumer-window-size> <!-- add this line -->
   </connection-factory>

Answer 2

实际上，JMS 规范的第 4.4.10.2 节（消息发送顺序）对于顺序非常清楚。

如果队列或主题订阅有单个生产者和单个消费者，则即使存在重新传递，也始终保证消息排序。

如果您有多个消费者，则在回滚或关闭消费者的情况下可能会重新交付客户端缓冲，并且可能会无序交付客户端缓冲区。

在 HornetQ 上，您还拥有消息组，它对生成的消息赋予额外的排序约束。