小工具知识网

当前位置: 首页 > 行业知识 > 【RabbitMQ】WorkQueue

行业知识

【RabbitMQ】WorkQueue

2026-11-12 02:15:09 来源:互联网转载

��      个人主页:五敷有你      

 系列专栏:MQ

⛺️稳中求进,晒太阳

Work Queues

Work queues任务模型,简单来说就是让多个消费者绑定到一个队列,共同消费队列中的消息

当消息处理比较耗时的时候,可能生产消息的速度会远远大于消息的消费速度。长此以往,消息就会堆积越来越多,无法及时处理。

此时就可以使用work 模型,多个消费者共同处理消息处理,消息处理的速度就能大大提高了。

消息发送

这次我们循环发送,模拟大量消息堆积现象。

在publisher服务中的SpringAmqpTest类中添加一个测试方法:

@Autowiredprivate RabbitTemplate rabbitTemplate;@Testvoid testSendMessage2Queue() throws InterruptedException {    String queueName1 = "work.queue";    for(int i=0;i

上一篇:rundll下载详解,轻松获取所需文件,一步到位指南

下一篇:台式电脑服务器怎么接线?