消息模型:

代码模拟:

相较于之前的基础队列，该队列新增了消费者 不再是一个，所以我们通过代码模拟出两个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配置里修改。