RabbitMQ的四种交换机

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

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

消息处理的过程code

交换机

有4种不一样的交换机类型:队列

  • 直连交换机:Direct exchange
  • 扇形交换机:Fanout exchange
  • 主题交换机:Topic exchange
  • 首部交换机:Headers exchange

 

扇形交换机资源

扇形交换机是最基本的交换机类型,它所能作的事情很是简单———广播消息。扇形交换机会把能接收到的消息所有发送给绑定在本身身上的队列。由于广播不须要“思考”,因此扇形交换机处理消息的速度也是全部的交换机类型里面最快的。路由

扇形交换机字符串

直连交换机消息队列

直连交换机是一种带路由功能的交换机,一个队列会和一个交换机绑定,除此以外再绑定一个routing_key,当消息被发送的时候,须要指定一个binding_key,这个消息被送达交换机的时候,就会被这个交换机送到指定的队列里面去。一样的一个binding_key也是支持应用到多个队列中的。string

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

直连交换机

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

主题交换机

直连交换机的routing_key方案很是简单,若是咱们但愿一条消息发送给多个队列,那么这个交换机须要绑定上很是多的routing_key,假设每一个交换机上都绑定一堆的routing_key链接到各个队列上。那么消息的管理就会异常地困难。

因此RabbitMQ提供了一种主题交换机,发送到主题交换机上的消息须要携带指定规则的routing_key,主题交换机会根据这个规则将数据发送到对应的(多个)队列上。

主题交换机的routing_key须要有必定的规则,交换机和队列的binding_key须要采用*.#.*.....的格式,每一个部分用.分开,其中:

  • *表示一个单词
  • #表示任意数量(零个或多个)单词。

假设有一条消息的routing_keyfast.rabbit.white,那么带有这样binding_key的几个队列都会接收这条消息:

  1. fast..
  2. ..white
  3. fast.#
  4. ……

这个图是网上找的,感受对主题交换机的描述比较到位:

主题交换机

当一个队列的绑定键为#的时候,这个队列将会无视消息的路由键,接收全部的消息。

首部交换机

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

绑定交换机队列的时候,Hash结构中要求携带一个键“x-match”,这个键的Value能够是any或者all,这表明消息携带的Hash是须要所有匹配(all),仍是仅匹配一个键(any)就能够了。相比直连交换机,首部交换机的优点是匹配的规则不被限定为字符串(string)。

--转载