如何部署使用消息隊列RabbitMQ

這期內容當中小編將會給大家帶來有關如何部署使用消息隊列RabbitMQ，文章內容豐富且以專業的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

什么是消息隊列

消息隊列拆開了看，就是消息 + 隊列，消息是什么？其實就是程序之間通訊所用到的數據，消息從生產者那里產生，進入隊列后，安裝設計好的規則出隊，由消費者消費。僅此而已。

為什么需要消息隊列

消息隊列，最重要的是隊列，可以想象一下沒有隊列的場景，你去銀行辦業務的時候，大家都不排隊的場景，大家都堆在一起，個子小沒力氣的根本辦不了業務。

如果沒有消息隊列，你的系統將嚴重耦合，在升級維護的時候牽一發而動全身。

如果沒有消息隊列，你的系統的很多功能都是同步的，同步意味著前面的事件完成后，才可以進行后續的操作，前端用戶的會覺得卡頓，體驗很差。

如果沒有消息隊列，web 系統突然面對高并發的訪問請求，可能會崩潰。

有了消息隊列，系統解耦、異步通信、流量削峰、延遲通知、最終一致性保證、順序消息、流式處理等需求都可以輕松解決。

常見的消息隊列

比較常見的消息隊列產品主要有 ActiveMQ、RabbitMQ、ZeroMQ、Kafka、RocketMQ 等。

ActiveMQ

Apache ActiveMQ 是 Apache 軟件基金會所研發的開放源碼消息中間件；由于 ActiveMQ 是一個純Java程序，因此只需要操作系統支持 Java 虛擬機，ActiveMQ 便可執行。

• 支持Java消息服務 (JMS) 1.1 版本

• Spring Framework

• 集群 (Clustering)

• 協議支持包括：OpenWire、REST、STOMP、WS-Notification、MQTT、XMPP 以及 AMQP

RabbitMQ

RabbitMQ 實現了高級消息隊列協議（AMQP）的開源消息代理軟件（亦稱面向消息的中間件）。RabbitMQ 服務器是用高性能、健壯以及可伸縮性出名的 Erlang 語言編寫的，支持所有主流的操作系統如 Linux，Windows，MacOS。客戶端支持所有主要的編程語言。

• 可伸縮性：集群服務

• 消息持久化：從內存持久化消息到硬盤，再從硬盤加載到內存

ZeroMQ

ZeroMQ（也拼寫作 0MQ 或 ZMQ )是一個為可伸縮的分布式或并發應用程序設計的高性能異步消息庫。它提供一個消息隊列, 但是與面向消息的中間件不同，ZeroMQ 的運行不需要專門的消息代理（message broker）。該庫設計成常見的套接字風格的API。

ZeroMQ 是由 iMatix 公司和大量貢獻者組成的社群共同開發的。ZeroQ 通過許多第三方軟件支持大部分流行的編程語言，從 Java 和Python 到 Erlang 和 Haskell。

Kafka

Kafka 是由 Apache 軟件基金會開發的一個開源流處理平臺，由 Scala 和 Java 編寫。該項目的目標是為處理實時數據提供一個統一、高吞吐、低延遲的平臺。其持久化層本質上是一個“按照分布式事務日志架構的大規模發布/訂閱消息隊列”，這使它作為企業級基礎設施來處理流式數據非常有價值。此外，Kafka 可以通過 Kafka Connect 連接到外部系統（用于數據輸入/輸出），并提供了 Kafka Streams 的流式處理庫。該設計受事務日志的影響較大。

RocketMQ

RocketMQ 是一個分布式消息和流數據平臺，具有低延遲、高性能、高可靠性、萬億級容量和靈活的可擴展性。RocketMQ 是 2012 年阿里巴巴開源的第三代分布式消息中間件，2016 年 11 月 21 日，阿里巴巴向 Apache 軟件基金會捐贈了 RocketMQ；第二年 2 月 20 日，Apache 軟件基金會宣布 Apache RocketMQ 成為頂級項目。

消息隊列的選型需要根據具體應用需求而定，ZeroMQ 小而美，RabbitMQ 大而穩，Kakfa 和 RocketMQ 快而強勁。

RabbitMQ 的部署和使用

推薦 Docker 部署，在安裝 Docker 的環境下，執行：

docker run -d --hostname my-rabbit -p 15672:15672 -p 5672:5672 -- name rabbit-server -e RABBITMQ_DEFAULT_USER=user -e RABBITMQ_DEFAULT_PASS=password rabbitmq:3-management

現在在瀏覽器中打開 localhost:15672 。用戶名是 user ，密碼是 password

接下來，讓我們創建一個隊列，名字叫 my_app

創建一個 Exchange，名字叫 my_exchange

點擊 Exchange 標簽頁，點擊 my_exchange 進入詳情頁， 將 my_exchange 和 my_app 綁定，路由密鑰設置為 test:

Python 編寫生產者

現在可以使用 Python 編寫生產者，來生產一條消息放入隊列，并觀察 Web 頁面的變動情況：

import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', pika.PlainCredentials('user', 'password')))
channel = connection.channel() 
channel.basic_publish(exchange='my_exchange', routing_key='test', body='Test!')
connection.close()

執行上面的代碼，即可將消息放入隊列，這里我執行了四次，可以看到有四條消息：

消息將保留在隊列中，直到消費者把它取出，接下來我們寫一個消費消息的程序。

Python 編寫消費者

import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', pika.PlainCredentials("user", "password")))
channel = connection.channel()
def callback(ch, method, properties, body):
    print(f'{body} is received')
channel.basic_consume(queue="my_app", on_message_callback=callback, auto_ack=True)
channel.start_consuming()

執行：

此時，隊列已經空了：

這段代碼最低限度地演示了如何將消息發布到 RabbitMQ 中

上述就是小編為大家分享的如何部署使用消息隊列RabbitMQ了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關知識，歡迎關注億速云行業資訊頻道。