springboot整合rabbitMQ系列（二）一个队列里面的信息，让多个消费者进行消费

一写代码就开心

发布于 2020-11-20 14:45:36

1.9K0

发布于 2020-11-20 14:45:36

文章被收录于专栏：java和python

之前讲解了第一个模型，直接队列模型，现在开始讲解工作模型

也就是有多个消费者要消费队列里面的信息，还是没有涉及到交换机。之前已经讲过，这个模型是rabbitmq默认使用轮询的方式将队列里面的信息发给多个消费者。

那么在springboot项目里面如何使用第二个模型呢？

发送者

这个和第一个模型是一样的，发送者还是往队列里面发送消息。往work队列里面发送消息

消费者

既然有了发送者，现在开始写消费者

@Component
public class WorkCustomer {
    @RabbitListener(queuesToDeclare = @Queue("work"))
    public void receive1 (String  message){
        System.out.println("message1="+message);
    }

    @RabbitListener(queuesToDeclare = @Queue("work"))
    public void receive2(String  message){
        System.out.println("message2="+message);
    }
}

两个不同的方法，就相当于是两个消费者

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2020/10/22 ，如有侵权请联系 cloudcommunity@tencent.com 删除

rabbitmq