multithreading - Spring-integration/ActiveMQ 在单个线程中订阅多个目的地

Question

我正在使用多个 <si:service-activator>的和 <jms:message-driven-channel-adapter>订阅多个队列和主题。来自每个目的地的消息都在一个单独的线程中接收，这意味着我的接收代码充满了锁来保护可变的内部状态。

我希望我的接收代码是无锁的。是否可以将 spring-integration/activemq 配置为从同一线程上的多个目的地接收？

如果这是不可能的，我可以想到两种选择:

启动我自己的从阻塞队列中读取的处理线程，将所有收到的消息放在这个队列中。

将所有收到的消息分派(dispatch)到一个目的地并从中消费。

有人有更好的想法吗？

Answer 1

使用 wildcard pattern在一个队列上。
也就是说，不要从两个队列中读取，而是使用一个队列并在名称中指定要读取的所有队列。
即:"QUEUE.NR1,QUEUE.NR2"或 "SOME.PREFIX.>"读取具有该前缀的所有队列。您的客户端代码将其作为单个队列处理。