rabbitmq基础-java-3、Fanout交换机-Toy模板网

这篇具有很好参考价值的文章主要介绍了rabbitmq基础-java-3、Fanout交换机。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

1、简介

Fanout，英文翻译是扇出。

rabbitmq基础-java-3、Fanout交换机,消息队列-rabbitmq,rabbitmq,分布式

2、特点

1）可以有多个队列

2）每个队列都要绑定到Exchange（交换机）

3）生产者发送的消息，只能发送到交换机

4）交换机把消息发送给绑定过的所有队列

5）订阅队列的消费者都能拿到消息

3、设置队列

rabbitmq基础-java-3、Fanout交换机,消息队列-rabbitmq,rabbitmq,分布式

4、设置交换机

rabbitmq基础-java-3、Fanout交换机,消息队列-rabbitmq,rabbitmq,分布式

5、绑定队列

rabbitmq基础-java-3、Fanout交换机,消息队列-rabbitmq,rabbitmq,分布式

6、设置生产者

    @Test
    void testSendFanout() {
        String exchangeName = "test.fanout";
        String msg = "hello, everyone!";
        rabbitTemplate.convertAndSend(exchangeName, null, msg);
    }

7、设置消费者

    @RabbitListener(queues = "fanout.queue1")
    public void listenFanoutQueue1(String msg) throws InterruptedException {
        System.out.println("消费者1 收到了 fanout.queue1的消息----：【" + msg +"】");
    }

    @RabbitListener(queues = "fanout.queue2")
    public void listenFanoutQueue2(String msg) throws InterruptedException {
        System.out.println("消费者2 收到了 fanout.queue2的消息====：【" + msg +"】");
    }