我正在使用 ActiveMQ 队列并将消息发布到队列并使用已发布的消息。我正在使用 spring DefaultMessageListenerContainer 来使用队列中的消息。我的队列名称是 case-queue。当 DefaultMessageListenerContainer 正在运行时,我在 ActiveMQ Console 中看到,在 Topic 下——对于 ActiveMQ.Advisory.Consumer.Queue.cases-queue 和 ActiveMQ.Advisory.Connection —— Enqueue # 保持一个以 10 为增量递增。
将 ActiveMQConnectionFactory.setWatchTopicAdvisories(false) 帮助。抱歉,我对 ActiveMQ 不太熟悉。
我不确定 ActiveMQ.Advisory.Consumer.Queue.cases-queue 是什么。什么是队列#?为什么 ActiveMQ.Advisory.Consumer.Queue.cases-queue 中的 Enqueue # 不断增加?为什么 Enqueue # 在 ActiveMQ.Advisory.Connection 中不断增加?这会导致服务器内存不足吗?
我还注意到,对于不同的队列 ActiveMQ.Advisory.Consumer.Queue.data-queue,Enqueue # 不会增加。我不确定这个队列监听器/消费者是如何实现的。
请看下图: