如何避免在rabbitMQ中使用彈簧連接（TCP）太多

Question

問：當消息（30,000+）氾濫時，消費者服務器建立了太多的TCP，甚至超過10,000個。爲了避免這種情況發生，在春季如何配置？

聽衆：

sendMQ

以下是rabbitmq.xml

Answer 1

這個計算器的問題可能會有所幫助：How is concurrency in Spring AMQP Listener Container implemented?

快速摘錄，請參閱「併發」：

<rabbit:listener-container 
     connection-factory="myConnectionFactory" 
     acknowledge="none" 
     concurrency="10" 
     requeue-rejected="false"> 
    <rabbit:listener ref="myListener" queues="myQueue"/> 
</rabbit:listener-container> 

我沒有使用Spring XML配置，但註釋，但是這是我用來限制併發用戶的數量：

@Bean 
    public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory() { 
     SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory(); 
     factory.setConnectionFactory(connectionFactory()); 

     // process each message one at a time 
     factory.setConcurrentConsumers(1); 
     factory.setMaxConcurrentConsumers(1); 
     return factory; 
    }