<kbd id="afajh"><form id="afajh"></form></kbd>
<strong id="afajh"><dl id="afajh"></dl></strong>
    <del id="afajh"><form id="afajh"></form></del>
        1. <th id="afajh"><progress id="afajh"></progress></th>
          <b id="afajh"><abbr id="afajh"></abbr></b>
          <th id="afajh"><progress id="afajh"></progress></th>

          SpringCloud項(xiàng)目:實(shí)現(xiàn)推送消息到RabbitMQ消息中間件

          共 3238字,需瀏覽 7分鐘

           ·

          2021-06-21 21:04

          點(diǎn)擊上方 Java學(xué)習(xí)之道,選擇 設(shè)為星標(biāo)

          每天18:30點(diǎn),干貨準(zhǔn)時(shí)奉上!

          來(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)路由鍵。

          -- END --

           | 更多精彩文章 -




             
                    
          加我微信,交個(gè)朋友
                   
          長(zhǎng)按/掃碼添加↑↑↑
                          

          瀏覽 49
          點(diǎn)贊
          評(píng)論
          收藏
          分享

          手機(jī)掃一掃分享

          分享
          舉報(bào)
          評(píng)論
          圖片
          表情
          推薦
          點(diǎn)贊
          評(píng)論
          收藏
          分享

          手機(jī)掃一掃分享

          分享
          舉報(bào)
          <kbd id="afajh"><form id="afajh"></form></kbd>
          <strong id="afajh"><dl id="afajh"></dl></strong>
            <del id="afajh"><form id="afajh"></form></del>
                1. <th id="afajh"><progress id="afajh"></progress></th>
                  <b id="afajh"><abbr id="afajh"></abbr></b>
                  <th id="afajh"><progress id="afajh"></progress></th>
                  免费视频一区 | 狼友视频网 | 亚洲操一操 | 亚洲天堂网视频网站 | 99re4|