【RabbitMQ】WorkQueue

��      📝个人主页：五敷有你      

 🔥系列专栏：MQ

⛺️稳中求进，晒太阳

Work Queues

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

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

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

消息发送

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

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

@Autowired
private RabbitTemplate rabbitTemplate;
@Test
void testSendMessage2Queue() throws InterruptedException {
    String queueName1 = "work.queue";
    for(int i=0;i