好程序員Java學(xué)習(xí)資源分享RabbitMQ介紹-創(chuàng)新互聯(lián)

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

成都創(chuàng)新互聯(lián)公司堅(jiān)持“要么做到，要么別承諾”的工作理念，服務(wù)領(lǐng)域包括：成都網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣等服務(wù)，滿足客戶于互聯(lián)網(wǎng)時(shí)代的化德網(wǎng)站設(shè)計(jì)、移動(dòng)媒體設(shè)計(jì)的需求，幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴！

什么是消息隊(duì)列

消息隊(duì)列屬于進(jìn)程間通信的一種方式，使用消息隊(duì)列可以通過(guò)異步方式處理數(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ī)則綁定起來(lái)

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ī)，再通過(guò)交換機(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è)單詞

創(chuàng)新互聯(lián)www.cdcxhl.cn，專業(yè)提供香港、美國(guó)云服務(wù)器，動(dòng)態(tài)BGP最優(yōu)骨干路由自動(dòng)選擇，持續(xù)穩(wěn)定高效的網(wǎng)絡(luò)助力業(yè)務(wù)部署。公司持有工信部辦法的idc、isp許可證， 機(jī)房獨(dú)有T級(jí)流量清洗系統(tǒng)配攻擊溯源，準(zhǔn)確進(jìn)行流量調(diào)度，確保服務(wù)器高可用性。佳節(jié)活動(dòng)現(xiàn)已開啟，新人活動(dòng)云服務(wù)器買多久送多久。

網(wǎng)頁(yè)題目：好程序員Java學(xué)習(xí)資源分享RabbitMQ介紹-創(chuàng)新互聯(lián)
文章起源：http://muchs.cn/article0/cshoio.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供靜態(tài)網(wǎng)站、自適應(yīng)網(wǎng)站、手機(jī)網(wǎng)站建設(shè)、App開發(fā)、電子商務(wù)、關(guān)鍵詞優(yōu)化

廣告

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