6

在 Java Web 应用程序中,我有一个 A 类型的重复消息负载(例如,每小时 20,000 条)。然后我有第二种类型的消息(B 型)偶尔出现,但优先级高于 A 型(比如 3,000)。我希望能够使用开源软件在一台或多台机器上处理这些消息。

在我看来,如果我有一个 JMS 服务器可以根据优先级从其队列中发送消息(例如,发送三个 B 类型的消息,然后发送一个 A 类型的消息,即使所有 A 类型的消息都是在消息队列的顶部)。

您知道可以执行此操作的 JMS 服务器吗?或者您知道实现此操作的另一种方法吗?

4

4 回答 4

6

JMS 标准支持的消息优先级默认为 4,可以指定其他)。我认为您需要在消息生产者和消息本身中设置它(两者都有方法)。

我认为 ActiveMQ 确实支持它。

但是,许多 JMS 代理默认禁用优先级处理。在代理配置的某处,您可能需要更改一个标志,例如“supportJMSPriority”。

此外,Apache Camel 允许您编写自己的消息重排序器,以便您可以实现任何形式的优先级。

于 2008-12-22T21:58:50.750 回答
2

在 MessageProducer(QueueSender 等)上调用“send(..)”时设置消息优先级。或者,您可以将 MessageProducer 的默认优先级设置为 0-9(9 为最高)。设置消息本身的优先级是行不通的。它被 Producer 覆盖。

Uri 是正确的——是否尊重优先级是特定于实现的。我相信 OpenJMS 通常尊重开箱即用的优先级,但不保证这一点。

JMS 规范指出:"JMS does not require that a provider strictly implement priority ordering of messages; however, it should do its best to deliver expedited messages ahead of normal messages."

于 2008-12-23T00:09:46.023 回答
0

为什么不考虑使用另一个 MDB 显式处理其他消息类型。上面的优先级细节仍然适用,此外,您可以更好地控制每种消息类型的并发处理。

对于大多数情况,我更喜欢每种消息类型有 1 个 mdb 或消息接收器。这样,如果事务回滚,您会立即知道是哪种类型的消息导致了问题

卡尔

于 2009-02-16T20:40:21.933 回答
0

您可以使用多个主题。即使有优先级,如果您的处理器忙于处理较低优先级的消息,它也不会停止它的工作。

If you have separate processors, a high priority message can start processing as soon as it can be delivered, not waiting for any other message to be processed.

于 2009-02-16T20:56:51.907 回答