插個廣告，公司最近在招“.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 中消費資訊。

不理解？沒關係，看下面。

接下來，我們就用 rabbitmqadmin ，來演示上面 RabbitMQ 投遞過程。

如果我們安裝了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 命令彙總：

參考資料：