RabbitMQ 相关概念和方法详解

名词解释

• ConnectionFactory: 与 RabbitMQ 服务器链接的管理器。
• Connection: 与 RabbitMQ 服务器的链接。
• Channel: 与 Exchange 的链接。
• Exchange: 接收生产者的消息，并根据消息的 RoutingKey 和 Exchange 绑定的 BindingKey 分配消息。
• Queue: 存储消费者的消息。
• RoutingKey: 指定当前消息被谁接收。
• BindingKey: 指定当前 Exchange 下，什么样的 RoutingKey 会被下派到当前绑定的 Queue 中。

exchange_declare 方法详解

def exchange_declare(self, callback=None, exchange=None, exchange_type='direct', passive=False, durable=False, auto_delete=False, internal=False, nowait=False, arguments=None):

• callback 若是 nowait=True 且 Exchange.DeclareOk 时，调用这个回调方法。
• exchange 交换器名称。
• exchange_type 交换器类型，常见的如 fanout direct topic。
• passive 若是为 true , 则执行声明或者检查交换器是否存在。
• durable 设置是否持久化。durable 设置为 true 表示持久化，反之非持久化。持久化能够将交换器存盘，在服务器重启的时候不会丢失消息。
• auto_delete 设置是否自动删除。auto_delete 设置为 true 则表示自动删除。自动删除的前提是至少有一个队列或者交换器绑定，以后全部与这个交换器绑定的队列或者交换器都与此解绑。注意不能错误地把这个参数理解为："当与此交换器链接的客户端都断开时，RabbitMQ 会自动删除本交换器"。
• internal 设置是不是内置的。若是设置为 true，则表示是内置的交换器，客户端程序没法直接发送消息到这个交换器中，只能经过交换器路由到交换器这种方式。
• nowait 若是设置为 false, 则不指望 RabbitMQ 服务器有一个 Exchange.DeclareOk 这样响应。
• arguments 其余一些结构化参数。好比：alternate-exchange。

exchange_bind 方法详解

def exchange_bind(self, callback=None, destination=None, source=None, routing_key='', nowait=False, arguments=None):

• callback 若是 nowait=True 且 Exchange.DeclareOk 时，调用这个回调方法。
• destinaction 一种交换器。
• source 消息从 source 交换器转发到 destination 交换器，从某种程度上看 destination 交换器能够是一种队列。
• routing_key 用来绑定队列和交换器的路由键。
• nowait 若是设置为 false, 则不指望 RabbitMQ 服务器有一个 Exchange.DeclareOk 这样响应。
• arguments 其余一些结构化参数。

queue_declare 方法详解

def queue_declare(self, queue='', passive=False, durable=False, exclusive=False, auto_delete=False, arguments=None):

• queue 队列名称。
• passive 若是为 true , 则执行声明或者检查队列是否存在。
• durable 设置是否持久化。为 true 则设置队列为持久化。持久化的队列会存盘，在服务器重启的时候能够保证不丢失相关的信息。
• exclusive 设置是否排他。为 true 则设置队列为排他的。若是一个队列被声明为排他队列，该队列对首次声明它的链接可见，并在链接断开时自动删除。这里须要注意三点：
  • 排他队列是基于链接（Connection）可见的，同一个链接的不一样信道（Channel）是能够同时访问同一个链接建立的排他队列。
  • "首次" 是指若是一个链接已经声明了一个排他队列，其余链接是不容许创建同名的排他队列，这个与普通队列不一样。
  • 即便该队列是持久化的，一旦链接关闭或者客户端退出，该队列都会被自动删除，这种队列适用于一个客户端同时发送和读取消息的应用场景。
• auto_delete 设置是否自动删除。为 true 则设置队列为自动删除。自动删除的前提是：至少有一个消费者链接到这个队列，以后全部与这个队列链接的消费者都断开时，才会自动删除。不能把这个参数错误的理解为："当链接到此队列的全部客户端断开时，这个队列自动删除"，由于生产者客户端建立这个队列，或者没有消费者客户端与这个队列链接时，都不会自动删除这个队列。
• arguments 设置队列的其余一些参数，如 x-message-ttl、x-expires、x-max-length。

queue_bind 方法详解

def queue_bind(self, queue, exchange, routing_key=None, arguments=None):

• queue 队列名称。
• exchange 交换器的名称。
• routing_key 用来绑定队列和交换器的路由键。
• arguments 定义绑定的一些参数。

basic_publish 方法详解

def basic_publish(self, exchange, routing_key, body, properties=None, mandatory=False, immediate=False):

• exchange 交换器的名称，指明消息须要发送到哪一个交换器。若是设置为空字符串，则消息会被发生到 RabbitMQ 默认的交换器中。
• routing_key 路由键，交换器根据路由键将消息存储到相应的队列之中。
• properties 消息的基本属性集，其包含 14 个属性成员，分别有 contentType、deliveryMode、proiotity等。
• body 消息体 payload，真正须要发送的消息。
• mandatory 当参数设置为 true 时，交换器没法根据自身的类型和路由键找到一个符合条件的队列，那么 RabbitMQ 会调用 Basic.Return 命令消息返回给生产者。当参数设置为 false 时，出现上述状况，则消息直接丢失。
• immediate 当参数设置为 true 时，若是交换器在将消息路由到队列时发现队列上并不存在任何消费者，那么这条消息将不会存入队列中。当与路由键匹配的全部队列都没有消费者时，该消息会经过 Basic.Return 返回至生产者。

basic_consume 方法详解

def basic_consume(self, consumer_callback, queue='', no_ack=False, exclusive=False, consumer_tag=None, arguments=None):

• consumer_callback 设置消费者的回调函数。用来处理 RabbitMQ 推送过来的消息，好比：DefaultConsumer，使用时须要客户端重写其中的方法。
• queue 队列的名称。
• no_ack 设置是否自动确认。建议设置成 false，即不自动确认。
• exclusive 设置是否排他。
• consumer_tag 消费者标签，用来区分多个消费者。
• arguments 设置消费者的其余参数。

exchange_type 模式

fanout 模式

• 任何发送到 fanout exchange 的消息都会被转发到与 exchange 绑定的全部的 queue 上。
• 不须要指定 routing_key, 即便指定了也是无效的。
• 须要提早将 exchange 与 queue 进行绑定， 一个 exchange 能够绑定到多个 queue, 一个 queue 也能够同多个 exchange 进行绑定。
• 接收到消息的 exchange 没有与任何 queue 绑定， 则消息就会被抛弃。

direct 模式

• 发送到 direct exchange 的消息都会被转发到 routing_key 中指定的 queue。
• 不须要将 exchange 进行任何绑定操做。固然也能够进行绑定操做，能够将不一样的 routing key 与不一样的 queue 进行绑定，不一样的 queue 与不一样 exchange 进行绑定。
• 消息须要传递一个 routing_key。
• 若是消息中不存在 routing_key 中绑定的队列名，则该消息就会被抛弃。
• 若是一个 exchange 声明为 direct，而且绑定中指定了 routing_key，那么发生消息时。须要同时指明该 exchange 和 routing_key。

topic 模式

• 这种模式比较复杂，简单来讲，就是每一个队列都有其关心的主题，全部的消息都带有一个 routing_key，exchange 会将消息转发到全部关注主题能与 routing_key 模糊匹配的队列。
• 须要 routing_key 要提早绑定 exchange 与 queue。
• 在进行绑定的时候，要提供一个该队列关心的主题，如："#.log.#" 表示该队列关心所涉及 log 的消息（一个 routing_key 为 "MQ.log.error" 的消息会被转发到该队列）。
• "#" 表示 0 个或若干个关键字，"" 表示一个关键字。如 "log." 能与 "log.warn.timeout" 匹配，可是 "log.#" 能与上述匹配。
• 若是 exchange 没有发现可以与 routing_key 匹配的 Queue，则会抛弃此消息。