RabbitMQ 的CLI管理工具 rabbitmqadmin(18)

2021-11-26 09:40:16 浏览数 (2)

这次我们使用 routing_key=first 来投递消息

代码语言:javascript复制
[root@h102 rabbitmq]# rabbitmqadmin list queues
 ------------- ---------- 
|    name     | messages |
 ------------- ---------- 
| test        | 2        |
| test.fanout | 1        |
 ------------- ---------- 
[root@h102 rabbitmq]# rabbitmqadmin purge queue name=test
queue purged
[root@h102 rabbitmq]# rabbitmqadmin purge queue name=test.fanout
queue purged
[root@h102 rabbitmq]# rabbitmqadmin list queues
 ------------- ---------- 
|    name     | messages |
 ------------- ---------- 
| test        | 0        |
| test.fanout | 0        |
 ------------- ---------- 
[root@h102 rabbitmq]# rabbitmqadmin publish routing_key=first exchange=my.fanout payload="just for test4"
Message published
[root@h102 rabbitmq]# rabbitmqadmin list queues
 ------------- ---------- 
|    name     | messages |
 ------------- ---------- 
| test        | 1        |
| test.fanout | 1        |
 ------------- ---------- 
[root@h102 rabbitmq]# rabbitmqadmin get queue=test requeue=true
 ------------- ----------- --------------- ---------------- --------------- ------------------ ------------ ------------- 
| routing_key | exchange  | message_count |    payload     | payload_bytes | payload_encoding | properties | redelivered |
 ------------- ----------- --------------- ---------------- --------------- ------------------ ------------ ------------- 
| first       | my.fanout | 0             | just for test4 | 14            | string           |            | False       |
 ------------- ----------- --------------- ---------------- --------------- ------------------ ------------ ------------- 
[root@h102 rabbitmq]# rabbitmqadmin get queue=test.fanout requeue=true
 ------------- ----------- --------------- ---------------- --------------- ------------------ ------------ ------------- 
| routing_key | exchange  | message_count |    payload     | payload_bytes | payload_encoding | properties | redelivered |
 ------------- ----------- --------------- ---------------- --------------- ------------------ ------------ ------------- 
| first       | my.fanout | 0             | just for test4 | 14            | string           |            | False       |
 ------------- ----------- --------------- ---------------- --------------- ------------------ ------------ ------------- 
[root@h102 rabbitmq]# 

发现结果一样,应证了前面说的 routing_key 会被忽略的说法,但是不能不指定,否则会报错

代码语言:javascript复制
[root@h102 rabbitmq]# rabbitmqadmin publish exchange=my.fanout payload="just for test5"

ERROR: mandatory argument "routing_key" required

rabbitmqadmin --help for help

[root@h102 rabbitmq]#

direct 的特性

定义第三个queue ,使用 my.direct binding 起来

代码语言:javascript复制
[root@h102 rabbitmq]# rabbitmqadmin list queues
 ------------- ---------- 
|    name     | messages |
 ------------- ---------- 
| test        | 0        |
| test.fanout | 0        |
 ------------- ---------- 
[root@h102 rabbitmq]# rabbitmqadmin declare queue name=test.direct durable=true
queue declared
[root@h102 rabbitmq]# rabbitmqadmin list queues
 ------------- ---------- 
|    name     | messages |
 ------------- ---------- 
| test        | 0        |
| test.direct | 0        |
| test.fanout | 0        |
 ------------- ---------- 
[root@h102 rabbitmq]# rabbitmqadmin declare binding source=my.direct destination=test routing_key=third
binding declared
[root@h102 rabbitmq]# rabbitmqadmin declare binding source=my.direct destination=test.direct routing_key=fourth
binding declared
[root@h102 rabbitmq]# rabbitmqadmin list bindings
 ----------- ------------- ------------- 
|  source   | destination | routing_key |
 ----------- ------------- ------------- 
|           | test        | test        |
|           | test.direct | test.direct |
|           | test.fanout | test.fanout |
| my.direct | test        | third       |
| my.direct | test.direct | fourth      |
| my.fanout | test        | first       |
| my.fanout | test.fanout | second      |
 ----------- ------------- ------------- 
[root@h102 rabbitmq]# 

0 人点赞