高性能網(wǎng)站實用技巧之消息隊列篇-創(chuàng)新互聯(lián)

什么是消息隊列

網(wǎng)站的建設(shè)創(chuàng)新互聯(lián)公司專注網(wǎng)站定制,經(jīng)驗豐富,不做模板,主營網(wǎng)站定制開發(fā).小程序定制開發(fā),H5頁面制作!給你煥然一新的設(shè)計體驗!已為成都集裝箱等企業(yè)提供專業(yè)服務(wù)。

消息隊列（Message Queue）是一種進程間通信或同一進程的不同線程間的通信方式。進程或者線程之間通過 消息 進行通信，消息發(fā)送后可以立即返回，由消息系統(tǒng)來確保信息的可靠傳遞，消息發(fā)布者（生產(chǎn)者）只管把消息發(fā)布到消息隊里中而不用管誰來消費，消息使用者（消費者）只管從消息隊列中獲取消息以進一步處理而不用管理誰發(fā)布的消息，這樣發(fā)布者和使用者都不用知道對方的存在。

消息（Message）是指在應(yīng)用之間傳送的數(shù)據(jù)。消息可以非常簡單，比如只包含文本字符串，也可以很復(fù)雜，如嵌入對象。

消息隊列的特點

通過提供 消息傳遞 和 消息排隊 模型，它可以在 分布式環(huán)境 下提供 應(yīng)用解耦、彈性伸縮、冗余存儲、流量削峰、異步通信、數(shù)據(jù)同步 等等功能，其作為 分布式系統(tǒng)架構(gòu) 中的一個重要組件，有著舉足輕重的地位。消息隊列主要特點有：

• 異步性：將耗時的同步操作，通過以發(fā)送消息的方式，進行了異步化處理。減少了同步等待的時間。

• 松耦合：消息隊列減少了服務(wù)之間的耦合性，不同的服務(wù)可以通過消息隊列進行通信，而不用關(guān)心彼此的實現(xiàn)細節(jié)，只要定義好消息的格式就行

• 分布式：通過對消費者的橫向擴展，降低了消息隊列阻塞的風(fēng)險，以及單個消費者產(chǎn)生單點故障的可能性。

• 可靠性：消息隊列一般會把接收的消息存儲到本地硬盤上（當(dāng)消息被處理完之后，存儲信息根據(jù)不同的消息隊列實現(xiàn)，有可能將其刪除），這樣即使應(yīng)用掛掉或者消息隊列本身掛掉，消息也能夠重新加載。

消息隊列應(yīng)用場景

異步處理

同步處理 是指從請求的發(fā)起一直到最終的處理完成期間，請求的調(diào)用方一直在同步阻塞等待調(diào)用的處理完成。

異步處理 處理是指在請求發(fā)起的處理過程中，客戶端的代碼已經(jīng)返回了，它可以繼續(xù)進行自己的后續(xù)操作，而不需要等待調(diào)用處理完成。

對一些比較耗時且不需要即時（同步）返回操作結(jié)果的操作，可以把處理過程通過消息隊列進行異步處理。這樣做可以推遲耗時操作的處理，使耗時操作異步化，而不必阻塞客戶端程序，客戶端的程序在得到處理結(jié)果之前可以繼續(xù)執(zhí)行，從而提高客戶端程序的處理性能。

異步處理的主要目的是 減少請求響應(yīng)時間，實現(xiàn)非核心流程異步化，提高系統(tǒng)響應(yīng)性能。

應(yīng)用解耦

使用消息隊列，可以有多個生產(chǎn)者發(fā)布消息，多個消費者消費消息，共同完成整個的業(yè)務(wù)處理邏輯，生產(chǎn)者只關(guān)心是否正確將消息寫入消息隊列，消費者只關(guān)心從消息隊列中獲取消息，然后進行處理邏輯，生產(chǎn)者和消費者之間不需要直接的交互調(diào)用，沒有代碼的依賴耦合。

耦合度越低程序代碼越容易維護，也容易進行擴展。

流量削峰

一般在秒殺活動中廣泛使用。

在秒殺活動中，一般由于瞬時訪問量過大，服務(wù)器瞬間接收了大量的請求，流量暴增，這種情況下很有可能導(dǎo)致相關(guān)系統(tǒng)無法處理請求甚至崩潰。為了解決這個問題，一般會在應(yīng)用的前端加入消息隊列。

• 請求先寫入消息隊列，而不是由業(yè)務(wù)系統(tǒng)直接處理，做了一次緩沖，極大的減少了業(yè)務(wù)處理系統(tǒng)的壓力。

• 隊列的長度可以做限制，一般秒殺活動都是有數(shù)量限制的，后寫入隊列的用戶無法秒殺到商品，這樣的請求可以直接被拋棄，可以直接返回活動已結(jié)束或商品已售完。

使用消息隊列，即便是訪問流量持續(xù)的增長，系統(tǒng)依然可以持續(xù)的接收請求。雖然生產(chǎn)者生成的消息比消費者消費的速度快，但是通過消息隊列進行了緩沖，在短時間內(nèi)，生產(chǎn)者和消費者之間處理能力不會互相影響，同樣也可以保證系統(tǒng)的穩(wěn)定性。

消息通訊

消息隊列一般都內(nèi)置了高效的通信機制，因此可以用于單純的消息通訊，比如實現(xiàn)點對點消息隊列或者聊天室。

廣播

如果沒有消息隊列，每當(dāng)一個新的業(yè)務(wù)方介入，那都需要聯(lián)調(diào)一次接口。有了消息隊列，只需要關(guān)系消息是否送達了隊列，至于誰希望訂閱，是下游的事情，無疑極大地減少了開發(fā)和聯(lián)調(diào)的工作量。

日志處理

將消息隊列用在日志處理中，解決了大量日志傳輸?shù)膯栴}（如Kafka）。

消息隊列的傳輸模式

點對點模式（Point to Point）

點對點模式 用于 消息生產(chǎn)者 和 消息消費者 之間 點到點 的通信。消息生產(chǎn)者將消息發(fā)送到由某個名字標識的特定隊列（Queue）。在消息傳遞給消費者之前它被 存儲 在這個隊列中。隊列消息 可以放在 內(nèi)存 中也可以 持久化，以保證在消息服務(wù)出現(xiàn)故障時仍然能夠傳遞消息。

點對點模式特點：

• 每個消息只有一個消費者（Consumer），即一旦消息被消費，消息就不再在消息隊列中。

• 生產(chǎn)者和消費者之間沒有依賴性，生產(chǎn)者發(fā)送消息之后，不管有沒有消費者在運行，都不會影響到生產(chǎn)者下次發(fā)送消息。

• 消費者在成功接收消息之后需向隊列應(yīng)答成功，以便消息隊列刪除當(dāng)前接收的消息。

發(fā)布/訂閱模式（Publish/Subscribe）

發(fā)布者/訂閱者 模型支持向一個特定的 消息主題 生產(chǎn)消息。 0 或多個 訂閱者 可能對接收來自 特定消息主題 的消息感興趣。

在這種模型下，發(fā)布者和訂閱者彼此不知道對方。多個消費者可以獲得消息，在 發(fā)布者 和 訂閱者 之間存在 時間依賴性。發(fā)布者需要建立一個 訂閱（subscription），以便能夠消費者訂閱。訂閱者 必須保持 持續(xù)的活動狀態(tài) 并 接收消息。

發(fā)布/點閱模式特點：

• 每個消息可以有多個訂閱者。

• 發(fā)布者和訂閱者之間有時間上的依賴性，針對某個主題（Topic）的訂閱者，它必須創(chuàng)建一個訂閱之后，才能消費發(fā)布者的消息。

• 為了消費消息，訂閱者需要提前訂閱該角色主題，并保持在線運行。

集中消息中間件對比

目前在生產(chǎn)環(huán)境，使用較多的消息隊列有ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ等。

歡迎工作一到五年的Java工程師朋友們加入Java技術(shù)交流群：659270626
群內(nèi)提供免費的Java架構(gòu)學(xué)習(xí)資料（里面有高可用、高并發(fā)、高性能及分布式、Jvm性能調(diào)優(yōu)、Spring源碼，MyBatis，Netty,Redis,Kafka,Mysql,Zookeeper,Tomcat,Docker,Dubbo,Nginx等多個知識點的架構(gòu)資料）合理利用自己每一分每一秒的時間來學(xué)習(xí)提升自己，不要再用"沒有時間“來掩飾自己思想上的懶惰！趁年輕，使勁拼，給未來的自己一個交代！

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

標題名稱：高性能網(wǎng)站實用技巧之消息隊列篇-創(chuàng)新互聯(lián)
網(wǎng)站網(wǎng)址：http://muchs.cn/article8/eieip.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供品牌網(wǎng)站建設(shè)、關(guān)鍵詞優(yōu)化、企業(yè)網(wǎng)站制作、全網(wǎng)營銷推廣、定制網(wǎng)站、建站公司

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)