springboot整合rabbitmq入門 二

今天繼續介紹一種rabbitmq的模式-topic模式

建立queue和exchange

@configuration

public class topicrabbitconfig 
@bean
public queue topicb()
@bean
public topicexchange topicexchange()
@bean
binding bindtopica(queue topica, topicexchange topicexchange)
//*表示乙個詞,#表示零個或多個詞
/***
* @param topicb
* @param topicexchange
* *表示乙個詞,#表示零個或多個詞
* @return
*/@bean
binding bindtopicb (queue topicb, topicexchange topicexchange)
}

topic.*和topic.#區別是：topic.*表示只能監聽到topic.***的訊息，而不能監聽到topic.***.***的訊息

傳送端：

@component

public class topicsend 
}

@component

@rabbitlistener(queues = "topica")
public class topicreceivea 
}

@component

@rabbitlistener(queues = "topicb")
public class topicreceiveb 
}

我們吧routingkey改為topic.message，會發現a和b兩個消費端都可以接受到訊息

SpringBoot使用訊息中介軟體RabbitMQ

首先在docker中安裝rabbitmq,pull 帶有web介面的 docker pull rabbitmq 3 management5672為客戶端,15672為web介面埠 docker run d p5672 5672 p15672 15672 name rabbitmq01 映象id簡要介...

springBoot整合dubbo整合專案

傳統spring 整合dubbo，需要繁瑣的編寫一堆堆的 xml 配置檔案 而springboot整合dubbo後，不在需要寫 xml,通過jar包引用，完 成整合，通過註解的形式完成配置。提高我們的開發效率 目錄結構 1 服務層生產者開發 hs ldm server service 1.1新增du...

SpringBoot整合系列 整合Swagger2

io.springfox springfox swagger2 2.7.0 io.springfox springfox swagger ui 2.7.0 一般無配置項，必要時可以新增自定義配置項，在配置類中讀取 swagger2的配置內容僅僅就是需要建立乙個docket例項 configurati...