RabbitMQ 工作模式之 fanout 模式

RabbitMQ 工作模式——fanout 模式（广播模型）

在广播模式下，消息发送流程是这样的：

可以有多个消费者
每个消费者有自己的 queue（队列）
每个队列都要绑定到 Exchange（交换机）
生产者发送的消息，只能发送到交换机，交换机来决定要发给哪个队列，生产者无法决定。
交换机把消息发送给绑定过的所有队列
队列的消费者都能拿到消息。实现一条消息被多个消费者消费

示例

使用广播模型的步骤如下：

创建连接工厂对象，设置对象参数
根据连接工厂对象获取连接对象
根据连接对象获取通道对象
获取通道对象之后，分生产者和消费者两种情况
- 生产者
  - 声明交换机以及该交换机的类型（这里为 fanout）
  - 发送消息
  - 关闭通道对象和连接对象
- 消费者
  - 声明交换机以及该交换机的类型
  - 获取到一个临时队列（因为广播类型可能就收一次广播消息，不知道对这个队列进行持久化）
  - 通道对象绑定队列名称以及交换机
  - 消费消息

1、Maven 依赖

pom.xml

<dependency>  
     <groupId>com.rabbitmq</groupId>  
     <artifactId>amqp-client</artifactId>  
     <version>5.7.2</version>  
</dependency>

2、定义生产者

public class Provider {  
  
  
 public static void main(String[] args) throws IOException {  
         // 获取连接对线  
         Connection connection = RabbitmqUtils.getConnection();  
         Channel channel = connection.createChannel();  

         //声明交换机  
         channel.exchangeDeclare("fanoutExchange","fanout");  

         //发送信息  
         channel.basicPublish("fanoutExchange","",null,"测试广播类型工作模式".getBytes());  
         
         //关闭资源  
         RabbitmqUtils.close(connection,channel);  
     }  
}

3、定义消费者

这里定义两个消费者，代码都一样，为了做区别，只在消费信息的时候标注是哪一个消费者消费。


public class Customer {  
     public static void main(String[] args) throws IOException {  
         //获取连接对线  
         Connection connection = RabbitmqUtils.getConnection();  
         Channel channel = connection.createChannel();  

         //通道绑定交换机  
         channel.exchangeDeclare("fanoutExchange","fanout");  

         //获取临时队列，广播类型没有必要对队列进行持久化  
         String tempQueueName = channel.queueDeclare().getQueue();  

         //绑定交换机和队列  
         channel.queueBind(tempQueueName,"fanoutExchange","");  

         channel.basicConsume(tempQueueName,true,new DefaultConsumer(channel){  
             @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {  
                 System.out.println("消费者1消费消息-> "+new String(body));  
             }  
         });  
     }  
}