[DATA] 訊息佇列 03 - RabbitMQ 架設方法與網頁管理介面

前言

上一篇介紹完 RabbitMQ 的架構和設計模式，接下來就要告訴大家如何自己搭建 RabbitMQ Server，不用幾行指令就可以在你本機或是虛擬主機把服務架起來，還提供了一個 Web 管理介面方便你瀏覽和操作。

[ 系列文章目錄 ]

1. [DATA] 訊息佇列 01 - Message Queue 介紹與實際應用
2. [DATA] 訊息佇列 02 - RabbitMQ 簡介與 5 種設計模式
3. [DATA] 訊息佇列 03 - RabbitMQ 架設方法與網頁管理介面（本篇）
4. [DATA] 訊息佇列 04 - RabbitMQ x Python 程式實作範例

RabbitMQ 環境架設

RabbitMQ 官方有提供 RabbitMQ Server 在不同作業系統(Linux, MacOS & Windows)上的安裝指南，不過我還是推薦使用 Docker / Docker Compose 建立環境最為簡單、快速。

使用 Docker 指令

1
2
3

# create and start container
docker run --rm --name rabbitmq -p 5672:5672 -p 15672:15672 \
-e RABBITMQ_DEFAULT_USER=root -e RABBITMQ_DEFAULT_PASS=1234 rabbitmq:management 

使用 Docker Compose 指令

1
2

# create and start container
docker-compose -f docker-compose.yml up

docker-compose.yml 的參數定義與 Docker 指令完全一致。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

# docker-compose.yml
services:
    rabbitmq:
    image: rabbitmq:management
    container_name: rabbitmq
    ports:
        - 5672:5672
        - 15672:15672
    environment:
        - RABBITMQ_DEFAULT_USER=root
        - RABBITMQ_DEFAULT_PASS=1234

進入 RabbitMQ

將 RabbitMQ 啟動後，在瀏覽器 http://localhost:15672 進入 RabbitMQ 網頁管理介面，如果能成功進入「登入頁面」，代表 RabbitMQ 已經成功在本機(localhost)架設起來了！

RabbitMQ 網頁管理介面

rabbitmq:management 這個 Docker Image 有包含 Web 版管理介面，供開發/維運人員透過查看 Queues 的狀態，並可以直接在上面操作，推送(publish)訊息和取出(get)訊息。以下將分別介紹 RabbitMQ 網頁管理介面的主要頁籤功能：

Overview

輸入剛剛設定的 RABBITMQ_DEFAULT_USER 和 RABBITMQ_DEFAULT_PASS 登入後，就會進入「總覽頁面」，顯示 RabbitMQ Server 上的重要資訊和指標。

Connections

顯示目前 RabbitMQ Server 上所有 Clients 的連線狀態與網路資訊。

Channels

顯示目前 RabbitMQ Server 上所有 Channels 的訊息吞吐量。

Exchanges

查看並管理 Exchanges，預設已經建立了幾種不同 Type 的 Exchanges，可以直接使用或是自行手動新增。

Queues

查看並管理每一條 Queue 的訊息(messages)狀態與吞吐量。

新增 Queue

輸入自訂 Queue name（唯一值），並設定必要及可選的參數。

Durablity

• Durable 在 RabbitMQ 關閉/重啟後訊息還會留存；Transient 在 RabbitMQ 關閉/重啟後就不存在了。

Auto delete

• 若選 Yes，Queue 會在所有 Consumer 都中斷連接時自行刪除。

Aruguments

• Message TTL：Queue 裡的訊息在多少時間（毫秒）內若沒有被取用就會被丟棄
• Auto expire：Queue 在多少時間（毫秒）內若都沒有被使用就會自動刪除
• Single active connsumer：這條 Queue 是否只能有一個存活的 Consumer
• Max length：Queue 最多保存的訊息量，若超過會從頭端（FIFO）丟棄訊息
• Max length bytes：Queue 最多保存的訊息長度，若超過會從頭端（FIFO）丟棄訊息

Queue 的訊息可能會因為過期（MMessage TTL）或超過限制（Max length）被丟棄，透過以下兩個 Arguments 設定這些訊息要被重新推送至哪裡。

• Dead letteer exchange：被丟棄的訊息要被推送進入的 Exchange
• Dead letteer routing key：Dead letteer exchange 要綁定(binding) Queue 的 Routing key

管理 Queue

點選上面建立的 test-ueue 進入 Queue 內容頁面，在這裡可以：

• 查看 Messages 的詳細資訊和速率指標
• 設定 Queue 要綁定(binding)的 Exchange 和 Routing key
• 查看連接的 Consumer(s)
• 推送訊息、取出一至多則訊息
• 刪除(delete)整條 Queue
• 清空(purge)整條 Queue 裡的訊息

Publish / Get message

你可以在介面上試著推送(Publish)訊息，再取出(Get)訊息，你將依序地得到這些訊息。

測試的同時你可觀察訊息圖表的即時變化。（網頁預設 Refresh every 5 seconds）

Admin

最初使用的 DEFAULT 帳密是最高權限使用者，若想把帳號分給其他人，可在這個頁面管理 Users 或新增 User。

參考

https://www.rabbitmq.com/queues.html

https://kucw.github.io/blog/2020/11/rabbitmq/

https://godleon.github.io/blog/ChatOps/message-queue-concepts/