更好的文章: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可以进行模糊匹配

headers

headers类型的Exchange不依赖于routing key与binding key的匹配规则来路由消息,而是根据发送的消息内容中的headers属性进行匹配。
在绑定Queue与Exchange时指定一组键值对;当消息发送到Exchange时,RabbitMQ会取到该消息的headers(也是一个键值对的形式),对比其中的键值对是否完全匹配Queue与Exchange绑定时指定的键值对;如果完全匹配则消息会路由到该Queue,否则不会路由到该Queue。(实际中我并有用过)

RabbitMQ简单架构图

图

RabbitMQ消息流转图

一个交换机可以绑定多个消息队列

图

Last modification:January 30, 2020
如果觉得我的文章对你有用,请随意赞赏