【Message Queue - RabbitMQ】模型架構
閱讀時間約 2 分鐘
對於軟體世界中Message Queue有興趣的朋友可以先閱讀這一篇「【資訊軟體知識】井然有序的處理機制 - Message Queue」建立基礎知識之後，再來看看這一篇會更容易進入情境唷！
這次就進入我們一般常見的MQ軟體「RabbitMQ」, 我們先以圖示來了解RabbitMQ的模型架構, 之後的章節再來逐一介紹如何去使用, 以及如何規劃與設計Queue的策略, 過程中皆以實作讓大家可以動手做並加深印象。
● Publisher: 負責生產訊息。
● Message: 由header跟body組成, 交換機主要根據header的內容來將訊息送到正確的Queue。
● Connection: 用於傳遞消息的TCP連接，因此也可以採用SSL來提升傳輸安全性。
● Channel: 在同一條TCP connection中可以建立許多的channel，不同的執行緒可以藉由使用不同的channel做出訊息隔離，同時又可以共用同一條TCP connection。
● Exchange: 主要負責將Message送往正確的Queues。
● BindingKey: Exchange與Queue之間建立關係的key。
● Queue: 消息隊列，儲存訊息的地方。
● Virtual Host: 主要達到資源隔離的效果，也用來做權限管理，一個Virtual Host裡面可以有多的Exchanges、Queues，而權限控制的單位則是Virtual Host，可以理解為每個用戶擁有自己的獨立資源。
俯瞰上面的架構圖搭配每個元件的介紹後, 從左而右很簡單, 就想像一下真實情境「郵件配送」的場景, 送件者(Publisher)將郵件(Message)透過各種渠道(臨櫃/郵筒)將郵件送至郵局(Broker), 而郵局則負責排序、分類, 依照距離、優先程度進行配送, 郵差會根據處理過後的訊息配送至各地區的收件箱, 而收件者(Consumer)則根據自己的時間去收件箱領取自己的信件, 這就是整個MQ模型的運行實例, 其實並不難, 只是將送與收進行分流有效率的處理, 避免等待造成擁塞, 包括現代的物流都有著MQ的影子, 所以MQ在傳輸上引入了不同的流程, 讓彼此不必等待, 值得我們好好的學習一番。
下一個章節將會談談如何將RabbitMQ以Docker架設, 讓我們在虛擬環境底下不管失敗多少次都能夠試誤到成功。
喜歡撰寫文章的你，不妨來了解一下：
歡迎加入一起練習寫作，賺取知識！
為什麼會看到廣告
118會員
263內容數
哈囉，我是阿Han，是一位 👩💻 軟體研發工程師，喜歡閱讀、學習、撰寫文章及教學，擅長以圖代文，化繁為簡，除了幫助自己釐清思路之外，也希望藉由圖解的方式幫助大家共同學習，甚至手把手帶您設計出高品質的軟體產品。
留言0
查看全部
你可能也想看
Google News 追蹤
RabbitMQ 和 Kafka 是兩種流行的消息處理工具，各自擅長不同的應用場景。RabbitMQ 以低延遲和靈活的消息路由著稱，適合即時通信和微服務；Kafka 則專注於高吞吐量和數據持久化，適用於大規模數據流和實時分析。本文比較了它們的性能、擴展性和安全性，幫助你選擇最符合需求的解決方案。
Message Queue 和 Streaming Process 是分佈式系統中最重要的技術之一，但它們的應用場景和特性有明顯區別。消息隊列適合可靠的低延遲通信，而流處理專注於大規模數據流的實時分析。本文深入比較兩者特性，幫助你根據需求選擇合適的技術，打造更高效的系統架構！
本文介紹如何使用 Docker 安裝 RabbitMQ，並將其與 Node.js 結合，實現訊息的生產與消費。這個架構可以應用於分佈式系統或事件驅動架構中，幫助讀者理解如何整合 RabbitMQ 與 Node.js。
※ 什麼是路由？
當我們說「路由」時，可能是在談論路由器（實體設備），也可能是在談論路由（選擇路徑的過程），或者是在談論路徑（資料封包的傳輸路徑）。
路由器 (Router)：這是一種實體設備，負責將資料封包 (Packet) 從一個網路傳送到另一個網路。它的工作方式類似於交通指揮，確保資料封包
※ 生產者和消費者模式
定義：
生產者和消費者在同一時間內共同存取某一個資料空間。生產者負責生成數據並將其放入共享空間，消費者負責從共享空間中取走數據進行處理。兩者之間互不相干，也不須互相知道對方的存在。
共同存取資料空間：生產者和消費者共享同一個資料空間。這個空間通常是緩衝區或隊列，用於在它
最近在研究 Email Marketing，發現寄信服務有產業限制，建議在購買之前確認 TOC，並注意回覆訂閱者的問題。使用 Cloudflare 和 Gmail 來轉寄所有信件到自己的網域信箱。建議直接購買 Zoho 或 MxRoute 來省去架 Mail Server 的麻煩。
Kafka是一個先進的分佈式流處理平臺，具有高吞吐量、可擴展性、容錯性和低延遲特性，提供瞭解耦、非同步和削峰特點。本文介紹了Kafka的通訊模式、適合的應用場景和未來發展趨勢，旨在幫助使用者更好地理解和應用Kafka。
透過 node 的 http 模組來建立 web 伺服器範例
在Python中，queue是一個非常有用的模块。
它提供了多種佇列（queue）實現，用於在多線程環境中安全地交換信息或者數據。
佇列（queue）是一種先進先出（FIFO）的數據結構，允許在佇列的一端插入元素，另一端取出元素。(FIFO 是First In, First Out 的縮寫)
RabbitMQ 和 Kafka 是兩種流行的消息處理工具，各自擅長不同的應用場景。RabbitMQ 以低延遲和靈活的消息路由著稱，適合即時通信和微服務；Kafka 則專注於高吞吐量和數據持久化，適用於大規模數據流和實時分析。本文比較了它們的性能、擴展性和安全性，幫助你選擇最符合需求的解決方案。
Message Queue 和 Streaming Process 是分佈式系統中最重要的技術之一，但它們的應用場景和特性有明顯區別。消息隊列適合可靠的低延遲通信，而流處理專注於大規模數據流的實時分析。本文深入比較兩者特性，幫助你根據需求選擇合適的技術，打造更高效的系統架構！
本文介紹如何使用 Docker 安裝 RabbitMQ，並將其與 Node.js 結合，實現訊息的生產與消費。這個架構可以應用於分佈式系統或事件驅動架構中，幫助讀者理解如何整合 RabbitMQ 與 Node.js。
※ 什麼是路由？
當我們說「路由」時，可能是在談論路由器（實體設備），也可能是在談論路由（選擇路徑的過程），或者是在談論路徑（資料封包的傳輸路徑）。
路由器 (Router)：這是一種實體設備，負責將資料封包 (Packet) 從一個網路傳送到另一個網路。它的工作方式類似於交通指揮，確保資料封包
※ 生產者和消費者模式
定義：
生產者和消費者在同一時間內共同存取某一個資料空間。生產者負責生成數據並將其放入共享空間，消費者負責從共享空間中取走數據進行處理。兩者之間互不相干，也不須互相知道對方的存在。
共同存取資料空間：生產者和消費者共享同一個資料空間。這個空間通常是緩衝區或隊列，用於在它
最近在研究 Email Marketing，發現寄信服務有產業限制，建議在購買之前確認 TOC，並注意回覆訂閱者的問題。使用 Cloudflare 和 Gmail 來轉寄所有信件到自己的網域信箱。建議直接購買 Zoho 或 MxRoute 來省去架 Mail Server 的麻煩。
Kafka是一個先進的分佈式流處理平臺，具有高吞吐量、可擴展性、容錯性和低延遲特性，提供瞭解耦、非同步和削峰特點。本文介紹了Kafka的通訊模式、適合的應用場景和未來發展趨勢，旨在幫助使用者更好地理解和應用Kafka。
透過 node 的 http 模組來建立 web 伺服器範例
在Python中，queue是一個非常有用的模块。
它提供了多種佇列（queue）實現，用於在多線程環境中安全地交換信息或者數據。
佇列（queue）是一種先進先出（FIFO）的數據結構，允許在佇列的一端插入元素，另一端取出元素。(FIFO 是First In, First Out 的縮寫)