如有错误请指正
RabbitMQ中的概念,channel.basicQos(1)指该消费者在接收到队列里的消息但没有返回确认结果之前,它不会将新的消息分发给它。
下图代码的两个消费者,在处理消息的时候,分别休眠10,1000毫秒,默认的任务分发机制,会使两个消费者获取相同的消息数量。更合理的方式是,休眠少的消费者多劳,消费更多的消息,channel.basicQos(1)能使休眠多的消费者接受更少的消息数量,而再是公平分发数量。
如有错误请指正
RabbitMQ中的概念,channel.basicQos(1)指该消费者在接收到队列里的消息但没有返回确认结果之前,它不会将新的消息分发给它。
下图代码的两个消费者,在处理消息的时候,分别休眠10,1000毫秒,默认的任务分发机制,会使两个消费者获取相同的消息数量。更合理的方式是,休眠少的消费者多劳,消费更多的消息,channel.basicQos(1)能使休眠多的消费者接受更少的消息数量,而再是公平分发数量。