how to avoid too many connections(TCP) in rabbitMQ using spring

Question

Q: when messages(30,000+) flood in, the consumer server established too many TCP , even more than 10,000 .how to configer in spring to avoid that?!

listener:

sendMQ

the following is rabbitmq.xml

Answer 1

This stackoverflow question might help: How is concurrency in Spring AMQP Listener Container implemented?

Quick excerpt, see 'concurrency':

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

I am not using the Spring XML configuration, but annotations, but this is what I have used to limit the amount of concurrent consumers:

@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;
    }