之前疫情帶來(lái)的隔離使得我們只能待在家里，除了工作、上網(wǎng)課、自我充電之外，即使有云健身、云購(gòu)物、做美食等等活動(dòng)，我們似乎還是覺(jué)得少了點(diǎn)什么。一天24小時(shí)，活動(dòng)的最大空間就是從客廳到廚房，這時(shí)候最大的釋放莫過(guò)于買(mǎi)買(mǎi)買(mǎi)了。

說(shuō)到買(mǎi)買(mǎi)買(mǎi)，最激動(dòng)人心的就是雙十一了，雙十一活動(dòng)雖然多可即使你提前開(kāi)始打開(kāi)手機(jī)電腦iPad等著，準(zhǔn)點(diǎn)開(kāi)搶?zhuān)欢€是搶不到搶不到搶不到！這背后的原因真的是因?yàn)橛械娜耸炙倏?、有的人運(yùn)氣好，而并不是供應(yīng)商搞這樣的活動(dòng)來(lái)吸引人然而實(shí)際沒(méi)做活動(dòng)。

我們以最讓大家激情澎湃的雙十一為例，從23:59分開(kāi)始，每個(gè)人都打開(kāi)手機(jī)，不斷的刷新頁(yè)面，不斷的點(diǎn)擊商品去結(jié)算，直到00:00這一時(shí)刻過(guò)去。除了商品買(mǎi)到或沒(méi)買(mǎi)到之外，淘寶app或網(wǎng)頁(yè)版卻也還是可用的，只不過(guò)是這件商品買(mǎi)不到而已，但不影響其它的商品的購(gòu)買(mǎi)，在2019年的雙十一中淘寶每秒處理544000筆請(qǐng)求，如此大的用戶請(qǐng)求量下還保障業(yè)務(wù)的正常運(yùn)行，可以說(shuō)阿里云是非常了不起的。在以前的交易系統(tǒng)中，我們購(gòu)買(mǎi)一個(gè)商品，先進(jìn)行商品的篩選，然后提交購(gòu)買(mǎi)商品的款式、數(shù)量給到系統(tǒng)，這時(shí)候需要等待查詢庫(kù)存的結(jié)果，如果有商品的話則可以繼續(xù)進(jìn)行付款，如果沒(méi)有的話就返回錯(cuò)誤。如果是這樣的機(jī)制運(yùn)行在雙十一這樣的大流量里，那么所有的人都要瘋了，一來(lái)一回的等，索性不買(mǎi)了！實(shí)際上我們也找到了一個(gè)特別好的解決方案— 消息隊(duì)列Message Queue，用其來(lái)實(shí)現(xiàn)消息的異步傳輸?，F(xiàn)在的交易系統(tǒng)是這樣的，我們篩選好商品之后，直接向訂單系統(tǒng)發(fā)起購(gòu)買(mǎi)請(qǐng)求，訂單系統(tǒng)一邊給庫(kù)存系統(tǒng)發(fā)送用戶訂單，另一邊直接返回用戶訂單結(jié)果，用戶無(wú)須等待即可快速的完成整個(gè)購(gòu)物流程。

那么MQ（Message Queue）的運(yùn)行機(jī)制是怎么樣的呢？現(xiàn)在業(yè)內(nèi)常用的MQ包括Kafka、ActiveMQ、RabbitMQ、RocketMQ，四者的基本原理都差不多，只不過(guò)是根據(jù)自己的類(lèi)型不同而有些許區(qū)別，我們以RabbitMQ來(lái)進(jìn)行講解吧～

在RabbitMQ中有三個(gè)角色，生產(chǎn)者producer、Broker、消費(fèi)者consumer，

? 生產(chǎn)者

即消息的創(chuàng)建者，將業(yè)務(wù)產(chǎn)生的數(shù)據(jù)進(jìn)行一定的包裝，放進(jìn)broker中。

? 消費(fèi)者

即接收消息的一方，通過(guò)連接broker，訂閱隊(duì)列里面的消息。

? broker

即管理消息的服務(wù)器，它包含exchange和queue。exchange即交換器，生產(chǎn)者將消息投給broker后，broker內(nèi)的exchange決定把消息分發(fā)給哪個(gè)隊(duì)列queue。

典型的MQ設(shè)計(jì)模式有兩種，即點(diǎn)對(duì)點(diǎn)P2P（point to point）、發(fā)布訂閱pub\sub（publish\subscribe）.

? P2P模式

P2P的典型特點(diǎn)是發(fā)送的消息都會(huì)被成功處理。每個(gè)消息只有一個(gè)消費(fèi)者，并且成功消費(fèi)后告知生產(chǎn)者。它包含生產(chǎn)者、消息隊(duì)列、消費(fèi)者三個(gè)模塊。

? Pub\Sub模式

發(fā)布\訂閱模式的特點(diǎn)是一條消息可以被多個(gè)消費(fèi)者消費(fèi)、也可以不必消費(fèi)，消費(fèi)者根據(jù)自己的需要來(lái)訂閱生產(chǎn)者消息。包含生產(chǎn)者、topic、消費(fèi)者三個(gè)模塊，topic也就是主題。對(duì)于生產(chǎn)者消費(fèi)者大家很熟悉了，但topic有點(diǎn)晦澀，我們以阿里巴巴旗下有淘寶、天貓、支付寶等產(chǎn)品來(lái)講解一下，在客戶注冊(cè)不同app后發(fā)送注冊(cè)成功的短信中，淘寶的注冊(cè)成功短信是一個(gè)topic，天貓的短信是另一個(gè)topic。

其實(shí)整個(gè)消息管理系統(tǒng)的運(yùn)轉(zhuǎn)就和平時(shí)寄快遞差不多，假設(shè)我們要寄個(gè)物品回家，首先將我們的快遞給到快遞公司，快遞公司內(nèi)部根據(jù)目的地再分配走哪條路線，到達(dá)目的地后再由快遞員送到家里。我們就是生產(chǎn)者，整個(gè)快遞公司就是broker，不同的目的地就是不同的topic，收件人就是消費(fèi)者。

MQ是隨著云計(jì)算的出現(xiàn)而出現(xiàn)的，隨著互聯(lián)網(wǎng)的發(fā)展，應(yīng)用變得越來(lái)越復(fù)雜，系統(tǒng)與系統(tǒng)之間互相依賴，這樣就導(dǎo)致在開(kāi)發(fā)過(guò)程中開(kāi)發(fā)周期長(zhǎng)、上線要互相等待、上線后用戶使用某個(gè)服務(wù)時(shí)也要互相等待。這時(shí)候MQ就擔(dān)任了系統(tǒng)與系統(tǒng)之間的橋梁，讓它們不再互相強(qiáng)依賴，訂單系統(tǒng)可以獨(dú)自開(kāi)發(fā)完成上線、庫(kù)存系統(tǒng)也可以獨(dú)自開(kāi)發(fā)完成上線，用戶使用時(shí)感覺(jué)順暢，實(shí)現(xiàn)了系統(tǒng)與系統(tǒng)之間的解耦。

MQ除了異步處理、解耦外，另一個(gè)主要的應(yīng)用場(chǎng)景就是削峰。以我們?cè)诰〇|搶商品為例，15:00準(zhǔn)時(shí)開(kāi)搶?zhuān)@個(gè)時(shí)候可能一下子就來(lái)了10000個(gè)用戶（平常也就是1000個(gè)用戶，一下多了十倍），如果每個(gè)用戶的下單請(qǐng)求都去請(qǐng)求庫(kù)存系統(tǒng)的話，那么后臺(tái)的數(shù)據(jù)庫(kù)一下子就崩潰了，但有了MQ，我們可以把用戶的請(qǐng)求全都放在消息隊(duì)列里，等到后臺(tái)一個(gè)個(gè)的處理，就等價(jià)于把流量高峰削減了，保障了網(wǎng)站的正常運(yùn)行。

隨著5G的到來(lái)、云計(jì)算的發(fā)展、人工智能的應(yīng)用與普及，會(huì)有越來(lái)越多的人同時(shí)接入互聯(lián)網(wǎng)，傳統(tǒng)的“巨無(wú)霸”應(yīng)用已不可取，將消息隊(duì)列融合在應(yīng)用中，實(shí)現(xiàn)應(yīng)用的解耦、異步使用，才能保障用戶的使用體驗(yàn)，也才能保障互聯(lián)網(wǎng)繼續(xù)大步的往前發(fā)展，用戶更快、更爽～