RabbitMQ 核心概念全面解析：從入門到進階

RabbitMQ 基礎架構與核心概念詳解

什麼是 RabbitMQ？

RabbitMQ 是 AMQP（Advanced Message Queuing Protocol）的開源實作，使用 Erlang 編寫，支援多種語言客戶端。作為訊息中介軟體，它實現元件解耦：生產者無需知曉消費者存在，反之亦然。核心特性包含訊息導向、佇列、路由（點對點與發布/訂閱）、可靠性與安全性。

核心元件

ConnectionFactory、Connection、Channel

• Connection：RabbitMQ 的 Socket 連線，封裝協議細節
• ConnectionFactory：Connection 的工廠
• Channel：業務操作的主要介面，定義 Queue、Exchange、綁定關係、發布訊息等均在此完成

Queue（佇列）

訊息儲存的內部物件。生產者（P）投遞訊息到 Queue，消費者（C）從中取出處理。多個消費者訂閱同一 Queue 時，訊息會平均分攤（輪詢分發），而非廣播。

Message Acknowledgment（訊息確認）

防止消費者處理訊息途中宕機導致訊息遺失。消費者處理完畢需發送 ACK，RabbitMQ 收到 ACK 才移除訊息。若連線斷開未收到 ACK，訊息會重新分發給其他消費者。注意：無 timeout 機制，僅靠連線斷開觸發重發。開發者忘記發送 ACK 會導致佇列堆積與重複消費。

Message Durability（訊息持久化）

將 Queue 與 Message 設為 durable，可在 RabbitMQ 重啟後保留訊息。但極端情況（如收到訊息尚未持久化即斷電）仍可能遺失，需配合事務機制解決。

Prefetch Count（預取計數）

限制每次分發給消費者的訊息數。設 prefetchCount=1 可實現公平分發，避免處理時間不均導致部分消費者閒置。

Exchange（交換器）與路由機制

生產者不直接發送訊息到 Queue，而是發送到 Exchange，由 Exchange 根據路由規則轉發到一或多個 Queue（或丟棄）。

Routing Key

生產者發送訊息時指定的路由鍵，配合 Exchange Type 與 Binding Key 決定訊息流向。長度限制 255 bytes。

Binding（綁定）

將 Exchange 與 Queue 關聯，指定 Binding Key。當 Binding Key 與 Routing Key 匹配時，訊息路由到對應 Queue。

四種 Exchange Type

RPC（遠端程序呼叫）模式

RabbitMQ 本質是非同步，但可透過 replyTo（回應佇列）與 correlationId（請求識別碼）實現同步 RPC：客戶端發送請求並監聽回應佇列，服務端處理後將結果發送至 replyTo 指定佇列並帶上 correlationId，客戶端據此匹配請求與回應。

總結

掌握 Queue、Exchange、Binding、Routing Key 等核心概念，並善用持久化、確認機制、Prefetch Count 等進階特性，即可應對絕大多數非同步業務場景。