rabbitmq-fanout（广播模式）

骑猪看日落 2022-05-17 04:15 183阅读 0赞

# RabbitMQ—fanout（广播模式） #

--------------------

## 一、什么是fanout(广播模式) ##

简单的讲，就是把交换机（Exchange）里的消息发送给所有绑定该交换机的队列，**忽略**routingKey。

![这里写图片描述][70]

由图可知，生产者把消息发送到交换机后，由交换机发送给消费者队列。消费者队列如果想要接收到交换机里的消息，那么需要保证：队列绑定的交换机名称要和交换机一致，这个是广播模式的关键，也是MQ后续所有模式最粗略的前提。

比如：  
1）生产者声明一个交换机（Exchange），交换机名称为“**fanoutLogs**”，类型为广播模式“**fanout**”，消息为“Now you see me”；

channel.exchangeDeclare("fanoutLogs", "fanout");

2）消费者声明一个队列**Q1**，声明一个交换机（名称为“**fanoutLogs**”，类型为广播模式”**fanout**“），最后队列和交换机绑定；

channel.exchangeDeclare("fanoutLogs", "fanout");
    channel.queueBind("Q1", "fanoutLogs", "");

3）消费者声明另一个队列**Q2**，声明一个交换机（名称为”***phantaciLogs***“，类型为广播模式”**fanout**“），最后队列与交换机绑定；

channel.exchangeDeclare("phantaciLogs", "fanout");
    channel.queueBind("Q2", "phantaciLogs", "");

4）**需注意，我们要先启动声明消费者，再启动声明生产者。否则先启动生产者的话，exchange接到消息后发现没有队列对它感兴趣，就任性的把消息给丢掉了**；

5）Q1和Q2两个消费者启动后，启动生产者。可以发现，**和生产者交换机（Exchange）名称相同的Q1正常接收到消息**；Q2虽然也是广播模式（fanout），但交换机名称不同，所以未接收到消息。

> RabbitMQ消息模型的**核心思想（core idea）**: 生产者会把消息发送给RabbitMQ的交换中心（Exchange），Exchange的一侧是生产者，另一侧则是一个或多个队列，由Exchange决定一条消息的生命周期–发送给某些队列，或者直接丢弃掉。

--------------------

## 二、代码域 ##

### 1. 生产者【FanoutBoss】 ###

### 2. 消费者【FanoutWorker】 ###

package com.iyungu.phantaci.test.rabbitmq;
    
    import com.rabbitmq.client.*;
    import org.apache.log4j.Logger;
    
    import java.io.IOException;
    import java.util.concurrent.TimeoutException;
    
    //广播模式-消息消费者
    public class FanoutWorker {
    
        private static final Logger logger = Logger.getLogger(FanoutWorker.class);
        public static void main(String[] args) {
    
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            try {
                Connection connection = factory.newConnection();
                Channel channel = connection.createChannel();
                //交换机声明（参数为：交换机名称；交换机类型）
                channel.exchangeDeclare("fanoutLogs",BuiltinExchangeType.FANOUT);
                //获取一个临时队列
                String queueName = channel.queueDeclare().getQueue();
                //队列与交换机绑定（参数为：队列名称；交换机名称；routingKey忽略）
                channel.queueBind(queueName,"fanoutLogs","");
    
                logger.info("********Waiting for messages********");
    
                //这里重写了DefaultConsumer的handleDelivery方法，因为发送的时候对消息进行了getByte()，在这里要重新组装成String
                Consumer consumer = new DefaultConsumer(channel) {
                    @Override
                    public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                        super.handleDelivery(consumerTag, envelope, properties, body);
                        String message = new String(body,"UTF-8");
                        logger.info("received:" + message);
                    }
                };
    
                //声明队列中被消费掉的消息（参数为：队列名称；消息是否自动确认;consumer主体）
                channel.basicConsume(queueName,true,consumer);
                //这里不能关闭连接，调用了消费方法后，消费者会一直连接着rabbitMQ等待消费
            } catch (IOException |TimeoutException e) {
                e.printStackTrace();
            }
    
    
        }
    
    }

--------------------

## 三、广播模式效果 ##

### 1. 先运行三个消费者，即【FanoutWorker】 ###

#### 控制台效果图如下，三个消费者等待接收消息 ####

![EkTa3B2.png][]  
![SX84VSW.png][]  
![SDIPPpD.png][]

#### RabbitMQ网页控制台如下，可看到三个消费者队列 ####

![hht9Vrv.png][]

### 2. 再运行一个生产者，即【FanoutBoss】 ###

#### 控制台效果图如下，一条消息发布后，三个消费者都接收到了消息 ####

![7VLUI5T.png][]  
![QGTufQU.png][]  
![AbD1s9I.png][]  
![Ar2Xroi.png][]

--------------------

> 参考：[http://www.cnblogs.com/4—-/p/6518801.html][http_www.cnblogs.com_4_-_p_6518801.html]，感谢分享

[70]: /images/20220517/498207e8439d43f5b0fe8f1eef30ff05.png
[EkTa3B2.png]: https://i.imgur.com/EkTa3B2.png
[SX84VSW.png]: https://i.imgur.com/SX84VSW.png
[SDIPPpD.png]: https://i.imgur.com/SDIPPpD.png
[hht9Vrv.png]: https://i.imgur.com/hht9Vrv.png
[7VLUI5T.png]: https://i.imgur.com/7VLUI5T.png
[QGTufQU.png]: https://i.imgur.com/QGTufQU.png
[AbD1s9I.png]: https://i.imgur.com/AbD1s9I.png
[Ar2Xroi.png]: https://i.imgur.com/Ar2Xroi.png
[http_www.cnblogs.com_4_-_p_6518801.html]: http://www.cnblogs.com/4----/p/6518801.html