SpringCloud項(xiàng)目:實(shí)現(xiàn)推送消息到RabbitMQ消息中間件
點(diǎn)擊上方 Java學(xué)習(xí)之道,選擇 設(shè)為星標(biāo)
來(lái)源: blog.csdn.net/yt812100/article/details/111785839
作者: 楊桃桃
Part1CRT創(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中的名稱(chēng),可以改變。網(wǎng)頁(yè)啟動(dòng)端口為15672)
啟動(dòng)之后,輸入docker ps命令查看是否創(chuàng)建成功
Part2登錄RabbitMQ
創(chuàng)建成功之后進(jìn)入網(wǎng)頁(yè),訪問(wèn)15672端口。(注:安裝在虛擬機(jī)則填虛擬機(jī)地址,否則則為本機(jī)地址)
用戶(hù)名和密碼都為guest
看到如下頁(yè)面則為RabbitMQ安裝登錄成功。
Part3依賴(lài)注入
導(dǎo)入依賴(lài)坐標(biāo)
Part4配置yaml文件
配置yaml配置文件 (注:host為地址,如果安裝在虛擬機(jī)則為虛擬機(jī)地址,安裝在本機(jī)則本機(jī)地址。port為端口號(hào),務(wù)必注意的是配置文件里寫(xiě)的是5672,而網(wǎng)頁(yè)訪問(wèn)的是15672)
Part5添加業(yè)務(wù)層代碼
這里的業(yè)務(wù)邏輯其實(shí)很簡(jiǎn)單。本文的業(yè)務(wù)環(huán)境是用戶(hù)訂閱作者,之后作者發(fā)文章,他的粉絲都能夠收到消息中間件發(fā)送的消息。而本文實(shí)現(xiàn)的是,將消息發(fā)送至消息中間件中,后續(xù)文章將介紹如何將消息中間件中的消息發(fā)送給用戶(hù)
業(yè)務(wù)層添加rabbit模板
訂閱部分,也就是發(fā)送消息給消息中間件的前提:創(chuàng)建好交換機(jī),路由鍵,以及隊(duì)列,并且用戶(hù)訂閱作者,就相當(dāng)于將隊(duì)列綁定到交換機(jī)上,并且有路由鍵作為關(guān)聯(lián)
實(shí)現(xiàn)以上業(yè)務(wù)邏輯之后,粉絲與作者就已經(jīng)綁定好了,那么當(dāng)作者發(fā)文章之后,程序就像消息中間件發(fā)送消息,因此在作者發(fā)送文章的方法內(nèi),添加如下代碼即可
Part6測(cè)試
首先用戶(hù)關(guān)注某個(gè)作者,在用作者的賬號(hào)發(fā)送文章。在消息中間件中即可收到發(fā)送的消息
結(jié)語(yǔ):此處難點(diǎn)為發(fā)送消息之前需要先創(chuàng)建交換機(jī),之后將隊(duì)列綁定給交換機(jī),并且關(guān)聯(lián)路由鍵。
-
| 更多精彩文章 -
▽加我微信,交個(gè)朋友 長(zhǎng)按/掃碼添加↑↑↑


