實(shí)現(xiàn)推送消息到RabbitMQ消息中間件

一、CRT創(chuàng)建RabbitMQ容器

CRT容器自帶RabbitMQ消息中間件，只需要在CRT中輸入如下命令：

docker run -id --name=tensquare_rabbit -p 5671:5671 -p 5672:5672 -p 4369:4369 -p 15672:15672 -p 25672:25672 rabbitmq:management

注：tensquare_rabbit為RabbitMQ中的名稱，可以改變。網(wǎng)頁啟動(dòng)端口為15672

啟動(dòng)之后，輸入docker ps命令查看是否創(chuàng)建成功

二、登錄RabbitMQ

創(chuàng)建成功之后進(jìn)入網(wǎng)頁，訪問15672端口。

注：安裝在虛擬機(jī)則填虛擬機(jī)地址，否則則為本機(jī)地址

用戶名和密碼都為guest

看到如下頁面則為RabbitMQ安裝登錄成功。

三、依賴注入

導(dǎo)入依賴坐標(biāo)

四、配置yaml文件

配置yaml配置文件

注：host為地址，如果安裝在虛擬機(jī)則為虛擬機(jī)地址，安裝在本機(jī)則本機(jī)地址。port為端口號(hào)，務(wù)必注意的是配置文件里寫的是5672，而網(wǎng)頁訪問的是15672

五、添加業(yè)務(wù)層代碼

這里的業(yè)務(wù)邏輯其實(shí)很簡單。本文的業(yè)務(wù)環(huán)境是用戶訂閱作者，之后作者發(fā)文章，他的粉絲都能夠收到消息中間件發(fā)送的消息。而本文實(shí)現(xiàn)的是，將消息發(fā)送至消息中間件中，后續(xù)文章將介紹如何將消息中間件中的消息發(fā)送給用戶

業(yè)務(wù)層添加rabbit模板

訂閱部分，也就是發(fā)送消息給消息中間件的前提：創(chuàng)建好交換機(jī)，路由鍵，以及隊(duì)列,并且用戶訂閱作者，就相當(dāng)于將隊(duì)列綁定到交換機(jī)上，并且有路由鍵作為關(guān)聯(lián)

實(shí)現(xiàn)以上業(yè)務(wù)邏輯之后，粉絲與作者就已經(jīng)綁定好了，那么當(dāng)作者發(fā)文章之后，程序就像消息中間件發(fā)送消息，因此在作者發(fā)送文章的方法內(nèi)，添加如下代碼即可

六、測試

首先用戶關(guān)注某個(gè)作者，在用作者的賬號(hào)發(fā)送文章。在消息中間件中即可收到發(fā)送的消息