The receiver sets the concurrency and current limit

1、 Receiver code

package com.example.demo.mq;

import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class Test1QueueReceiver {
    

	//concurrency = "2-5" Indicates that this queue is the smallest 2 individual , Maximum 5 Consumers 
    //mqlistenerContainer Need to be in config Middle configuration 
    @RabbitListener(queues = "test1_Queue",concurrency = "2-5",containerFactory = "mqlistenerContainer")
    public void process(String mes, Channel channel, Message message) {
    
        System.err.println(mes);

        // All relevant information of the message can be found in message Find 
        System.err.println(message.toString());
    }
}

2、 stay RabbitmqConfig Middle configuration mqlistenerContainer

@Autowired
private CachingConnectionFactory connectionFactory;


/** *  Current limiting  * @return */
@Bean(name = "mqlistenerContainer")
public SimpleRabbitListenerContainerFactory simpleRabbitListenerContainerFactory(){
    
    SimpleRabbitListenerContainerFactory factory=new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setPrefetchCount(75);
    return factory;
}

Complete the above , View queue information on the console

At this time, there are two consumers , When there are too many messages in the queue, it will become 5 Consumers . The upper limit of messages received per consumer per unit time is 75 strip