如何使用Java和Spring 3.0同时处理来自JMS主题（而非队列）的多个消息？

Question

我希望多个消息侦听器可以同时处理该主题的后续消息。另外，我希望每个消息侦听器都可以事务性地操作，以便给定消息侦听器中的处理失败将导致该侦听器的消息保留在主题上。

春天的DefaultMessageListenerContainer似乎仅支持JMS队列的并发。

我需要实例化多个DefaultMessageListenerContainers吗？

如果时间沿垂直轴向下流动：

ListenerA reads msg 1        ListenerB reads msg 2        ListenerC reads msg 3
ListenerA reads msg 4        ListenerB reads msg 5        ListenerC reads msg 6
ListenerA reads msg 7        ListenerB reads msg 8        ListenerC reads msg 9
ListenerA reads msg 10       ListenerB reads msg 11       ListenerC reads msg 12
...

我最终要做的是创建多个对象DefaultMessageListenerContainers，concurrency=1然后在消息侦听器中放入逻辑，以便只有一个线程可以处理给定的消息ID。

Answer 1

你不想要多个DefaultMessageListenerContainer实例，不，但是你需要DefaultMessageListenerContainer使用concurrentConsumers属性将并发配置为：

指定要创建的并发使用者数。默认值为1。

为此设置指定较高的值将提高运行时调度的并发使用者的标准级别：这实际上是在任何给定时间调度的最小并发使用者数。这是静态设置；对于动态缩放，请考虑改为指定“ maxConcurrentConsumers”设置。

建议增加并发使用者的数量，以扩展从队列传入的消息的用量。但是，请注意，一旦注册了多个使用者，任何订购保证都将丢失。通常，对于少量队列，请坚持使用1个使用者。

但是，在底部有一个大警告：

不要增加主题的并发使用者数量。这将导致同时消耗同一消息，这几乎是不希望的。

这很有趣，并且在你考虑时是有道理的。如果你有多个DefaultMessageListenerContainer实例，则会发生相同的情况。

我想也许你需要重新考虑你的设计，尽管我不确定我会建议什么。并发使用pub / sub消息似乎是一件很合理的事情，但是如何避免同一条消息同时传递给所有使用者呢？