即使有8个消费者专用,仍有大量的消息未决,例如:如果有80000个消息,则只处理70000个消息,等待10000个消息。
没有内存限制问题,但仍然会更频繁地出现此问题
我发现设置预取限制会有所帮助,但仍然无法正常工作,但是当系统重新启动包括服务器(JBOSS)时,待处理消息将由消费者使用
是否有其他人遇到同样的问题并找到了解决方案?请帮忙!
onMessage()
方法是synchronized
,它不允许多个线程(消息)进入块并因为结果队列被填满而被处理,并且消息将超过其超时限制并最终进入队列。这对我来说是个问题。