RabbitMQ04_fanout广播模型

Myth丶恋晨 2022-12-19 09:18 134阅读 0赞

**RabbitMQ04\_fanout广播模型**  
![在这里插入图片描述][20201106160740637.png_pic_left]  
**生产者发送消息给交换机（Exchange）**  
**交换机将消息发送给所有绑定的队列**  
**队列的消费者都能拿到消息，实现了一条消息被多个消费者消费**

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

**消息生产者：**

public static void main(String[] args) throws IOException { 
        Connection connection = RabbitMQUtils.getConnection();
        Channel channel = connection.createChannel();
        //将通道声明指定的交换机
        //参数1：交换机名称（自定义） 参数2：交换机的类型 fanout表示广播类型
        channel.exchangeDeclare("logs", "fanout");
        //发送消息给交换机
        //参数2：在广播模型中routingKey没有意义，填空字符串
        channel.basicPublish("logs", "", null, "fanout type message".getBytes());
        RabbitMQUtils.closeConnectionAndChannel(channel, connection);
    }

**消费者1：**

public static void main(String[] args) throws IOException { 
        Connection connection = RabbitMQUtils.getConnection();
        Channel channel = connection.createChannel();
        //通道绑定交换机
        channel.exchangeDeclare("logs", "fanout");
        //创建临时队列
        String queueName = channel.queueDeclare().getQueue();
        //绑定交换机和队列,参数3：routingKey在fanout中无意义
        channel.queueBind(queueName, "logs", "");
        //消费消息
        channel.basicConsume(queueName, true, new DefaultConsumer(channel) { 
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, BasicProperties properties, byte[] body)
                throws IOException { 
                System.out.println("消费者1："+new String(body));
            }
        });
    
    }

**消费者2：**

public static void main(String[] args) throws IOException { 
        Connection connection = RabbitMQUtils.getConnection();
        Channel channel = connection.createChannel();
        channel.exchangeDeclare("logs", "fanout");
        String queueName = channel.queueDeclare().getQueue();
        channel.queueBind(queueName, "logs", "");
        channel.basicConsume(queueName, true, new DefaultConsumer(channel) { 
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, BasicProperties properties, byte[] body)
                throws IOException { 
                System.out.println("消费者2："+new String(body));
            }
        });
    
    }

**每当消息生产者生产消息时，消费者1和消费者2都能够消费消息，这就是广播模式**

[20201106160740637.png_pic_left]: /images/20221120/6de9bd6f3b754cb2b43e3efc62682a9a.png