SpringBoot整合RabbitMQ 簡單示例

2021-08-27 08:31:14 字數 1193 閱讀 9952

引入依賴jar包

org.springframework.bootgroupid>

spring-boot-starter-amqpartifactid>

dependency>

引入配置

@configuration

public

class

rabbitconfig

@bean

public queue queue2()

@bean

topicexchange exchange()

@bean

binding bindingexchangemessages(queue queue1, topicexchange exchange)

@bean

binding bindingexchangemessage(queue queue2, topicexchange exchange)

}

這裡做個筆記,rabbitmq是通過交換機給queue發訊息,但是中間還會通過routingkey進行過濾,bindingbuilder.bind(queue2).to(exchange).with(「sanguo.message」) 這句話的意思就是,通過交換機exchange傳送的訊息,滿足routingkey條件的(sanguo.message)會被**到queue2裡面

下面是具體的訊息傳送

@component

public

class hellosender

}

接收端–記得也要引入上面的依賴

@component

@rabbitlistener(queues = "sanguo.message")

public

class

helloreceiver

}

spring.rabbitmq

.host=127.0

.0.1

spring.rabbitmq

.port=5672

spring.rabbitmq

.username=guest

spring.rabbitmq

.password=guest

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...