【RabbitMQ系列】队列、绑定、交换器
2018-02-12 15:53
302 查看
队列:
从概念上来讲,AMQP消息路由必须有三部分:交换器、队列和绑定。生产者把消息发布到交换器上;消息最终到达队列,并被消费者接收;绑定决定了消息如何从路由器路由到特定的队列。消费者通过以下两种方式从特定的队列中接收消息:
1)通过AMQP的basic.consume命令订阅。这样做会将信道置为接收模式,知道取消对队列的订阅为止。订阅了消息后,消费者在消费(或者拒绝)最近接收的那道消息后,就能从队列中(可用的)自动接收下一条消息。如果消费者处理队列消息,并且/或者需要在消息已到达队列时就自动接收的话,你应该使用basic.consume.
2)如果只是想获得单条消息而不是持久订阅,向队列请求单消息是通过AMQP的basic.get命令来实现的,这样做可以让消费者接收队列中的下一条消息,如果要获得更多的的消息的话,需要再次发送basic.get命名。不应该使用basic.get放在一个循环里来替代basic.consume,因为这样会影响Rabbit的性能,大致上讲,basic.get命令会订阅消息,活儿单条消息,然后取消订阅。消费者理应始终使用basic.consume来实现高吞吐量。
如果至少有一个消费者订阅了队列的话,消息会立即发送给这些订阅的消费者。但是如果消息到达了无人订阅的队列呢?这种情况下,消息会在队列中等候。一旦有消费者订阅到该队列,那么队列上的消息就会发送给消费者。
当多个消费者订阅到同一队列上时,消息是如何发布的?
当Rabbit队列拥有多个消费者时,队列收到的消息将以循环的方式发送给消费者。每条通道只会发送给一个订阅的消费者。假设有seed_bin队列,消费者1和消费者2订阅到该队列,当消息到达seed_bin队列时,消息投递方式如下:
1)消息A到达seed_bin队列
2)RbbitMQ把消息A发送给消费者1
3)消费者1确认收到了消息A
4)RbbitMq把消息A从seed_bin中删除
5)消息B到达seed_bin队列
6)RbbitMQ把消息B发送给消费者2
7)消费者2确认收到了消息B
8)RabbitMQ把消息B从seed_bin中删除
联合起来:交换器和绑定
消息是如何到达队列的呢?当你想将消息投递到队列时,你通过把消息发送给交换器来完成。然后,根据确定的规则,RabbitMQ将会决定消息该投递到哪个队列,这些规则发送到代理服务器时,消息将拥有一个路由器--即便是空的--RabbitMQ也会将其和绑定使用的路由键进行匹配。如果相匹配的话,那么消息将会投递到该队列。如果路由的消息不匹配任何绑定模式的话,消息将进入“黑洞”。
服务器会根据路由键将消息从交换器路由到队列,但它是如何处理投递到多个队列的情况呢?
协议中定义的不同类型的交换器发挥了作用。一共有四种类型:direct fanout topic headers
headers交换器允许你匹配AMQP消息的header而非路由键。性能比direct差。
direct交换器:
服务器必须实现direct类型交换器,包含一个空白字符串名称的默认交换器。当声明一个队列时,它会自动绑定到默认交换器,并以队列名称作为路由键。这意味着你可以使用如下代码发送消息到之前声明的队列中去。
fanout交换器:
当你发送一条消息到fanout交换器时,它会把消息投递到所有附加在此交换器上的额队列,这允许你对单条消息做不同的反应。
topic交换器:
这类交换器允许你实现有趣的消息通信场景,它使得来自不同源头的消息能够到达同一个队列,让我们用Web应用程序日志系统作为示例。
相关文章推荐
- 【RabbitMQ】生产者,消费者,信道,队列,交换器和绑定
- 【RabbitMQ】生产者,消费者,信道,队列,交换器和绑定
- RabbitMQ的交换器、绑定以及队列
- 在Node.js中使用RabbitMQ系列二 任务队列
- RabbitMQ消息队列系列教程(一)认识RabbitMQ
- RabbitMQ系列教程之二:工作队列(Work Queues)(转载)
- RabbitMQ系列教程之二:工作队列(Work Queues)
- rabbitmq消息队列——"topic型交换器"
- RabbitMQ系列教程之二:工作队列(Work Queues)
- 消息队列系列(四):Rabbitmq常用命令行
- 消息队列基础 RabbitMQ与AMQP协议详解——超大规模高可用OpenStack核心技术深入解析系列(二)
- RabbitMQ学习系列二:.net 环境下 C#代码使用 RabbitMQ 消息队列
- 在Node.js中使用RabbitMQ系列二 任务队列
- RabbitMQ系列三 (深入消息队列)
- 集群与负载均衡系列(4)——消息队列之Rabbitmq的搭建
- 消息队列基础 RabbitMQ与AMQP协议详解——超大规模高可用OpenStack核心技术深入解析系列(二)
- 消息队列系列(四):Rabbitmq常用命令行
- 消息队列系列(二):.Rabbitmq的使用及Web监控工具使用
- 自动化运维Python系列之消息队列RabbitMQ
- RabbitMQ系列二(构建消息队列)