云計算與大數據技術 課件8.5消息隊列

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