哪些网站用python做的,陕西住房建设部网站,数字营销前景,佛山网站建设公司消息模型: 代码模拟:
相较于之前的基础队列#xff0c;该队列新增了消费者 不再是一个#xff0c;所以我们通过代码模拟出两个consumer消费者。在原来的消费者类里写两个方法 其中消费者1效率高 消费者2效率低
RabbitListener(queues simple.queue)public voi…消息模型: 代码模拟:
相较于之前的基础队列该队列新增了消费者 不再是一个所以我们通过代码模拟出两个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配置里修改。
