目录
- 一、概述
- 二、Direct Exchange (直连型交换机)
- 三、Fanout Exchange(扇型交换机)
- 四、Topic Exchange(主题交换机)
- 五、Header Exchange(头交换机)
- 六、Default Exchange(默认交换机)
- 七、Dead Letter Exchange(死信交换机)
一、概述
RabbitMQ最简单的实现流程如下:首先生产者将消息推送至RabbitMQ服务,然后经过交换机,队列等各种关系,将数据处理入列后,最终由消费者获取对应监听的消息。
常用的交换机有以下六种,因为消费者是从队列获取信息的,队列是绑定交换机的(一般),所以对应的消息推送/接收模式也会有以下几种:
- Direct Exchange (直连型交换机)
- Fanout Exchange(扇型交换机)
- Topic Exchange(主题交换机)
- Header Exchange(头交换机)
- Default Exchange(默认交换机)
- Dead Letter Exchange(死信交换机)
二、Direct Exchange (直连型交换机)
直连型交换机,也可以叫做定向交换机
。根据消息携带的路由键
将消息投递给对应的队列。
大致流程:有一个队列绑定了一个直连交换机,同时赋予了一个路由键routing key
。然后当一个消息携带路由值为X
,这个消息通过生产者发送给交换机时,交换机就会根据这个路由值X
去寻找绑定值也是X
的队列。
RabbitMQ:SpringAMQP Direct Exchange(直连型交换机)
三、Fanout Exchange(扇型交换机)
扇型交换,也可以叫做广播交换机
。这个交换机没有路由的概念,就算绑定了路由键也是无视的。交换机在接收到消息后,会直接转发到绑定到它上面的所有队列
上。
RabbitMQ:SpringAMQP Fanout Exchange(扇型交换机)
四、Topic Exchange(主题交换机)
主题交换机,这个交换机跟直接交换机流程差不多,但是它的特点就是它的路由键跟绑定键是有规则的
。
* (星号) 用来表示一个单词 (必须出现的)
# (井号) 用来表示任意数量(零个或多个)单词
通配的绑定键是跟队列进行绑定的,举个小例子
队列Q1 绑定键为 *.TT.*
队列Q2绑定键为 TT.#
如果一条消息携带的路由键为 A.TT.B,那么队列Q1将会收到;
如果一条消息携带的路由键为TT.AA.BB,那么队列Q2将会收到;
总结:
- 当一个队列的绑定键为
“#”(井号)
的时候,这个队列将会无视消息的路由键,接收所有的消息
。 - 当
* (星号)
和# (井号)
这两个特殊字符都未在绑定键中出现的时候,此时主题交换机就拥有的直连交换机
的行为。
所以主题交换机也就实现了扇形交换机的功能,和直连交换机的功能。
RabbitMQ:SpringAMQP Topic Exchange(主题交换机)