如何使用java和spring 3.0从JMS主题(而不是队列)同时处理多个消息？

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了如何使用java和spring 3.0从JMS主题(而不是队列)同时处理多个消息？，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2047字，纯文字阅读大概需要3分钟。

内容图文

请注意,我希望多个消息侦听器同时处理来自主题的连续消息.此外,我希望每个消息监听器都以事务方式运行,以便给定消息监听器中的处理失败将导致该监听器的消息保留在该主题上.

Spring 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
...

更新：
感谢您的反馈@ T.Rob和@skaffman.

我最后要做的是创建多个DefaultMessageListenerContainers,其中concurrency = 1,然后将逻辑放在消息监听器中,这样只有一个线程可以处理给定的消息ID.

解决方法:

您不需要多个DefaultMessageListenerContainer实例,但是您需要使用concurrentConsumers property将DefaultMessageListenerContainer配置为并发：

Specify the number of concurrent
consumers to create. Default is 1.

Specifying a higher value for this
setting will increase the standard
level of scheduled concurrent
consumers at runtime: This is
effectively the minimum number of
concurrent consumers which will be
scheduled at any given time. This is a
static setting; for dynamic scaling,
consider specifying the
“maxConcurrentConsumers” setting
instead.

Raising the number of concurrent
consumers is recommendable in order to
scale the consumption of messages
coming in from a queue. However, note
that any ordering guarantees are lost
once multiple consumers are
registered. In general, stick with 1
consumer for low-volume queues.

然而,底部有一个很大的警告：

Do not raise the number of concurrent consumers for a topic.
This would lead to concurrent
consumption of the same message, which
is hardly ever desirable.

这很有意思,当你想到它时就有意义了.如果您有多个DefaultMessageListenerContainer实例,则会发生相同的情况.

我想也许你需要重新考虑你的设计,虽然我不确定我的建议.同时消费发布/订阅消息似乎是一件非常合理的事情,但是如何避免同时向所有消费者传递相同的消息？

内容总结

以上是互联网集市为您收集整理的如何使用java和spring 3.0从JMS主题(而不是队列)同时处理多个消息？全部内容，希望文章能够帮你解决如何使用java和spring 3.0从JMS主题(而不是队列)同时处理多个消息？所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端