第三个模型是广播模型，这个模型里面就要使用交换机了，

生产者

@Test void testFanout() { //使用rabbitmq直接往队列里面放数据 // convertAndSend（）第一个参数 是 rabbitTemplate.convertAndSend("logs","","Fanout 模型里面发送的消息"); }

消费者

@Component public class FanoutCustomer { @RabbitListener(bindings = { @QueueBinding( value = @Queue, //创建临时队列 exchange = @Exchange(value = "logs",type = "fanout") //绑定的交换机 ) }) public void receivel(String message){ System.out.println("message1="+message); } @RabbitListener(bindings = { @QueueBinding( value = @Queue, //创建临时队列 exchange = @Exchange(value = "logs",type = "fanout") //绑定的交换机 ) }) public void receive2(String message){ System.out.println("message2="+message); } }

生产者在交换机里面发送了消息，发送者的第一个参数就是交换机。

既然在交换机里面已经接受到了消息

现在使用广播的形式在消费端进行接收消息，因为交换机和队列需要绑定，所以，我们在消费端可以直接使用绑定的注解，将队列和交换机进行绑定。注解就是如下的这种情况

@RabbitListener(bindings = { @QueueBinding( value = @Queue, //创建临时队列 exchange = @Exchange(value = "logs",type = "fanout") //绑定的交换机 ) })

现在我们创建多个消费者，那么多个消费者都会接受到消息，因为这个是广播的模型