快捷導(dǎo)航

高級(jí)消息隊(duì)列協(xié)議AMQP簡(jiǎn)介

更新時(shí)間：2022年07月02日 14:39:40 作者：天方

這篇文章簡(jiǎn)單介紹了高級(jí)消息隊(duì)列協(xié)議AMQP，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

歷史：

Message Queue的需求由來(lái)已久，80年代最早在金融交易中，高盛等公司采用Teknekron公司的產(chǎn)品，當(dāng)時(shí)的Message queuing軟件叫做：the information bus（TIB）。 TIB被電信和通訊公司采用，路透社收購(gòu)了Teknekron公司。之后，IBM開(kāi)發(fā)了MQSeries，微軟開(kāi)發(fā)了Microsoft Message Queue（MSMQ）。這些商業(yè)MQ供應(yīng)商的問(wèn)題是廠商鎖定，價(jià)格高昂。2001年，Java Message queuing試圖解決鎖定和交互性的問(wèn)題，但對(duì)應(yīng)用來(lái)說(shuō)反而更加麻煩了。

于是2004年，摩根大通和iMatrix開(kāi)始著手Advanced Message Queuing Protocol （AMQP）開(kāi)放標(biāo)準(zhǔn)的開(kāi)發(fā)。2006年，AMQP規(guī)范發(fā)布。2007年，Rabbit技術(shù)公司基于AMQP標(biāo)準(zhǔn)開(kāi)發(fā)的RabbitMQ 1.0 發(fā)布。

基本概念

AMQP基本模型如下圖所示：

Broker：

接收和分發(fā)消息的應(yīng)用，如RabbitMQ Server就是Message Broker。

Virtual host：

出于多租戶和安全因素設(shè)計(jì)的，把AMQP的基本組件劃分到一個(gè)虛擬的分組中，類(lèi)似于網(wǎng)絡(luò)中的namespace概念。

Exchange

交換器是消息送達(dá)的實(shí)體。他是具名的，它是消息的第一站。系統(tǒng)根據(jù)分發(fā)規(guī)則，匹配查詢表中的routing key，分發(fā)消息到queue中去。

屬性：

durable：該交換器將在broker重啟后生效。
auto-delete：該交換器將在沒(méi)有消息隊(duì)列綁定時(shí)自動(dòng)刪除。一個(gè)從未綁定任何隊(duì)列的交換器不會(huì)自動(dòng)刪除。

類(lèi)型：

direct (point-to-point)
fanout (multicast)
topic (publish-subscribe)

Queue

隊(duì)列是接收消息的實(shí)體，具有名字和屬性，但沒(méi)有類(lèi)型。客戶端可以訂閱隊(duì)列以便使broker遞送某消息隊(duì)列的內(nèi)容到該客戶端。

屬性：

alternate-exchange ：當(dāng)消息被訂閱者拒絕或者由于隊(duì)列被刪除而孤立時(shí)則被送往此交換器，同時(shí)隊(duì)列中的該消息被刪除。
passive ：當(dāng)隊(duì)列不存在時(shí)會(huì)拋出一個(gè)錯(cuò)誤信息，仍然不會(huì)被聲明。
durable ：隊(duì)列將在broker重啟時(shí)啟動(dòng)。
exclusive ：隊(duì)列僅服務(wù)于一個(gè)客戶端。
auto-delete ：隊(duì)列在沒(méi)有活躍訂閱者的時(shí)候?qū)⒆詣?dòng)刪除。當(dāng)客戶端終結(jié)時(shí)，exclusive類(lèi)型的隊(duì)列則一定會(huì)自動(dòng)刪除。

Binding

綁定是隊(duì)列和交換器之間的關(guān)系，規(guī)定消息如何由交換器到隊(duì)列。綁定的屬性被交換器用來(lái)與路由算法匹配。

當(dāng)一個(gè)消息的路由關(guān)鍵字與綁定中的模式匹配時(shí)，交換器會(huì)把該消息的拷貝送達(dá)隊(duì)列。如何進(jìn)行匹配僅依賴(lài)于交換器的類(lèi)型：

direct型：消息的路由關(guān)鍵字與綁定相同。
fanout型：總是匹配，即使綁定無(wú)關(guān)鍵字。
topic型：匹配路由關(guān)鍵字屬性，字符串的各個(gè)部分以'.'分隔?？砂瑑蓚€(gè)特殊字符：'*'表示單個(gè)任意詞，'#'表示0個(gè)或多個(gè)詞，例如 *.stock.# 匹配usd.stock和eur.stock.db，但不匹配stock.nasdaq。
headers型：匹配各個(gè)鍵-值對(duì)的邏輯組合結(jié)果。

Connection:

publisher／consumer和broker之間的TCP連接。斷開(kāi)連接的操作只會(huì)在client端進(jìn)行，Broker不會(huì)斷開(kāi)連接，除非出現(xiàn)網(wǎng)絡(luò)故障或broker服務(wù)出現(xiàn)問(wèn)題。

Channel:

如果每一次訪問(wèn)RabbitMQ都建立一個(gè)Connection，在消息量大的時(shí)候建立TCP Connection的開(kāi)銷(xiāo)將是巨大的，效率也較低。

Channel是在connection內(nèi)部建立的邏輯連接，如果應(yīng)用程序支持多線程，通常每個(gè)thread創(chuàng)建單獨(dú)的channel進(jìn)行通訊，AMQP method包含了channel id幫助客戶端和message broker識(shí)別channel，所以channel之間是完全隔離的。Channel作為輕量級(jí)的Connection極大減少了操作系統(tǒng)建立TCP connection的開(kāi)銷(xiāo)。

到此這篇關(guān)于高級(jí)消息隊(duì)列協(xié)議AMQP的文章就介紹到這了。希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: