更好的文章:https://blog.csdn.net/super_rd/article/details/70238869
AMQP协议模型
rabbitmq是支持amqp协议的、协议模型也是其他语言通用、rabbitmq是支持php扩展amqp中最好的服务。
核心概念
Server 又称Broker
, 接受客户端的连接,实现AMQP实体服务
Connection
:连接,应用程序与Broker的网络链接。
Channel
:网络信道,几乎所有的操作都在Chanel中进行,Channel是进行消息读写的通道。客户端可建立多个chanel,每个Channel代表一个会话任务。(只要和rabbitmq都要用channel)。
Message
:消息, 服务器和应用程序之间传送的数据,amqp的消息有两部分Properties和Body组成。Properties:可以对消息进行修饰、比如消息的优先级、延迟等高级特性;Body则就是消息体内容。
Virtual host
:虚拟地址,用于进行逻辑隔离,最上层的消息路由(类似redis中16个db)。一个Virtual Host里面可以有若干个Exchange和Queue,同一个Virtual host 里面不能有相同名称的Exchange或Queue
Exchange
:交换机,接收消息,根据路由键转发消息到绑定的列队(消息的发送必须先要发送到Exchange上)。
Binding
: Exchange和Queue之间的虚拟连接,binding中可以包含routing key
Routing key
: 一个路由规则,虚拟机可用它来确定如何路由一个特定消息。
Queue
:也称为Message Queue,消息队列,保存消息并将他们转发给消费者
Exchange Types
fanout
fanout类型的Exchange路由规则非常简单,它会把所有发送到该Exchange的消息路由到所有与它绑定的Queue中。
生产者发送到Exchange的所有消息都会路由到绑定的Queue,并最终被两个消费者消费。
direct
direct类型的Exchange路由规则也很简单,它会把消息路由到那些binding key与routing key完全匹配的Queue中。(在实际使用RabbitMQ的过程中并没有binding key这个参数,只有routing key,为了区分我们把交换机和队列绑定时传的参数叫binding key,把发送消息时带的这个参数叫routing key)
topic
前面讲到direct类型的Exchange路由规则是完全匹配binding key与routing key,但这种严格的匹配方式在很多情况下不能满足实际业务需求。topic类型的Exchange在匹配规则上进行了扩展,它与direct类型的Exchage相似,也是将消息路由到binding key与routing key相匹配的Queue中,但direct是完全匹配,而通过topic可以进行模糊匹配
routing key为一个句点号“. ”分隔的字符串(我们将被句点号“. ”分隔开的每一段独立的字符串称为一个单词),如“stock.usd.nyse”、“nyse.vmw”、“quick.orange.rabbit”
binding key与routing key一样也是句点号“. ”分隔的字符串
binding key中可以存在两种特殊字符“”与“#”,用于做模糊匹配,其中“”用于匹配一个单词,“#”用于匹配多个单词(可以是零个)
headers
headers类型的Exchange不依赖于routing key与binding key的匹配规则来路由消息,而是根据发送的消息内容中的headers属性进行匹配。
在绑定Queue与Exchange时指定一组键值对;当消息发送到Exchange时,RabbitMQ会取到该消息的headers(也是一个键值对的形式),对比其中的键值对是否完全匹配Queue与Exchange绑定时指定的键值对;如果完全匹配则消息会路由到该Queue,否则不会路由到该Queue。(实际中我并有用过)
RabbitMQ简单架构图
RabbitMQ消息流转图
一个交换机可以绑定多个消息队列