【原】RabbitMQ基本概念

2017-09-12  本文已影响0人  曹赫洋

快速入门

Broker:可以理解为消息队列服务器的实体,它是一个中间件应用,负责接收消息生产者的消息,然后将消息发送至消息接收者或者其他的Broker。
Exchange:消息交换机,是消息第一个到达的地方,消息通过它指定的路由规则,分发到不同的消息队列中去。
Queue:消息队列,消息通过发送和路由之后最终到达的地方,到达Queue的消息即进入逻辑上等待消费的状态。每个消息都会被发送到一个多个队列。
Binding:绑定,它的作用就是把Exchange和Queue按照路由规则绑定起来,也就是Exchange和Queue之间的虚拟连接。
Routing Key:路由关键字,Exchange根据这个关键字进行消息投递。
Virtual host:虚拟主机,它是对Broker的虚拟划分,将消费者、生产者和它们依赖的AMQP相关结构进行隔离,一般都是为了安全考虑。比如,我们可以在一个Broker中设置多个虚拟主机,对不同用户进行权限的分离。
Connection:连接,代表生产者、消费者、Broker之间进行通信的物理网络。
Channel:消息通道,用于连接生产者和消费者的逻辑结构。在客户端的每个连接里,可建立多个Channel,每个Channel代表一个会话任务,通过Channel可以隔离同一连接中的不同交互内容。
Producer:消息生产者,制造消息并发送消息的程序。
Consumer:消息消费者,接收消息并处理消息的程序。

消息投递到队列的过程

1.客户端连接到消息队列服务器,打开一个Channel。
2.客户端声明一个Exchange,并设置相关属性。
3.客户端声明一个Queue,并设置相关属性。
4.客户端使用Routing Key,在Exchange和Queue之间建立好绑定关系。
5.客户端投递消息到Exchange。
6.Exchange接收到消息后,根据消息的key和已经设置的Binding,进行消息路由,将消息投递到一个或多个Queue里。

Exchange类型

1.Direct交换机:完全根据key进行投递。比如,绑定时设置了Routing Key为abc,那么客户端提交的消息,只有设置了Key为abc的才会被投递到队列。
2.Topic交换机:对key进行模式匹配后进行投递,可以使用符号#匹配一个多个词,符号匹配正好一个词。比如abc.#匹配abc.def.ghi,acb.只匹配abc.def。
3.Fanout交换机:不需要任何key,它采取广播的模式,一个消息进来时,投递到与该交换机绑定的所有队列。

消息队列持久化

1.Exchange持久化,在声明时指定durable => 1。
2.Queue 持久化,在声明时指定durable => 1。
3.消息持久化,在投递时指定devivery_mode > =2 (1是非持久化)
如果Exchange和Queue 都是持久化的,那么它们之间的Binding也是持久化的。如果Exchange和Queue 两者之间有一个是持久化的,一个是非持久化的,就不允许建立连接。

上一篇下一篇

猜你喜欢

热点阅读