好程序員Java學習資源分享RabbitMQ介紹

好程序員Java學習資源分享RabbitMQ介紹，前言，RabbitMQ是基于AMQP協議（Advanced Message Queue Protocol）的消息中間件

什么是消息隊列

消息隊列屬于進程間通信的一種方式，使用消息隊列可以通過異步方式處理數據，借此可以提高系統性能。我們可以把消息當作存放數據的容器，消息的消費者可以從隊列中獲取數據，進行處理。常見的消息隊列有：ActiveMQ，RabbitMQ，Kafka，RocketMQ等。

RabbitMQ中用到基本概念

Broker：消息隊列的服務器實體

　　 Exchange：消息交換機，它指定消息按什么規則，路由到哪個隊列

　　 Queue：消息隊列載體，每個消息都會被投入到一個或多個隊列

　　 Binding：綁定，它主要是把exchange和queue按照路由規則綁定起來

　　 Routing Key：路由關鍵字，exchange根據這個關鍵字進行消息投遞

　　 vhost：虛擬主機，一個broker里可以開設多個vhost，用作不同用戶的權限分離

　　 producer：消息生產者，投遞消息的程序

　　 consumer：消息消費者，接收消息的程序

　　 channel：消息通道，在客戶端的每個連接里，可以建立多個channel，每個channel代表一個會話任務

RabbitMQ中消息模式

1?簡單隊列

一個生產者對應一個消費者

2?工作隊列

一個生產者，多個消費者，一個消息只能發給一個消費者，spring中整合rabbitmq時，默認采用公平分發

?

3?發布訂閱模式

傳遞一個消息到多個消費者中，借助該模式可以發布的消息將被廣播給所有接收者。

使用該模式需要借助交換機，生產者將消息發送到交換機，再通過交換機到達隊列。

RabbitMQ中有四種交換機：direct/topic/headers/fanout。默認交換機是direct，發布與訂閱的實現使用fanout。

使用交換機時，每個消費者有自己的隊列，生產者將消息發送到交換機(X)，每個隊列都要綁定到交換機。

4路由模式

生產者將消息發送到direct交換機（路由模式需要借助直連交換機實現），在綁定隊列和交換機的時候有一個路由key，生產者發送的消息會指定一個路由key，那么消息只會發送到相應key相同的隊列，接著監聽該隊列的消費者消費消息。也就是讓消費者有選擇性的接收消息。

5?主題模式

又稱通配符模式。

使用直連交換機可以改善我們的系統，但是它仍有局限性，它不能實現多重條件的路由。在消息系統中，我們不僅想要訂閱基于路由鍵的隊列，還想訂閱基于生產消息的源，這時候可以使用topic交換機。

使用主題交換機時，路由鍵的語法形式是采用點分割的有意義的單詞。例如"goods.stock.info"。

其中：*星號代表一個單詞，#井號代表0個或多個單詞