前言

RabbitMQ是基于AMQP協(xié)議(Advanced Message Queue Protocol)的消息中間件。

什么是消息隊(duì)列

消息隊(duì)列屬于進(jìn)程間通信的一種方式，使用消息隊(duì)列可以通過異步方式處理數(shù)據(jù)，借此可以提高系統(tǒng)性能。我們可以把消息當(dāng)作存放數(shù)據(jù)的容器，消息的消費(fèi)者可以從隊(duì)列中獲取數(shù)據(jù)，進(jìn)行處理。常見的消息隊(duì)列有：ActiveMQ，RabbitMQ，Kafka，RocketMQ等。

RabbitMQ中用到基本概念

Broker：消息隊(duì)列的服務(wù)器實(shí)體。

Exchange：消息交換機(jī)，它指定消息按什么規(guī)則，路由到哪個(gè)隊(duì)列。

Queue：消息隊(duì)列載體，每個(gè)消息都會(huì)被投入到一個(gè)或多個(gè)隊(duì)列。

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

Routing Key：路由關(guān)鍵字，exchange根據(jù)這個(gè)關(guān)鍵字進(jìn)行消息投遞。

vhost：虛擬主機(jī)，一個(gè)broker里可以開設(shè)多個(gè)vhost，用作不同用戶的權(quán)限分離。

producer：消息生產(chǎn)者，投遞消息的程序。

consumer：消息消費(fèi)者，接收消息的程序。

channel：消息通道，在客戶端的每個(gè)連接里，可以建立多個(gè)channel，每個(gè)channel代表一個(gè)會(huì)話任務(wù)。

RabbitMQ中消息模式

1、簡(jiǎn)單隊(duì)列

一個(gè)生產(chǎn)者對(duì)應(yīng)一個(gè)消費(fèi)者。

2、工作隊(duì)列

一個(gè)生產(chǎn)者，多個(gè)消費(fèi)者，一個(gè)消息只能發(fā)給一個(gè)消費(fèi)者，spring中整合rabbitmq時(shí)，默認(rèn)采用公平分發(fā)。

3、發(fā)布訂閱模式

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

使用該模式需要借助交換機(jī)，生產(chǎn)者將消息發(fā)送到交換機(jī)，再通過交換機(jī)到達(dá)隊(duì)列。

RabbitMQ中有四種交換機(jī)：direct/topic/headers/fanout。默認(rèn)交換機(jī)是direct，發(fā)布與訂閱的實(shí)現(xiàn)使用fanout。

使用交換機(jī)時(shí)，每個(gè)消費(fèi)者有自己的隊(duì)列，生產(chǎn)者將消息發(fā)送到交換機(jī)(X)，每個(gè)隊(duì)列都要綁定到交換機(jī)。

4、路由模式

生產(chǎn)者將消息發(fā)送到direct交換機(jī)(路由模式需要借助直連交換機(jī)實(shí)現(xiàn))，在綁定隊(duì)列和交換機(jī)的時(shí)候有一個(gè)路由key，生產(chǎn)者發(fā)送的消息會(huì)指定一個(gè)路由key，那么消息只會(huì)發(fā)送到相應(yīng)key相同的隊(duì)列，接著監(jiān)聽該隊(duì)列的消費(fèi)者消費(fèi)消息。也就是讓消費(fèi)者有選擇性的接收消息。

5、主題模式

又稱通配符模式。

使用直連交換機(jī)可以改善我們的系統(tǒng)，但是它仍有局限性，它不能實(shí)現(xiàn)多重條件的路由。在消息系統(tǒng)中，我們不僅想要訂閱基于路由鍵的隊(duì)列，還想訂閱基于生產(chǎn)消息的源，這時(shí)候可以使用topic交換機(jī)。

使用主題交換機(jī)時(shí)，路由鍵的語(yǔ)法形式是采用點(diǎn)分割的有意義的單詞。例如"goods.stock.info"。

其中：*星號(hào)代表一個(gè)單詞，#井號(hào)代表0個(gè)或多個(gè)單詞。

總結(jié)

以上是生活随笔為你收集整理的java中mq组建是什么_Java教程之RabbitMQ介绍的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。