RabbitMQ CLI 管理工具 rabbitmqadmin（管理和监控）

插个广告，公司最近在招“.NET”开发（杭州），如果你现在还从事 .NET 开发（想用 .NET Core，但被公司不认可），想转 JAVA 开发（但又没有工作经验，惧怕面试），想用微服务架构重构（面对现有庞大的单体应用程序，有心无力），那么请关注右侧的公众号私信我，或许我可以帮到你一些～～～

一般情况下，我们会使用 rabbitmq_management 插件，通过 Web UI 的方式来监控和操作 RabbitMQ（端口 15672），但有时候命令的方式会更加方便一些，RabbitMQ 提供了 CLI 管理工具 rabbitmqadmin ，其实就是基于 RabbitMQ 的 HTTP API，用 Python 写的一个脚本。

另外，除了 rabbitmqadmin ，有个人也写了一个 rabbitmq-dump-queue 脚本，用于抓取 Queue 队列，用文件进行存储，但使用下来，感觉还是官方的 rabbitmqadmin 比较好些。

rabbitmqadmin 提供了下面功能：

• 列出 exchanges, queues, bindings, vhosts, users, permissions, connections and channels。
• 创建和删除 exchanges, queues, bindings, vhosts, users and permissions。
• 发布和获取消息，以及消息详情。
• 关闭连接和清空队列。
• 导入导出配置。

使用 rabbitmqadmin 的时候，我们需要理解 RabbitMQ 的基本概念，先回顾一下：

RabbitMQ 概念：

RabbitMQ 流程：

RabbitMQ 投递过程：

• 1. 客户端连接到消息队列服务器，打开一个 channel。
• 2. 客户端声明一个 exchange，并设置相关属性。
• 3. 客户端声明一个 queue，并设置相关属性。
• 4. 客户端使用 routing key，在 exchange 和 queue 之间建立好绑定关系。
• 5. 客户端投递消息到 exchange。
• 6. 客户端从指定的 queue 中消费信息。

不理解？没关系，看下面。

如果我们安装了rabbitmq_management插件，可以打开http://node1:15672/cli/页面，下载 rabbitmqadmin。

或者直接进行下载：

[[email protected] ~]# wget http://node1:15672/cli/rabbitmqadmin

然后移到PATH目录，并赋予权限：

[[email protected] ～]# mv rabbitmqadmin /usr/local/bin
[[email protected] ～]# sudo chmod 777 /usr/local/bin/rabbitmqadmin

查看 rabbitmqadmin 命令：

[[email protected] ~]# rabbitmqadmin -help
Usage
=====
  rabbitmqadmin [options] subcommand
...

创建一个test队列：

[[email protected] ~]# rabbitmqadmin declare queue name=test durable=true
queue declared
[[email protected] ~]# rabbitmqadmin list queues
+------+----------+
| name | messages |
+------+----------+
| test | 0        |
+------+----------+

需要注意：durable=true表示持久化，如果没有创建 Exchange，RabbitMQ 会使用默认的 Exchange，以及创建一个 Binding，这也就是为什么下面发布消息，可以成功的原因。

发布一条消息：

[[email protected] ~]# rabbitmqadmin publish routing_key=test payload="hello world"
Message published
[[email protected] ~]# rabbitmqadmin list queues
+------+----------+
| name | messages |
+------+----------+
| test | 1        |
+------+----------+

消费一条消息（查看消息内容）：

[[email protected] ~]# rabbitmqadmin get queue=test requeue=true
+-------------+----------+---------------+-------------+---------------+------------------+------------+-------------+
| routing_key | exchange | message_count |   payload   | payload_bytes | payload_encoding | properties | redelivered |
+-------------+----------+---------------+-------------+---------------+------------------+------------+-------------+
| test        |          | 0             | hello world | 11            | string           |            | False       |
+-------------+----------+---------------+-------------+---------------+------------------+------------+-------------+
[[email protected] ~]# rabbitmqadmin list queues
+------+----------+
| name | messages |
+------+----------+
| test | 1        |
+------+----------+
[[email protected] ~]# rabbitmqadmin get queue=test requeue=false
+-------------+----------+---------------+-------------+---------------+------------------+------------+-------------+
| routing_key | exchange | message_count |   payload   | payload_bytes | payload_encoding | properties | redelivered |
+-------------+----------+---------------+-------------+---------------+------------------+------------+-------------+
| test        |          | 0             | hello world | 11            | string           |            | True        |
+-------------+----------+---------------+-------------+---------------+------------------+------------+-------------+
[[email protected] ~]# rabbitmqadmin list queues
+------+----------+
| name | messages |
+------+----------+
| test | 0        |
+------+----------+

需要注意：requeue=true表示查看队列，不消费；requeue=false表示查看队列，进行消费。

我们查看下上面创建队列后，默认创建的 Binding：

[[email protected] ~]# rabbitmqadmin list bindings
+--------+-------------+-------------+
| source | destination | routing_key |
+--------+-------------+-------------+
|        | test        | test        |
+--------+-------------+-------------+

可以看到，使用的默认 Exchange 是空字符串（系统中的第一个 Exchange，Binding 中的 source 部分），并且这个默认的 Exchange 是direct类型（也就是一对一模式），这种隐式调用确保了消息准确投递。

另外，再说一下 Binding 中的三个概念：

• Source：源头的意思，其实就是 Exchange。
• destination：目的地的意思，其实就是 Queue。
• routing_key：路由键的规则，用于 Queue 匹配（比如test.#）。

那下面我们就手动创建一下 Exchange：

[[email protected] ~]# rabbitmqadmin declare exchange name=my.topic type=topic
exchange declared
[[email protected] ~]# rabbitmqadmin list exchanges
+--------------------+---------+
|        name        |  type   |
+--------------------+---------+
|                    | direct  |
| amq.direct         | direct  |
| amq.fanout         | fanout  |
| amq.headers        | headers |
| amq.match          | headers |
| amq.rabbitmq.log   | topic   |
| amq.rabbitmq.trace | topic   |
| amq.topic          | topic   |
| my.topic           | topic   |
+--------------------+---------+

需要注意：这边我们只创建了一个 Exchange，类型为 Topic，和之前创建的test队列，目前没有任何关系。

然后再创建一个 Binding：

[[email protected] ~]# rabbitmqadmin declare binding source=my.topic destination=test routing_key=my.#
binding declared
[[email protected] ~]# rabbitmqadmin list bindings
+----------+-------------+-------------+
|  source  | destination | routing_key |
+----------+-------------+-------------+
|          | test        | test        |
| my.topic | test        | my.#        |
+----------+-------------+-------------+

需要注意：我们上面创建的 Binding（最后那个），就是将名称为my.topic的 Exchange 和名称为test的 Queue 关联起来，并且设置的routing_key规则为my.#。

下面我们发布两条消息：

[[email protected] ~]# rabbitmqadmin publish routing_key=my.test exchange=my.topic  payload="hello world by my.test"
Message published
[[email protected] ~]# rabbitmqadmin publish routing_key=my.test.test exchange=my.topic  payload="hello world by my.test.test"
Message published
[[email protected] ~]# rabbitmqadmin list queues
+------+----------+
| name | messages |
+------+----------+
| test | 2        |
+------+----------+

需要注意，发布的两条消息都指定了my.topic的 Exchange，但消息的routing_key不同，但都成功发布到test队列了，原因是my.test和my.test.test都符合my.#路由规则。

下面，我们对两条消息进行消费：

[[email protected] ~]# rabbitmqadmin get queue=test requeue=false
+-------------+----------+---------------+------------------------+---------------+------------------+------------+-------------+
| routing_key | exchange | message_count |        payload         | payload_bytes | payload_encoding | properties | redelivered |
+-------------+----------+---------------+------------------------+---------------+------------------+------------+-------------+
| my.test     | my.topic | 1             | hello world by my.test | 22            | string           |            | False       |
+-------------+----------+---------------+------------------------+---------------+------------------+------------+-------------+
[[email protected] ~]# rabbitmqadmin get queue=test requeue=false
+--------------+----------+---------------+-----------------------------+---------------+------------------+------------+-------------+
| routing_key  | exchange | message_count |           payload           | payload_bytes | payload_encoding | properties | redelivered |
+--------------+----------+---------------+-----------------------------+---------------+------------------+------------+-------------+
| my.test.test | my.topic | 0             | hello world by my.test.test | 27            | string           |            | False       |
+--------------+----------+---------------+-----------------------------+---------------+------------------+------------+-------------+
[[email protected] ~]# rabbitmqadmin list queues
+------+----------+
| name | messages |
+------+----------+
| test | 0        |
+------+----------+

rabbitmqadmin 测试到这边，你应该就体会到了 RabbitMQ 的投递过程了吧，我们再对之前的投递过程完善下：

• 1. 声明一个 Queue，和谁都没有关系（只有名称和持久化配置）。
• 2. 声明一个 Exchange，和谁都没有关系（只有名称和 Exchange Type 配置）。
• 3. 声明一个 Binding，通过 source 和 destination，将 Queue 和 Exchange 关联起来，并通过 routing_key，设置发布消息的路由规则。
• 4. 发布一个消息，需要指定一个 Exchange，以及本身的路由名称。
• 5. 消费队列中的消息，需要指定一个 Queue。

rabbitmqadmin 命令汇总：

参考资料：

• Management Command Line Tool（官网）
• RabbitMQ 的CLI管理工具 rabbitmqadmin（推荐）
• 05_RabbitMQ 的CLI管理工具 rabbitmqadmin

原文地址：https://www.cnblogs.com/xishuai/p/rabbitmq-cli-rabbitmqadmin.html