消息隊列消息隊列簡介消息隊列（MessageQueue，MQ）從廣義上來說是一種消息隊列服務(wù)中間件，提供一套完整的信息生產(chǎn)、傳遞和消費的軟件系統(tǒng)。常見的MQ中間件有：RabbitMQ、RocketMQ、Kafka、ActiveMQ等。消息隊列簡介MQ是一種應(yīng)用程序間的通信機(jī)制，與傳統(tǒng)的遠(yuǎn)程調(diào)用（RPC）不同，它采用異步通信模式。MQ中間件是一個獨立的應(yīng)用程序，專門用于接收、存儲、分發(fā)消息。消息隊列簡介兩種主要的消息傳遞模式為點對點傳遞模式、發(fā)布-訂閱傳遞模式。消息隊列簡介1．點對點傳遞模式點對點傳遞模式將消息持久化到一個隊列中，此時將有一個或多個消費者消費隊列中的數(shù)據(jù)，但是一條消息只能被消費一次。消息隊列簡介2．發(fā)布-訂閱傳遞模式發(fā)布-訂閱傳遞模式將消息持久化到一個Topic中。消費者可以訂閱一個或多個Topic，并消費該Topic中所有的數(shù)據(jù)。同一條數(shù)據(jù)可以被多個消費者消費。消息隊列作用1．程序間解耦在應(yīng)用之間引入MQ，可以使應(yīng)用之間的交互更改為通過MQ消息來觸發(fā)，降低了應(yīng)用之間的耦合度。只需上游系統(tǒng)發(fā)布消息和下游系統(tǒng)訂閱消息即可。消息隊列作用2．異步處理異步應(yīng)用場景，如用戶在Web應(yīng)用或App上注冊成功后，服務(wù)端需要給用戶發(fā)送注冊郵件和注冊短信電商平臺上完成訂單支付后，后臺服務(wù)需要扣減庫存量、贈送優(yōu)惠券、增加用戶積分、修改訂單狀態(tài)、物流系統(tǒng)等。消息隊列作用消息隊列提供了一個異步通信機(jī)制，消息的發(fā)送者不必一直等到消息被成功處理后才返回，而是可以立即返回。消息隊列作用3．削峰填谷在互聯(lián)網(wǎng)電商的秒殺活動、團(tuán)購搶單、店慶等超高并發(fā)場景中，后端服務(wù)可能來不及同步處理過多、過快的請求，就會導(dǎo)致請求堵塞，嚴(yán)重時可能因為高負(fù)荷運轉(zhuǎn)而拖垮Web服務(wù)器。這樣的突發(fā)流量并不常見，若為了處理這類峰值訪問而投入資源來隨時待命，則會造成巨大的浪費。此時，可以先將用戶的秒殺請求作為消息存入消息隊列中間件，然后由后端服務(wù)根據(jù)自身能力慢慢處理消息隊列中的請求信息。消息隊列作用消息隊列作用4．消息通信消息隊列系統(tǒng)通常內(nèi)置了高效、可靠的通信機(jī)制，因此，除了主要的數(shù)據(jù)傳輸和任務(wù)處理功能，也可以用于實現(xiàn)純消息通信。這種通信方式可以用于多種場景，如點對點通信或聊天室通信等。常見的消息隊列1．RabbitMQRabbitMQ是一個由Erlang語言開發(fā)的AMQP（AdvancedMessageQueuingProtocol，高級消息隊列協(xié)議）的開源實現(xiàn)，其本質(zhì)是一套消息隊列服務(wù)軟件，本身支持很多協(xié)議，屬于重量級消息隊列，更適合企業(yè)級的開發(fā)。常見的消息隊列RabbitMQ架構(gòu)常見的消息隊列2．RocketMQRocketMQ是阿里中間件團(tuán)隊開源的一款消息隊列，它采用純Java開發(fā)，具有高吞吐量、高可用性等特點，適用于大規(guī)模分布式系統(tǒng)，支持事務(wù)消息、順序消息、批量消息、定時消息、消息回溯等。目前在阿里巴巴被廣泛應(yīng)用于交易、充值、流