引入依賴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...