SpringBoot學習(六)—— springboot快速整合RabbitMQ

Rabbit MQ消息隊列

@[toc]

簡介

優(yōu)點

erlang開發(fā),并發(fā)能力強。

社區(qū)活躍秀姐,使用的人多,穩(wěn)定性較強嗜湃。

延時低

缺點

erlang語言開發(fā)的,國內(nèi)精通的不多澜掩,日后定制開發(fā)困難购披。

Rabbit MQ工作模式

1,"Hello World!"模式
在這里插入圖片描述

簡單模式是Rabbit MQ最簡單入門的案例肩榕,其中一個生產(chǎn)者刚陡,一個消費者。無需聲明交換機(其實是有個默認的交換機)点把,聲明完一個隊列以后橘荠,生產(chǎn)者往這里發(fā)送,消費者則監(jiān)聽該隊列郎逃,對消息做出響應。

應用場景:如兩個用戶之間的聊天挺份。

2褒翰,Work queues 模式
在這里插入圖片描述

工作隊列模式在工人之間分配任務(競爭的消費者模式),就是有多個消費者的簡單模式匀泊,多個消費者一起監(jiān)聽該隊列优训,Rabbit MQ 會確保隊列中的某一條消息只會被某一個消費者消費。

應用場景:如多個用戶搶某個訂單(高并發(fā)下爭搶同一個資源的記得考慮加鎖)

3各聘,Publish/Subscribe 模式
在這里插入圖片描述

發(fā)布/訂閱模式一次向許多消費者發(fā)送消息揣非,還是一個生產(chǎn)者多個消費者,但是該模式需要顯示聲明交換機了躲因,將創(chuàng)建的多個隊列與該交換機進行綁定早敬,生產(chǎn)者將消息發(fā)給交換機,由交換機發(fā)給已經(jīng)綁定好的隊列大脉,對應的某隊列的消費者消費該隊列中的信息搞监。

應用場景:群發(fā)某個郵件,推送某條廣告

4镰矿,Routing 模式
在這里插入圖片描述

路由模式是有選擇地接收消息琐驴,還是顯示聲明交換機,將隊列與交換機綁定,由生產(chǎn)者將消息發(fā)給交換機绝淡,由交換機發(fā)給對應的隊列宙刘,由對應的消費者消費信息。但是隊列綁定交換機時需要指定一個routingkey 牢酵,這樣的話悬包,生產(chǎn)者再向生產(chǎn)者發(fā)消息的時候,會判斷具體的 routingkey 值茁帽,并將符合對應 routingkey 值的消息發(fā)送給對應的隊列玉罐。

應用場景:封裝若干類錯誤類型通知

5,Topics 模式
在這里插入圖片描述

主題模式根據(jù)模式(主題)接收消息潘拨,同路由模式一樣吊输,只不過不再是根據(jù)具體的 routingkey 值做判斷,是根據(jù) routingkey 值模糊匹配的铁追。其中季蚂,星號代表多個單詞 , 井號代表一個單詞。

更加詳細的資料可訪問官網(wǎng) : RabbitMQ官網(wǎng)

交換機模式

fanout模式:不處理路由鍵琅束,即沒有 routingkey 值扭屁,很像子網(wǎng)廣播,每臺子網(wǎng)內(nèi)的主機都獲得了一份復制的消息涩禀。

direct模式:處理路由鍵料滥,需要路由鍵匹配才能轉發(fā),即完全匹配上 routingkey 值艾船。

topic模式:處理路由鍵葵腹,需要路由鍵模糊匹配才能轉發(fā),即模糊匹配上 routingkey 值屿岂。

引入RabbitMQ隊列

RabbitMQ 依賴與 erlang 語言践宴,點擊 官網(wǎng)下載鏈接 下載 erlang。

點擊 官網(wǎng)下載鏈接 下載RabbitMQ爷怀。

安裝兩者的時候阻肩,一路默認設置即可。

啟動 RabbitMQ 服務运授,cmd模式下輸入烤惊,進入默認安裝路徑

C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.6.10\sbin

輸入命令

rabbitmq-plugins enable rabbitmq_management

服務啟動成功,如圖所示


在這里插入圖片描述

點擊 http://localhost:15672/ 徒坡,如下圖所示

在這里插入圖片描述
在這里插入圖片描述

pom.xml中新增

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

application.properties中加入

# RabbitMQ
spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
# 并發(fā)消費者的初始化值
spring.rabbitmq.listener.concurrency=10
# 并發(fā)消費者的最大值
spring.rabbitmq.listener.max-concurrency=20
# 每個消費者每次監(jiān)聽時可拉取處理的消息數(shù)量
spring.rabbitmq.listener.prefetch=5

代碼實戰(zhàn)

簡單模式和工作隊列模式?jīng)]有指定交換機撕氧,rabbitMQ的精妙之處不能體現(xiàn)出來,而路由模式和主體模式都有 routingkey 值喇完,故挑其一伦泥,本文以發(fā)布/訂閱模式和路由模式為例剥啤,其余的都可類比。不全寫不脯,是因為這是快速上手使用系列府怯,最短的時間精力明白來龍去脈,才是該系列的宗旨防楷,人類畏懼晦澀冗長的牺丙,喜歡簡短直接的。

新增代碼后的目錄如下所示

在這里插入圖片描述

RabbitConfig.java

package com.example.config;

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


@Configuration
public class RabbitConfig {

    //==============發(fā)布/訂閱模式==============

    //隊列A
    @Bean()
    public Queue queueA() {
        return new Queue("fanoutQueueA");
    }

    //隊列B
    @Bean()
    public Queue queueB() {
        return new Queue("fanoutQueueB");
    }

    //發(fā)布訂閱模式下的 fanout 交換機
    @Bean
    public FanoutExchange fanoutExchange() {
        return new FanoutExchange("fanoutExchange");
    }

    // 把 隊列A 和 fanout交換機 綁定在一起
    @Bean
    public Binding bindingWithQueueA() {
        return BindingBuilder.bind(queueA()).to(fanoutExchange());
    }

    // 把 隊列B 和 fanout交換機 綁定在一起
    @Bean
    public Binding bindingWithQueueB() {
        return BindingBuilder.bind(queueB()).to(fanoutExchange());
    }


    //==============路由模式==============
    //隊列C
    @Bean()
    public Queue queueC() {
        return new Queue("directQueueC");
    }

    //隊列D
    @Bean()
    public Queue queueD() {
        return new Queue("directQueueD");
    }

    //發(fā)布訂閱模式下的 direct 交換機
    @Bean
    public DirectExchange directExchange() {
        return new DirectExchange("directExchange");
    }

    // 把 隊列C 和 direct交換機 綁定在一起
    @Bean
    public Binding bindingWithQueueC() {
        return BindingBuilder.bind(queueC()).to(directExchange()).with("directRoutingkey");
    }

    // 把 隊列B 和 direct交換機 綁定在一起
    @Bean
    public Binding bindingWithQueueD() {
        return BindingBuilder.bind(queueD()).to(directExchange()).with("directRoutingkey");
    }

}

RabbitController.java

package com.example.controller;

import com.example.service.IRabbitProducerService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;

@Controller
@RequestMapping("rabbit")
public class RabbitController {

    @Autowired
    private IRabbitProducerService rabbitProducerService;

    @RequestMapping("/fanout")
    public void fanout() {
        for (int i = 0; i < 5; i++) {
            this.rabbitProducerService.producerFanout("發(fā)布訂閱模式下的第" + i + "條信息");
        }
    }

    @RequestMapping("/direct")
    public void direct() {
        for (int i = 0; i < 5; i++) {
            this.rabbitProducerService.producerDirect("路由模式下的第" + i + "條信息");
        }
    }

}

IRabbitProducerService.java

package com.example.service;

public interface IRabbitProducerService {

    void producerFanout(String message);

    void producerDirect(String message);

}

RabbitProducerServiceIml.java

package com.example.service;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service("rabbitProducerService")
public class RabbitProducerServiceIml implements IRabbitProducerService {

    @Autowired
    RabbitTemplate rabbitTemplate;

    public void producerFanout(String message) {
        rabbitTemplate.convertAndSend("fanoutExchange", null, message);
    }

    public void producerDirect(String message) {
        rabbitTemplate.convertAndSend("directExchange", "directRoutingkey", message);
    }

}

IRabbitConsumerService.java

package com.example.service;

public interface IRabbitConsumerService {

    void consumerFanoutA(String message);

    void consumerFanoutB(String message);

    void consumerDirectC(String message);

    void consumerDirectD(String message);

}

RabbitConsumerServiceIml.java

package com.example.service;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class RabbitConsumerServiceIml implements IRabbitConsumerService {

    @RabbitListener(queues = "fanoutQueueA")
    public void consumerFanoutA(String message) {
        System.out.println("消費者收到隊列A中的消息:" + message);
    }

    @RabbitListener(queues = "fanoutQueueB")
    public void consumerFanoutB(String message) {
        System.out.println("消費者收到隊列B中的消息:" + message);
    }

    @RabbitListener(queues = "routingQueueC")
    public void consumerDirectC(String message) {
        System.out.println("消費者收到隊列C中的消息:" + message);
    }

    @RabbitListener(queues = "routingQueueD")
    public void consumerDirectD(String message) {
        System.out.println("消費者收到隊列D中的消息:" + message);
    }

}

啟動項目后复局,瀏覽器輸入 http://localhost:8080/rabbit/fanout 冲簿,(雖然前臺會報錯,因為這個請求只是觸發(fā)消息的生產(chǎn)亿昏,并沒有對應的界面展示峦剔。生產(chǎn)出來的消息經(jīng)過交換機傳給隊列,消費者則監(jiān)聽隊列角钩,做出對應的響應吝沫。)發(fā)布/訂閱模式下使用 fanout 交換機生產(chǎn)消費消息的效果圖如下所示;

在這里插入圖片描述

瀏覽器輸入 http://localhost:8080/rabbit/direct 递礼,發(fā)路由模式下使用 direct 交換機生產(chǎn)消費消息的效果圖如下所示惨险;

在這里插入圖片描述

注:如果是根據(jù)本文系列文章來的,因為一開始就配置好了spring security脊髓,所以記得將該地址配給所登錄的用戶辫愉。或者開一個超級管理員賬號将硝,可以訪問項目的任意目錄一屋,使用該管理員賬號訪問這些地址。

到這里袋哼,篇幅已經(jīng)很長了,本來想準備寫完死信隊列闸衫,和消息確認機制涛贯。想想這是快速整合上手系列,就把深入的內(nèi)容放到踩坑深入系列蔚出,盡情期待后續(xù)開辟新的系列文章吧弟翘。

?著作權歸作者所有,轉載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市骄酗,隨后出現(xiàn)的幾起案子稀余,更是在濱河造成了極大的恐慌,老刑警劉巖趋翻,帶你破解...
    沈念sama閱讀 219,589評論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件睛琳,死亡現(xiàn)場離奇詭異,居然都是意外死亡,警方通過查閱死者的電腦和手機师骗,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,615評論 3 396
  • 文/潘曉璐 我一進店門历等,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人辟癌,你說我怎么就攤上這事寒屯。” “怎么了黍少?”我有些...
    開封第一講書人閱讀 165,933評論 0 356
  • 文/不壞的土叔 我叫張陵寡夹,是天一觀的道長。 經(jīng)常有香客問我厂置,道長菩掏,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 58,976評論 1 295
  • 正文 為了忘掉前任农渊,我火速辦了婚禮患蹂,結果婚禮上,老公的妹妹穿的比我還像新娘砸紊。我一直安慰自己传于,他們只是感情好,可當我...
    茶點故事閱讀 67,999評論 6 393
  • 文/花漫 我一把揭開白布醉顽。 她就那樣靜靜地躺著沼溜,像睡著了一般。 火紅的嫁衣襯著肌膚如雪游添。 梳的紋絲不亂的頭發(fā)上系草,一...
    開封第一講書人閱讀 51,775評論 1 307
  • 那天,我揣著相機與錄音唆涝,去河邊找鬼找都。 笑死,一個胖子當著我的面吹牛廊酣,可吹牛的內(nèi)容都是我干的能耻。 我是一名探鬼主播,決...
    沈念sama閱讀 40,474評論 3 420
  • 文/蒼蘭香墨 我猛地睜開眼亡驰,長吁一口氣:“原來是場噩夢啊……” “哼晓猛!你這毒婦竟也來了?” 一聲冷哼從身側響起凡辱,我...
    開封第一講書人閱讀 39,359評論 0 276
  • 序言:老撾萬榮一對情侶失蹤戒职,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后透乾,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體洪燥,經(jīng)...
    沈念sama閱讀 45,854評論 1 317
  • 正文 獨居荒郊野嶺守林人離奇死亡磕秤,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,007評論 3 338
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了蚓曼。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片亲澡。...
    茶點故事閱讀 40,146評論 1 351
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖纫版,靈堂內(nèi)的尸體忽然破棺而出床绪,到底是詐尸還是另有隱情,我是刑警寧澤其弊,帶...
    沈念sama閱讀 35,826評論 5 346
  • 正文 年R本政府宣布癞己,位于F島的核電站,受9級特大地震影響梭伐,放射性物質(zhì)發(fā)生泄漏痹雅。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 41,484評論 3 331
  • 文/蒙蒙 一糊识、第九天 我趴在偏房一處隱蔽的房頂上張望绩社。 院中可真熱鬧,春花似錦赂苗、人聲如沸愉耙。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,029評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽朴沿。三九已至,卻和暖如春败砂,著一層夾襖步出監(jiān)牢的瞬間赌渣,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,153評論 1 272
  • 我被黑心中介騙來泰國打工昌犹, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留坚芜,地道東北人。 一個月前我還...
    沈念sama閱讀 48,420評論 3 373
  • 正文 我出身青樓斜姥,卻偏偏與公主長得像货岭,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子疾渴,可洞房花燭夜當晚...
    茶點故事閱讀 45,107評論 2 356

推薦閱讀更多精彩內(nèi)容