1 发布/订阅模型简介

1. 可以看到，在订阅模型中，多了一个exchange角色，而且过程略有变化：
   • Publisher：生产者，也就是要发送消息的程序，但是不再发送到队列中，而是exchange交换机
   • Exchange：交换机。一方面，接收生产者发送的消息。另一方面，知道如何处理消息，例如递交给某个特别队列、递交给所有队列、或是将消息丢弃。到底如何操作，取决于Exchange的类型。Exchange有以下3种类型：
     • Fanout：广播，将消息交给所有绑定到交换机的队列
     • Direct：定向，把消息交给符合指定routing key 的队列
     • Topic：通配符，把消息交给符合routing pattern（路由模式） 的队列
   • Consumer：消费者，与以前一样，订阅队列，没有变化
   • Queue：消息队列也与以前一样，接收消息、缓存消息。
2. Exchange（交换机）只负责转发消息，不具备存储消息的能力，因此如果没有任何队列与Exchange绑定，或者没有符合路由规则的队列，那么消息会丢失！

2 发布/订阅模型：Fanout-Exchange广播交换机

2.1 Fanout-Exchange

1. Fanout Exchange 会将接收到的消息广播到每一个跟其绑定的queue
   
2. 在广播模式下，消息发送流程是这样的：
   1. 可以有多个队列
   2. 每个队列都要绑定到Exchange（交换机）
   3. 生产者发送的消息，只能发送到交换机，交换机来决定要发给哪个队列，生产者无法决定
   4. 交换机把消息发送给绑定过的所有队列
   5. 订阅队列的消费者都能拿到消息

2.2 案例

• 创建一个交换机 itcast.fanout，类型是Fanout
• 创建两个队列fanout.queue1和fanout.queue2，绑定到交换机itcast.fanout

2.2.1 声明交换机、队列和绑定

1. Spring提供了声明交换机、队列、绑定关系的API，其中Exchange接口表示所有不同类型的交换机
   
2. 在consumer服务中创建一个类，添加@Configuration注解，并声明FanoutExchange、Queue和绑定关系对象Binding

package cn.itcast.mq.config;

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class FanoutConfig {

    // 声明交换机：itcast.fanout
    @Bean
    public FanoutExchange fanoutExchange() {
        return new FanoutExchange("itcast.fanout");
    }

    // 声明队列1：fanout.queue1
    @Bean
    public Queue fanoutQueue1() { // 注意Queue来自amqp.core包
        return new Queue("fanout.queue1");
    }

    // 绑定队列1到交换机
    @Bean
    public Binding fanoutBinding1(Queue fanoutQueue1, FanoutExchange fanoutExchange) { // 注意Binding来自amqp.core包
        return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);
    }

    // 声明队列2：fanout.queue2
    @Bean
    public Queue fanoutQueue2() {
        return new Queue("fanout.queue2");
    }

    // 绑定队列2到交换机
    @Bean
    public Binding fanoutBinding2(Queue fanoutQueue2, FanoutExchange fanoutExchange) {
        return BindingBuilder.bind(fanoutQueue2).to(fanoutExchange);
    }
}

3. 启动测试

2.2.2 消息发送

2.2.3 消息接收

2.3 小结

1. 交换机的作用是什么？
   • 接收publisher发送的消息
   • 将消息按照规则路由到与之绑定的队列
   • 不能缓存消息，路由失败，消息丢失
   • FanoutExchange的会将消息路由到每个绑定的队列
2. 声明队列、交换机、绑定关系的Bean是什么？
   • Queue
   • FanoutExchange
   • Binding

3 发布/订阅模型：Direct-Exchange定向交换机

小结

1. 描述下Direct交换机与Fanout交换机的差异？
   • Fanout交换机将消息路由给每一个与之绑定的队列
   • Direct交换机根据RoutingKey判断路由给哪个队列
   • 如果多个队列具有相同的RoutingKey，则与Fanout功能类似
2. 基于@RabbitListener注解声明队列和交换机有哪些常见注解？
   • @Queue
   • @Exchange

4 发布/订阅模型：Topic-Exchange通配符交换机

小结

1. 描述下Direct交换机与Topic交换机的差异？
   • Topic交换机接收的消息RoutingKey必须是多个单词，以 **.** 分割
   • Topic交换机与队列绑定时的bindingKey可以指定通配符
   • #：代表0个或多个词
   • *：代表1个词