获取到达两个队列之一的第一条消息

Question

我有一个应用程序，我想使用队列A中的消息，但是如果队列A是空的，我希望它使用队列B中的消息，而不是闲置。我只希望它一次处理一条消息，如果使用者正忙于处理一条消息（来自任一队列），那么其他挂起的消息（在任一队列中）应该保留在他们的队列中，直到使用者再次空闲（这给其他使用者一个机会来处理新的消息）。

例如，如果一条消息在使用者空闲（等待）时到达队列a或队列B，那么使用者就会拾取它。如果在使用者当前正在处理消息时消息到达任一队列，则在使用者完成当前消息的处理之前不会发生任何事情。如果消息在队列a和队列B上都可用，则使用者更喜欢从队列a中选择消息。

Edit：实际上，我同样乐意得知消息可以在A和B上使用，并实现我自己的逻辑来选择我想从队列中提取的消息。

在单独的线程中同时订阅两个队列似乎不起作用,原因是：

• 如果消息M到达队列a，则使用者必须在处理消息M时从队列B退订，然后在消息M处理完毕后重新订阅。否则，如果消息到达队列B，它可能会被同时拾取和分派--我不想一次处理多条消息。
• 如果一条消息同时到达两个队列（或者当使用者启动或完成处理前一条消息时，两个队列中都有一条消息可用），那么在使用者有机会从队列B中退订之前，这两条消息都有可能被拾取。如果发生这种情况，我必须将其中一条消息回滚，但如果经常发生这种情况，则消息将超过回滚计数并被移到失败队列。

理想情况下，我想将其推广到N个队列的情况。我对理想情况下通过JMS工作的解决方案很感兴趣，但是如果我必须使用IBM MQ特定的API来实现这一点，也可以。是否有一个使用模式或库，将有助于实现这一点？是否有可供选择的排队方法/技术/技术允许它？

将所有消息从所有队列中取出并放入单个队列是不可行的；我们需要能够独立清除单个队列，不同的消费者可能订阅这N个队列的不同子集。

Answer 1

我不知道这对您的代码是否会是一个很大的改变，但是您有没有想过在您的项目中加入Spring框架，特别是Spring集成？您所描述的这些问题已经在那里得到了处理。

通过两个endpoint和两个队列上的事件驱动使用者以及一个线程池，可以解决这个问题。

http://www.eaipatterns.com/eventdrivenconsumer.html

http://en.wikipedia.org/wiki/thread_pool_pattern

[编辑]