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

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

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

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

发送者

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

消费者

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

代码语言：javascript复制

@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);
    }
}

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

rabbitmq 队列 工作 交换机 模型

0 人点赞