RabbitMQ 詳解以及使用場景

2021-09-29 22:45:22 字數 2586 閱讀 9635

mq全稱為message queue, 訊息佇列(mq)是一種應用程式對應用程式的通訊方法。應用程式通過讀寫出入佇列的訊息(針對應用程式的資料)來通訊,而無需專用連線來鏈結它們。訊息傳遞指的是程式之間通過在訊息中傳送資料進行通訊,而不是通過直接呼叫彼此來通訊,直接呼叫通常是用於諸如遠端過程呼叫的技術。排隊指的是應用程式通過 佇列來通訊。佇列的使用除去了接收和傳送應用程式同時執行的要求。

rabbitmq是使用erlang語言開發的開源訊息佇列系統,基於amqp協議來實現。amqp的主要特徵是面向訊息、佇列、路由(包括點對點和發布/訂閱)、可靠性、 安全。amqp協議更多用在企業系統內,對資料一致性、穩定性和可靠性要求很高的場景,對效能和吞吐量的要求還在其次。

1、解耦(為面向服務的架構(soa)提供基本的最終一致性實現)

場景說明:使用者下單後,訂單系統需要通知庫存系統。傳統的做法是,訂單系統呼叫庫存系統的介面。

傳統模式的缺點:

假如庫存系統無法訪問,則訂單減庫存將失敗,從而導致訂單失敗

訂單系統與庫存系統耦合

引入訊息佇列

訂單系統:使用者下單後,訂單系統完成持久化處理,將訊息寫入訊息佇列,返回使用者訂單下單成功

庫存系統:訂閱下單的訊息,採用拉/推的方式,獲取下單資訊,庫存系統根據下單資訊,進行庫存操作

假如:在下單時庫存系統不能正常使用。也不影響正常下單,因為下單後,訂單系統寫入訊息佇列就不再關心其他的後續操作了。實現訂單系統與庫存系統的應用解耦

為了保證庫存肯定有,可以將佇列大小設定成庫存數量,或者採用其他方式解決。

基於訊息的模型,關心的是「通知」,而非「處理」。

簡訊、郵件通知、快取重新整理等操作使用訊息佇列進行通知。

訊息佇列和rpc的區別與比較:

rpc: 非同步呼叫,及時獲得呼叫結果,具有強一致性結果,關心業務呼叫處理結果。

訊息佇列:兩次非同步rpc呼叫,將呼叫內容在佇列中進行轉儲,並選擇合適的時機進行投遞(錯峰流控)

2、非同步提公升效率

場景說明:使用者註冊後,需要發註冊郵件和註冊簡訊。

傳統的做法有兩種 :

3. 流量削峰

流量削鋒也是訊息佇列中的常用場景,一般在秒殺或團搶活動中使用廣泛

應用場景:系統其他時間a系統每秒請求量就100個,系統可以穩定執行。系統每天晚間八點有秒殺活動,每秒併發請求量增至1萬條,但是系統最大的處理能力只能每秒處理1000個請求,於是系統崩潰,伺服器宕機。

之前架構:大量使用者(100萬使用者)通過瀏覽器在晚上八點高峰期同時參與秒殺活動。大量的請求湧入我們的系統中,高峰期達到每秒鐘5000個請求,大量的請求打到mysql上,每秒鐘預計執行3000條sql。但是一般的mysql每秒鐘扛住2000個請求就不錯了,如果達到3000個請求的話可能mysql直接就癱瘓了,從而系統無法被使用。但是高峰期過了之後,就成了低峰期,可能也就1萬使用者訪問系統,每秒的請求數量也就50個左右,整個系統幾乎沒有任何壓力。

引入mq:100萬使用者在高峰期的時候,每秒請求有5000個請求左右,將這5000請求寫入mq裡面,系統a每秒最多只能處理2000請求,因為mysql每秒只能處理2000個請求。系統a從mq中慢慢拉取請求,每秒就拉取2000個請求,不要超過自己每秒能處理的請求數量即可。mq,每秒5000個請求進來,結果只有2000個請求出去,所以在秒殺期間(將近一小時)可能會有幾十萬或者幾百萬的請求積壓在mq中。這個短暫的高峰期積壓是沒問題的,因為高峰期過了之後,每秒就只有50個請求進入mq了,但是系統還是按照每秒2000個請求的速度在處理,所以說,只要高峰期一過,系統就會快速將積壓的訊息消費掉。我們在此計算一下,每秒在mq積壓3000條訊息,1分鐘會積壓18萬,1小時積壓1000萬條訊息,高峰期過後,1個多小時就可以將積壓的1000萬訊息消費掉。

優點

優點就是以上的那些場景應用,就是在特殊場景下有其對應的好處,解耦、非同步、削峰。

缺點

系統的可用性降低

系統引入的外部依賴越多,系統越容易掛掉,本來只是a系統呼叫bcd三個系統介面就好,abcd四個系統不報錯整個系統會正常執行。引入了mq之後,雖然abcd系統沒出錯,但mq掛了以後,整個系統也會崩潰。

系統的複雜性提高

引入了mq之後,需要考慮的問題也變得多了,如何保證訊息沒有重複消費?如何保證訊息不丟失?怎麼保證訊息傳遞的順序?

一致性問題

a系統傳送完訊息直接返回成功,但是bcd系統之中若有系統寫庫失敗,則會產生資料不一致的問題。

總結

訊息佇列是一種十分複雜的架構,引入它有很多好處,但是也得針對它帶來的壞處做各種額外的技術方案和架構來規避。引入mq系統複雜度提公升了乙個數量級,但是在有些場景下,就是複雜十倍百倍,還是需要使用mq。

RabbitMQ 簡介以及使用場景

目錄mq全稱為message queue,訊息佇列 mq 是一種應用程式對應用程式的通訊方法。應用程式通過讀寫出入佇列的訊息 針對應用程式的資料 來通訊,而無需專用連線來鏈結它們。訊息傳遞指的是程式之間通過在訊息中傳送資料進行通訊,而不是通過直接呼叫彼此來通訊,直接呼叫通常是用於諸如遠端過程呼叫的技...

RabbitMQ使用場景介紹

場景說明 使用者註冊後,需要傳送郵件和註冊簡訊,傳統的方式有兩種 1 序列的方式,2 並行的方式 場景 雙十一是購物狂節,使用者下單後,訂單系統要通知庫存系統,傳統的做法就是訂單系統呼叫庫存系統的介面 這種做法有乙個缺點 當庫存系統出現故障之後,訂單系統就會失敗,訂單系統和庫存系統耦合,引入訊息佇列...

rabbitMq 使用詳解

傳送訊息 所謂的生產者 rabbitmq host 127.0.0.1 listener acknowledge mode manual password 自己的密碼 port 5672 username 自己的使用者名稱 virtual host develop 虛擬伺服器,相當於許可權設定 mq...