行业知识
RabbitMQ(任务模型,交换机(广播,订阅,通配符订阅))
2026-11-08 10:22:09
来源:互联网转载
一.WorkQueues模型
WorkQueues(任务���式):让多个消费者绑定到一个队列,共同消费队列中的消息。
架构:
所需场景:
当消息处理比较耗时的时候,可能生产消息的速度会远远大于消息的消费速度。长此以往,消息就会堆积越来越多,无法及时处理。 此时就可以使用work 模型,多个消费者共同处理消息处理,消息处理的速度就能大大提高了。
1.新建队work.queue
2.生产者模块循环发送消息
@Test void testWorkQueue() throws InterruptedException { String queueName = "work.queue"; for (int i = 1; i