我正在尝试使用Spring JMS和ActiveMQ来处理大量消息。问题的上下文如下:每个客户生成一组消息,这些消息被添加到队列中。将消息添加到队列中,并将客户id作为参数。
在一种情况下,客户A可以向队列添加10k条消息,而客户B只能向同一队列添加100条消息。我的问题是,客户B需要等到所有10k消息都完成处理后,才能处理它的100条消息。
有没有办法同时处理客户A的一些消息和客户B的一些消息?我知道可以对来自客户B的消息设置更高的优先级,但当有多个客户时,这并不能解决问题。拥有更多消息的客户将填满队列,而其他客户将不得不等待。
如果你能提供一些帮助或建议,我将不胜感激。
https://stackoverflow.com/questions/55620671
复制相似问题