Queues

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

当消息处理比较耗时的时候可能生产消息的速度会远远大于消息的消费速度。

长此以往消息就会堆积越来越多无法及时处理。

消息发送

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

Autowired

编号i;rabbitTemplate.convertAndSend(queueName1,

消息接收

要模拟多个消费者绑定同一个队列我们在consumer服务的SpringRabbitListener中添加2个新的方法

work.queue)

{System.out.println(消费者1收到了work.queue的消息【

msg

{System.err.println(消费者1收到了work.queue的消息【

msg

消息是平均分配给每个消费者并没有考虑到消费者的处理能力。

导致1个消费者空闲另一个消费者忙的不可开交。

没有充分利用每一个消费者的能力最终消息处理的耗时远远超过了1秒。

这样显然是有问题的。

能者多劳

spring:rabbitmq:listener:simple:prefetch:

再次测试发现结果如下.

可以发现由于消费者1处理速度较快所以处理了更多的消息消费者2处理速度较慢只处理了6条消息。

而最终总的执行耗时也在1秒左右大大提升。

正所谓能者多劳这样充分利用了每一个消费者的处理能力可以有效避免消息积压问题。

多个消费者绑定到一个队列同一条消息只会被一个消费者处理通过设置prefetch来控制消费者预取的消息数量