概述

不管是微服務(wù)還是分布式的系統(tǒng)架構(gòu)中，消息隊(duì)列中間件都是不可缺少的一個(gè)重要環(huán)節(jié)，主流的消息隊(duì)列中間件有RabbitMQ、RocketMQ等等，從這篇開始詳細(xì)介紹以RabbitMQ為代表的消息隊(duì)列中間件。

AMQP協(xié)議

• AMQP協(xié)議是一個(gè)提供統(tǒng)一消息服務(wù)的應(yīng)用層標(biāo)準(zhǔn)協(xié)議，基于此協(xié)議的客戶端與消息中間件可傳遞消息，并不受客戶端/中間件不同產(chǎn)品，不同開發(fā)語言等條件的限制。
• AMQP協(xié)議是一種二進(jìn)制協(xié)議，提供客戶端應(yīng)用與消息中間件之間的異步、安全、高效的交互。
• AMQP作為中間層服務(wù)，把消息生產(chǎn)和消費(fèi)分隔開來，當(dāng)消費(fèi)者產(chǎn)生出現(xiàn)異常，不影響消費(fèi)者對消息的消費(fèi)，當(dāng)消費(fèi)者異常時(shí)，生產(chǎn)者生產(chǎn)的消息可以存放到服務(wù)的內(nèi)存或者磁盤，不會(huì)影響想消費(fèi)的速率，同時(shí)，消息也可以基于路由的規(guī)則可以投遞到指定的消費(fèi)者消費(fèi)。

AMQP協(xié)議重要角色

1.生產(chǎn)者和消費(fèi)者

• 生產(chǎn)者是生產(chǎn)消息的主體，消費(fèi)者是消費(fèi)消息的主體
• 數(shù)據(jù)集成與系統(tǒng)解耦、異步處理與事件驅(qū)動(dòng)、流量薛峰、事務(wù)消息與分布式事務(wù)的最終一致
• 生產(chǎn)者生產(chǎn)一條消息丟給消息代理，消息代理根據(jù)投遞規(guī)則將消息傳到消費(fèi)者手上

2.交換機(jī)

• 交換機(jī)就像是消息代理的路由器，負(fù)責(zé)拿到一個(gè)消息之后，根據(jù)確定的規(guī)則(路由鍵)將它路由給一個(gè)或零個(gè)隊(duì)列，交換機(jī)具備多種路由模式。
• 基于消息生產(chǎn)者和路由規(guī)則可以將消息投遞到指定的Message Queue，交換機(jī)收到生產(chǎn)者投遞的消息，基于路由規(guī)則及隊(duì)列綁定關(guān)系匹配到投遞對應(yīng)的交換機(jī)或者隊(duì)列進(jìn)行分發(fā)，交換機(jī)不存儲(chǔ)消息，只做轉(zhuǎn)發(fā)

交換機(jī)類型：

• 直連交換機(jī)：根據(jù)路由鍵完全匹配的投遞到對應(yīng)的隊(duì)列
• 扇形交換機(jī)：無視路由鍵，將消息進(jìn)行拷貝，并路由到給綁定到它身上所有隊(duì)列，提供了一個(gè)廣播的效果。
• 主題交換機(jī)：根據(jù)路由鍵按模式匹配的投遞到對應(yīng)的隊(duì)列
• 交換機(jī)也具備自己的屬性，可以定義自己的名字，是否持久化等選項(xiàng)。

3.隊(duì)列

• 隊(duì)列是消息的暫存地，至少有一個(gè)消費(fèi)者訂閱了隊(duì)列的話，消息會(huì)立即發(fā)送給這些訂閱的消費(fèi)者，但是如果消息到達(dá)了無人的訂閱隊(duì)列，消息會(huì)在隊(duì)列中等待，等待有了消費(fèi)者便進(jìn)行分發(fā)。
• Exchange和Message Queue之間存在綁定關(guān)系，消息到了Exchange 后基于路由策略可以將消息投遞到已綁定且符合路由策略的Message Queue。
• 消息隊(duì)列會(huì)將消息存儲(chǔ)到內(nèi)存或者是磁盤中，并將這些消息按照一定順序轉(zhuǎn)發(fā)給一個(gè)或多個(gè)消費(fèi)者，每個(gè)消息隊(duì)列都是獨(dú)立隔離的，相互不影響。
• 消息隊(duì)列具有不同的屬性(私有、共享、持久化、臨時(shí)、客戶端定義或者服務(wù)端定義等))，可以基于實(shí)際需求選擇對應(yīng)的類型

4.消息

• 消息是信息的載體，也是AMQP協(xié)議的一個(gè)實(shí)體，消息包含兩部分
• 載荷：就是真正的信息，是你想要傳輸?shù)娜魏蝺?nèi)容，該部分內(nèi)容對消息代理來說是透明的
• 元信息：包含路由鍵、內(nèi)容類型、編碼、是否持久化等消息屬性，會(huì)被消息代理所解析，消息代理根據(jù)消息的屬性對這條消息進(jìn)行投遞，存儲(chǔ)等，這部分被消息代理所關(guān)系，而消費(fèi)者對其是不關(guān)心的。

5.信道

• 網(wǎng)絡(luò)信道，是建立在Connection鏈接之上的一種輕量級(jí)的鏈接，幾乎所有的操作都在Channel中進(jìn)行，Channel是進(jìn)行消息讀寫的通道，客戶端可以建立對各Channel，每個(gè)Channel代表一個(gè)會(huì)話任務(wù)。
• 一個(gè)Connection上可以創(chuàng)建任意數(shù)量的Channel

Docker安裝RabbitMQ

1.查看Docker倉庫里的RabbitMQ鏡像

# 查詢鏡像
docker search rabbitmq
# 下載鏡像
docker pull rabbitmq

2.啟動(dòng)MQ安裝management

如果在云服務(wù)上部署需在安全組開通一下端口：15672(UI頁面通信口)、5672(client端通信口)、25672(server間內(nèi)部通信口)、61613(stomp 消息傳輸)、1883(MQTT消息隊(duì)列遙測傳輸)。

docker run -d --name rabbit -e \
RABBITMQ_DEFAULT_USER=stark -e RABBITMQ_DEFAULT_PASS=1990@stark 
-p 15672:15672 \
-p 5672:5672 \
-p 25672:25672 \
-p 61613:61613 \
-p 1883:1883 rabbitmq:management

使用 http://127.0.0.1:15672訪問，賬號(hào)和密碼就是參數(shù)RABBITMQ_DEFAULT_USER和RABBITMQ_DEFAULT_PASS設(shè)置的值。

以上就是 Docker安裝RabbitMQ、AMQP協(xié)議、和主要角色的詳細(xì)內(nèi)容，更多關(guān)于 Docker安裝RabbitMQ的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論