即使有8个消费者专用,仍有大量的消息未决,例如:如果有80000个消息,则只处理70000个消息,等待10000个消息。
没有内存限制问题,但……
该 onMessage() 方法是 synchronized ,这将不允许多个线程(消息)进入块并被处理,因为结果队列被填满,并且消息将超过其超时限制并最终进入队列。这对我来说是个问题。
onMessage()
synchronized