RabbitMQ 四种交换机

淡淡的烟草味﹌ 2024-03-25 20:16 74阅读 0赞

RabbitMQ作为一个消息队列提供一个通用的消息发送和接收平台，并且保证消息在传输过程中的安全可靠。

消息(Message)由Client发送，RabbitMQ接收到消息之后通过交换机转发到对应的队列上面。Worker会从队列中获取未被读取的数据处理。

![format_png][]

#### 什么是交换机 ? ####

在 RabbitMQ 中，交换机主要用来将生产者生产出来的消息，传送到对应的频道中，即**交换机是一个消息传送的媒介**，其英文被称为 exchange 。交换机在 RabbitMQ 中起着承上启下的作用。

#### 交换机 ####

有4种不同的交换机类型：

*  直连交换机：Direct exchange

*  扇形交换机：Fanout exchange

*  主题交换机：Topic exchange

*  首部交换机：Headers exchange

#### 扇形交换机 ####

扇形交换机是最基本的交换机类型，它所能做的事情非常简单———广播消息。扇形交换机会把能接收到的消息全部发送给绑定在自己身上的队列。因为广播不需要“思考”，所以扇形交换机处理消息的速度也是所有的交换机类型里面最快的。

![format_png 1][]

#### 直连交换机 ####

直连交换机是一种带路由功能的交换机，一个队列会和一个交换机绑定，除此之外再绑定一个routing\_key，当消息被发送的时候，需要指定一个binding\_key，这个消息被送达交换机的时候，就会被这个交换机送到指定的队列里面去。同样的一个binding\_key也是支持应用到多个队列中的。

这样当一个交换机绑定多个队列，就会被送到对应的队列去处理。

![format_png 2][]

适用场景：有优先级的任务，根据任务的优先级把消息发送到对应的队列，这样可以指派更多的资源去处理高优先级的队列。

#### 主题交换机 ####

直连交换机的routing\_key方案非常简单，如果我们希望一条消息发送给多个队列，那么这个交换机需要绑定上非常多的routing\_key，假设每个交换机上都绑定一堆的routing\_key连接到各个队列上。那么消息的管理就会异常地困难。

所以RabbitMQ提供了一种主题交换机，发送到主题交换机上的消息需要携带指定规则的routing\_key，主题交换机会根据这个规则将数据发送到对应的(多个)队列上。

主题交换机的routing\_key需要有一定的规则，交换机和队列的binding\_key需要采用\*.\#.\*.....的格式，每个部分用.分开，其中：

*  \*表示一个单词

*  \#表示任意数量（零个或多个）单词。

假设有一条消息的routing\_key为fast.rabbit.white,那么带有这样binding\_key的几个队列都会接收这条消息：

1.  fast..

1.  ..white

1.  fast.\#

1.  ……

当一个队列的绑定键为\#的时候，这个队列将会无视消息的路由键，接收所有的消息。

#### 首部交换机 ####

首部交换机是忽略routing\_key的一种路由方式。路由器和交换机路由的规则是通过Headers信息来交换的，这个有点像HTTP的Headers。将一个交换机声明成首部交换机，绑定一个队列的时候，定义一个Hash的数据结构，消息发送的时候，会携带一组hash数据结构的信息，当Hash的内容匹配上的时候，消息就会被写入队列。

绑定交换机和队列的时候，Hash结构中要求携带一个键“x-match”，这个键的Value可以是any或者all，这代表消息携带的Hash是需要全部匹配(all)，还是仅匹配一个键(any)就可以了。相比直连交换机，首部交换机的优势是匹配的规则不被限定为字符串(string)。

[format_png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/68a0cd534d7040d3bf53835743f051fe.png
[format_png 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/70395fac23ec4ca78cdbdcae3fed8ee2.png
[format_png 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/25/ec0320dfdeff4096b14477eff10b886e.png