RabbitMQ work模型
Work 模型是 RabbitMQ 最基础的消息处理模式,核心思想是 多个消费者竞争消费同一个队列中的消息,适用于任务分发和负载均衡场景。同一个消息只会被一个消费者处理。
当一个消息队列绑定了多个消费者,每个消息消费的个数都是平摊的,一人一个消息,不会考虑哪个消费者能力强弱。这样会造成消息堆积。
如何解决:修改yml文件,修改preFetch参数,控制消费者预取的消息数量,处理完再处理下一条,能者多劳
Work 模型是 RabbitMQ 最基础的消息处理模式,核心思想是 多个消费者竞争消费同一个队列中的消息,适用于任务分发和负载均衡场景。同一个消息只会被一个消费者处理。
当一个消息队列绑定了多个消费者,每个消息消费的个数都是平摊的,一人一个消息,不会考虑哪个消费者能力强弱。这样会造成消息堆积。
如何解决:修改yml文件,修改preFetch参数,控制消费者预取的消息数量,处理完再处理下一条,能者多劳