RabbitMQ之Queue属性测试

dy223 6年前

本篇围绕 RabbitMQ 中最基本的 fabric – queue 进行讨论,主要介绍其常用的几个属性设置,以及在实际使用中的约束条件。

常用queue属性

rabbitmq-c代码中可以看到如下代码
RabbitMQ之Queue属性测试
上图所示为
queue声明时使用的结构体。其中最容易让使用者迷惑的3个属性是durableexclusiveauto_delete
RabbitMQ之Queue属性测试
上图所示为
consumerqueue进行消息消费时用于设置属性的结构体。其中最容易让使用者迷惑的属性是exclusive(上图中的exclusive注释有点问题,请忽略)

测试过程

在编写python语言的测试程序时,我将行为分为以下几步

  • 声明7个具有不同属性的queue,分别和名为test_exchage的exchange进行绑定(因为exchange为fanout类型,所以测试代码中的routing_key其实是不起作用的);
  • 向exchange发送具有persistent属性的消息(delivery_mode=2);
  • 创建7个消费者分别从上述7个queue中获取消息;

RabbitMQ之Queue属性测试

RabbitMQ之Queue属性测试

RabbitMQ之Queue属性测试

测试结果如下

RabbitMQ之Queue属性测试

可以看到,所有的7个消费者均收到了对应的消息内容。 

下面我们从RabbitMQ服务器测查看以下上述测试能展现什么信息。

1.client和server建立了一条AMQP connection

RabbitMQ之Queue属性测试

2.在该connection上使用了channel1进程AMQP协议通信。

RabbitMQ之Queue属性测试

3.连接建立时的用户名为guest,以及各种channel属性设置情况。

RabbitMQ之Queue属性测试

4.在当前channel上共存在7个消费者,分别从7个不同的queue上获取消息;该channel上的消息均来自名为test_exchageexchange(请原谅我测试过程中的英文拼写错误)。

RabbitMQ之Queue属性测试

Exchanges选项卡上可以看到test_exchage下绑定了哪些queue

RabbitMQ之Queue属性测试

Queues选项卡上可以看到全部7queue的属性情况

RabbitMQ之Queue属性测试

看到这里,眼尖的同学可能会发现问题所在了,那就是客户端代码中声明的queue属性并没有全部生效,为什么会这样呢?

首先分别看一下代码中声明的7queue在服务器侧的详细信息。

a.test_1_queue没有设置任何属性,在界面上没有看到任何属性。

RabbitMQ之Queue属性测试

RabbitMQ之Queue属性测试

b. test_2_queue设置了durable属性,在界面上看到了“durable:true”。

RabbitMQ之Queue属性测试

RabbitMQ之Queue属性测试

 

c. test_3_queue设置了auto-delete属性,在界面上看到了“auto-delete:true”。

RabbitMQ之Queue属性测试

RabbitMQ之Queue属性测试

d. test_4_queue同时设置了durableauto-delete属性,在界面上看到了“durable:trueauto-delete:true”。

RabbitMQ之Queue属性测试

RabbitMQ之Queue属性测试

e. test_5_queue同时设置了durableexclusive属性,但在界面上只看到了“Exlusive owner”的存在。

RabbitMQ之Queue属性测试

RabbitMQ之Queue属性测试

f. test_6_queue同时设置了auto_deleteexclusive属性,在界面上同时看到“auto-delete:true”和“Exlusive owner”的存在。

RabbitMQ之Queue属性测试

RabbitMQ之Queue属性测试

g. test_7_queue同时设置了durableauto_deleteexclusive属性,在界面上只看到了“auto-delete:true”和“Exlusive owner”的存在。

RabbitMQ之Queue属性测试

RabbitMQ之Queue属性测试

综上,可以得出如下结论

  • durable属性和auto-delete属性可以同时生效
  • durable属性和exclusive属性会有性质上的冲突,两者同时设置时,仅exclusive属性生效
  • auto_delete属性和exclusive属性可以同时生效

除此之外,还能得到其它一些有趣的结论:

  • Queue的“Exlusive owner”对应的是connection而不是channel
  • Consumer存在于某个channel上的

 附上一张客户端同时设置durableauto_deleteexclusive属性的抓包截图:

RabbitMQ之Queue属性测试

下面通过改变client侧代码,模拟不同情况下各种属性对queue的存在情况的影响。

a.在成功创建全部7queue后,通过Ctrl+C异常终止客户端程序。

RabbitMQ之Queue属性测试

(上图为全部创建时的状态)

 RabbitMQ之Queue属性测试

 停止后,queue的情况如下图所示。

RabbitMQ之Queue属性测试

对比发现,此时只有 test_1_queue test_2_queue 仍旧存在,其它queue已经被RabbitMQ服务器删除掉了(思考原因)。

b.客户端侧执行到消息发送后,结束当前操作(无consumer情况)。代码调整如下

RabbitMQ之Queue属性测试

此时仍旧可以看到queue的声明和绑定都是成功的。

RabbitMQ之Queue属性测试

此时客户端程序执行后会自动退出

RabbitMQ之Queue属性测试

再从web页面查看queue的情况如下

RabbitMQ之Queue属性测试

对比发现,此时仅test_1_queuetest_2_queuetest_3_queuetest_4_queue 存在(思考原因)。

      这里有个细节值得说一下:虽然最终我们在web页面上只看到了4queue的存在,但其实7queue都被成功创建过(抓包可以证明),如果你够幸运,你也可能在web页面上看到一闪而过的另外3queue。通过对比可以发现,导致另外3queue消失的原因是exclusive属性的设置,前面我已经说过,queue的“Exlusive owner”对应的是connection,所以在这个实验中可以确定的是,connection仍旧是存在的(这里遗留个问题:为什么python执行退出后连接仍旧存在),而此时实际上不存在的是consumer,所以需要对之前得到的结论进行加强:具有exclusive属性的queue的存在条件是在connection上存在某个consumer订阅了该queue同样可以得到另外一个结论:可以在没有创建consumer的情况下,创建出具有auto-delete属性的queue

RabbitMQ官方文档中其实已经对上述现象进行了说明,只不过一语带过,不注意的话容易忽略掉。在queue.declare方法中包含如下属性说明

RabbitMQ之Queue属性测试

此时肯定有人会问,除了queue.declare中具有exclusive属性,basic.consume中也具有exclusive属性,后者是什么含义呢?在文档说明中有如下内容

RabbitMQ之Queue属性测试

由此可以理解两个属性的差异和实际使用中应该注意的问题是什么!(自行思考)

在此情况下,若执行RabbitMQ server的重启(rabbitmqctl stop_app;rabbitmqctl start_app),可以看到仅有test_2_queuetest_4_queue仍旧存在。

RabbitMQ之Queue属性测试

测试版本

以上测试基于如下RabbitMQ版本

RabbitMQ之Queue属性测试

为什么使用这个版本?(我猜肯定有人会问)因为这个实验是我半年前就已经完成了的~~

来自:http://my.oschina.net/moooofly/blog/392239