RabbitMQ实现（并发）多线程处理消息

@RabbitListener默认是单线程监听队列(@RabbitListener(queues = {MqConstants.OA_TAB_REFRESH}, concurrency = "10") 也能实现⼗个并发)

缺点 : 单线程处理消息, 当消息队列有多个任务时消费端监听队列每次只消费⼀个消息 , 容易引起消息堆积 , 处理效率慢…透水混凝土做法

解决⽅法 : 多线程处理消息 , 配置mq容器⼯⼚参数 , 增加并发处理量 .

@Configuration

public class RabbitMQConfig {

public static final String QUEUE_INFORM_EMAIL = "queue_inform_email";

// 声明交换机

// 声明队列

// 队列绑定交换机，指定routingKey

...

//并发数量

public static final int DEFAULT_CONCURRENT = 10;

@Bean("customContainerFactory")

public SimpleRabbitListenerContainerFactory containerFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer,

ConnectionFactory connectionFactory) {

SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();

factory.setConcurrentConsumers(DEFAULT_CONCURRENT);

桶盖

电路板测试台factory.setMaxConcurrentConsumers(DEFAULT_CONCURRENT);

return factory;

}

@Component

紫外可见漫反射光谱public class ReceiveHandler {

private static final Logger LOGGER = Logger(ReceiveHandler.class);

// 在@RabbitListener注解中指定容器⼯⼚

@RabbitListener(queues = {RabbitmqConfig.QUEUE_INFORM_EMAIL},

containerFactory = "customContainerFactory")

//@RabbitListener(queues = {MqConstants.OA_TAB_REFRESH}, concurrency = "10") 也能实现⼗个并发

public void send_email(String msg,Message message,Channel channel){

LOGGER.info("receive message is:"+msg);

粉尘气溶胶发生器>第五指令

// work

...

}

本文发布于:2024-09-21 19:08:27，感谢您对本站的认可！

标签：消息队列并发

留言与评论（共有 0 条评论）