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

也就是有多个消费者要消费队列里面的信息,还是没有涉及到交换机。
之前已经讲过,这个模型是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);
    }
}

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