码迷,mamicode.com
首页 > 其他好文 > 详细

【RabbitMQ系列】队列、绑定、交换器

时间:2018-02-12 18:38:05      阅读:219      评论:0      收藏:0      [点我收藏+]

标签:绑定   名称   部分   direct   附加   rabbit   应用程序   进入   ons   

队列:

从概念上来讲,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系列】队列、绑定、交换器

标签:绑定   名称   部分   direct   附加   rabbit   应用程序   进入   ons   

原文地址:https://www.cnblogs.com/dream-to-pku/p/8444754.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!