Rabbitmq的用處以后再說(shuō)。
Rabbitmq的存儲(chǔ)也以后再說(shuō)讼庇。
先上Docker命令绎巨，我只掛載了一個(gè)目錄，可以把消息隊(duì)列的內(nèi)容掛載到本機(jī)上蠕啄，這樣容器重啟數(shù)據(jù)也不會(huì)丟场勤，消息隊(duì)列信息也不會(huì)丟。
sudo docker run -d? -p 5672:5672 -p 15672:15672? -v /你的目錄:/var/lib/rabbitmq/: rabbitmq:management
然后我們?nèi)サ?/p>
https://www.rabbitmq.com/getstarted.html
點(diǎn)擊Topic下的Python查看
其中P是消息生產(chǎn)者歼跟，C是消息消費(fèi)者和媳。
X是交換機(jī)，消息首先來(lái)到交換機(jī)這里哈街。
*.orange.*是key留瞳，根據(jù)消費(fèi)者P傳來(lái)的key，匹配后傳給對(duì)應(yīng)的隊(duì)列Q骚秦，匹配的隊(duì)列可以是一個(gè)她倘、多個(gè)和沒(méi)有。
然后我們打開(kāi)http://localhost:15672/
這是rabbitmq的管理界面作箍，默認(rèn)登錄用戶(hù)密碼為guest/guest硬梁。
我們建了一個(gè)交換機(jī)，叫Java胞得，Type選擇了Topic荧止，Durability這個(gè)選擇了Durable（Durable可以讓你的交換機(jī)一直存在，不然重啟一次就沒(méi)了）阶剑。
我們建立一個(gè)隊(duì)列叫Spring4跃巡，對(duì)應(yīng)的Durability也選擇Durable。
我們點(diǎn)擊Exchanges中的Java牧愁。
然后我們綁定 交換機(jī)和隊(duì)列瓷炮，key為L(zhǎng)aLa.*
我們用python發(fā)送一條消息。
然后我們?nèi)リ?duì)列里看一下這條消息递宅。
然后我們消費(fèi)一下。
然后我們?nèi)eb那看一下。
這個(gè)消息被消費(fèi)了已經(jīng)沒(méi)了办龄。然后消費(fèi)者正常是要返回給Rabbitmq一個(gè)ack表明已經(jīng)消費(fèi)此條消息的烘绽，這個(gè)以后再寫(xiě)，生產(chǎn)者對(duì)應(yīng)也需要發(fā)送一個(gè)標(biāo)志告訴Rabbitmq的俐填，這個(gè)也以后再寫(xiě)安接。
先結(jié)束了。
