消息模型:
代码模拟:
相较于之前的基础队列,该队列新增了消费者 不再是一个,所以我们通过代码模拟出两个consumer消费者。在原来的消费者类里写两个方法 其中消费者1效率高 消费者2效率低
@RabbitListener(queues = "simple.queue")public void lintestWorkQueue50(String mes) throws InterruptedException {System.out.println("消费者1接收到了消息:" + mes +" "+ LocalDateTime.now());Thread.sleep(20);}@RabbitListener(queues = "simple.queue")public void lintestWorkQueue10(String mes) throws InterruptedException {System.err.println("消费者2接收到了消息:" + mes + " "+LocalDateTime.now());Thread.sleep(200);}
在publisher提供者编写测试方法 一次发送50条消息
发送后让观察控制台消费者处理情况 会发现两者处理的效率不一样但是处理的消息是平均分配的,一人25条,这是因为Rabbit有个预取机制,不管执行消费者效率,消费者都会提前在队列里预取一个消息,最后效果就是平均分配。
这个预取机制可以在yml配置里修改。