插個廣告，公司最近在招“.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 概念：
| 概念 | 詳解 |
|---|---|
| Exchange | 消息交換機，它指定消息按什么規則，路由到哪個隊列 |
| Queue | 消息隊列，每個消息都會被投入到一個或多個隊列 |
| Binding | 綁定，它的作用就是把 exchange 和 queue 按照路由規則綁定起來 |
| Routing Key | 路由關鍵字，exchange 根據這個關鍵字進行消息投遞 |
| Vhost | 虛擬主機，可以開設多個 vhost，用作不同用戶的權限分離 |
| Producer | 消息生產者，就是投遞消息的程序 |
| Consumer | 消息消費者，就是接受消息的程序 |
| Channel | 消息通道，在客戶端的每個連接里，可建立多個 channel，每個 channel 代表一個會話任務 |
RabbitMQ 流程：
RabbitMQ 投遞過程：
- 1. 客戶端連接到消息隊列服務器，打開一個 channel。
- 2. 客戶端聲明一個 exchange，並設置相關屬性。
- 3. 客戶端聲明一個 queue，並設置相關屬性。
- 4. 客戶端使用 routing key，在 exchange 和 queue 之間建立好綁定關系。
- 5. 客戶端投遞消息到 exchange。
- 6. 客戶端從指定的 queue 中消費信息。
不理解？沒關系，看下面。
接下來，我們就用 rabbitmqadmin ，來演示上面 RabbitMQ 投遞過程。
如果我們安裝了rabbitmq_management插件，可以打開http://node1:15672/cli/頁面，下載 rabbitmqadmin。
或者直接進行下載：
[root@node1 ~]# wget http://node1:15672/cli/rabbitmqadmin
然后移到PATH目錄，並賦予權限：
[root@node1 ～]# mv rabbitmqadmin /usr/local/bin
[root@node1 ～]# sudo chmod 777 /usr/local/bin/rabbitmqadmin
查看 rabbitmqadmin 命令：
[root@node1 ~]# rabbitmqadmin -help
Usage
=====
rabbitmqadmin [options] subcommand
...
創建一個test隊列：
[root@node1 ~]# rabbitmqadmin declare queue name=test durable=true
queue declared
[root@node1 ~]# rabbitmqadmin list queues
+------+----------+
| name | messages |
+------+----------+
| test | 0 |
+------+----------+
需要注意：durable=true表示持久化，如果沒有創建 Exchange，RabbitMQ 會使用默認的 Exchange，以及創建一個 Binding，這也就是為什么下面發布消息，可以成功的原因。
發布一條消息：
[root@node1 ~]# rabbitmqadmin publish routing_key=test payload="hello world"
Message published
[root@node1 ~]# rabbitmqadmin list queues
+------+----------+
| name | messages |
+------+----------+
| test | 1 |
+------+----------+
消費一條消息（查看消息內容）：
[root@node1 ~]# 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 |
+-------------+----------+---------------+-------------+---------------+------------------+------------+-------------+
[root@node1 ~]# rabbitmqadmin list queues
+------+----------+
| name | messages |
+------+----------+
| test | 1 |
+------+----------+
[root@node1 ~]# 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 |
+-------------+----------+---------------+-------------+---------------+------------------+------------+-------------+
[root@node1 ~]# rabbitmqadmin list queues
+------+----------+
| name | messages |
+------+----------+
| test | 0 |
+------+----------+
需要注意：requeue=true表示查看隊列，不消費；requeue=false表示查看隊列，進行消費。
我們查看下上面創建隊列后，默認創建的 Binding：
[root@node1 ~]# 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：
[root@node1 ~]# rabbitmqadmin declare exchange name=my.topic type=topic
exchange declared
[root@node1 ~]# 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：
[root@node1 ~]# rabbitmqadmin declare binding source=my.topic destination=test routing_key=my.#
binding declared
[root@node1 ~]# rabbitmqadmin list bindings
+----------+-------------+-------------+
| source | destination | routing_key |
+----------+-------------+-------------+
| | test | test |
| my.topic | test | my.# |
+----------+-------------+-------------+
需要注意：我們上面創建的 Binding（最后那個），就是將名稱為my.topic的 Exchange 和名稱為test的 Queue 關聯起來，並且設置的routing_key規則為my.#。
下面我們發布兩條消息：
[root@node1 ~]# rabbitmqadmin publish routing_key=my.test exchange=my.topic payload="hello world by my.test"
Message published
[root@node1 ~]# rabbitmqadmin publish routing_key=my.test.test exchange=my.topic payload="hello world by my.test.test"
Message published
[root@node1 ~]# rabbitmqadmin list queues
+------+----------+
| name | messages |
+------+----------+
| test | 2 |
+------+----------+
需要注意，發布的兩條消息都指定了my.topic的 Exchange，但消息的routing_key不同，但都成功發布到test隊列了，原因是my.test和my.test.test都符合my.#路由規則。
下面，我們對兩條消息進行消費：
[root@node1 ~]# 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 |
+-------------+----------+---------------+------------------------+---------------+------------------+------------+-------------+
[root@node1 ~]# 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 |
+--------------+----------+---------------+-----------------------------+---------------+------------------+------------+-------------+
[root@node1 ~]# 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 命令匯總：
| 命令 | 解釋 |
|---|---|
| rabbitmqadmin list users | 查看所有用戶 User |
| rabbitmqadmin list users name | 查看所有用戶名 Username |
| rabbitmqadmin list users tags | 查看所有用戶角色 |
| rabbitmqadmin list vhosts | 查看所有虛擬主機 |
| rabbitmqadmin list connections | 查看所有連接 |
| rabbitmqadmin list exchanges | 查看所有路由 Exchange |
| rabbitmqadmin list bindings | 查看所有路由與隊列的關系綁定 Binding |
| rabbitmqadmin list permissions | 查看所有角色的權限 Permission |
| rabbitmqadmin list channels | 查看所有通道 Channel |
| rabbitmqadmin list consumers | 查看所有消費者 Consumer |
| rabbitmqadmin list queues | 查看所有消息隊列 Queue |
| rabbitmqadmin list nodes | 查看所有節點 Node |
| rabbitmqadmin show overview | 概覽 Overview |
| rabbitmqadmin list bindings source destination_type destination properties_key | 查看所有路由與隊列的關系綁定的詳細信息 Binding |
| rabbitmqadmin declare queue name=test durable=true | 定義一個隊列queue，durable=true代表持久化打開。 |
| rabbitmqadmin declare exchange name=my.fanout type=fanout | 定義一個Fanout路由 |
| rabbitmqadmin declare exchange name=my.direct type=direct | 定義一個Direct路由 |
| rabbitmqadmin declare exchange name=my.topic type=topic | 定義一個Topic路由 |
| rabbitmqadmin declare binding source=my.fanout destination=test routing_key=first | 定義 binding |
| rabbitmqadmin publish routing_key=test payload="hello world" | 發布一條消息 |
| rabbitmqadmin publish routing_key=my.test exchange=my.topic payload="hello world" | 使用路由轉發消息 |
| rabbitmqadmin get queue=test requeue=true | 查看消息，不消費 |
| rabbitmqadmin get queue=test requeue=false | 查看消息，並消費 |
| rabbitmqadmin purge queue name=test | 刪除隊列中的所有消息 |
| rabbitmqadmin delete queue name=hello | 刪除消息隊列 Queue |
| rabbitmqadmin delete user name=test | 刪除用戶 User |
| rabbitmqadmin delete exchange name=test | 刪除路由器 Exchange |
| rabbitmqadmin delete binding source='kk' destination_type=queue destination=test properties_key=test | 刪除路由器與消息隊列的關系綁定 Binding |
| rabbitmqadmin -f raw_json list users | raw_json 格式化輸出 |
| rabbitmqadmin -f long list users | 格式化輸出 |
| rabbitmqadmin -f pretty_json list users | pretty_json 格式化輸出 |
| rabbitmqadmin -f kvp list users | 格式化輸出 |
| rabbitmqadmin -f tsv list users | 格式化輸出 |
| rabbitmqadmin -f table list users | table 格式化輸出 |
| rabbitmqadmin -f bash list users | bash 格式化輸出 |
參考資料：