SpringBoot使用訊息中介軟體RabbitMQ

2021-08-21 13:33:24 字數 2014 閱讀 8274

首先在docker中安裝rabbitmq,pull 帶有web介面的

docker

pull

rabbitmq

:3-management

5672為客戶端,15672為web介面埠

docker run -d

-p5672:5672

-p15672:15672

--name rabbitmq01 映象id

簡要介紹一下rabbitmq的三個exchange

fanout( 廣播)

繫結queue時,不用設定routkey

發布訊息時,不用設定routkey

direct (點對點,單播)

繫結queue時,設定routkey

發布訊息時,設定routkey,單播

topic

繫結queue時,使用包含* 和#的表示式

#代表乙個或多個單詞

*代表乙個單詞

發布訊息時,繫結queue的表示式中,匹配到的queue 則收到訊息

接下來在springboot專案中使用rabbitmq

在pom.xml中引入依賴

org.springframework.bootgroupid>

spring-boot-starter-amqpartifactid>

dependency>

org.springframework.bootgroupid>

spring-boot-starter-webartifactid>

dependency>

配置

spring.rabbitmq

.host=120.87

.111

.104

spring.rabbitmq

.port=5672

spring.rabbitmq

.username=guest

spring.rabbitmq

.password=guest

開啟註解

@enablerabbit

public

class

public

static

void

main(string args)

}

初始化

@autowired

amqpadmin admin;

//初始化

@test

public

void

test1()

設定messageconverter

@configuration

public

class

rabbitmqconfig

}

進行相關測試

//單播

@test

public

void

test3()

//廣播

@test

public

void

test5()

//topic

@test

public

void

test6()

//接收

@test

public

void

test4()

還可以在service中進行監聽

@service

public

class

userservice

@rabbitlistener(queues = "admin.lhc1")

//自動型別轉化

public

void

receive(user user)

}

spring boot 訊息佇列

org.springframework.boot spring boot starter activemq 2.0.6.release spring.activemq.broker url tcp localhost 16161 預設保持在記憶體中 true 持久化 false spring.act...

Spring Boot 中的redis使用

步驟一 匯入依賴包 org.springframework.boot spring boot starter redis 步驟二 1.單機版 spring.redis.host 192.168.0.111 spring.redis.port 8023在spring boot 的啟動類中開啟redis...

springboot中redis的使用

先引入redis的依賴 開啟註解 cacheable cachenames product key currpage 指定引數作為key 不填預設所有 將結果快取到redis中 快取區名叫product key是快取的鍵 如果不設定key 則預設是以方法的引數為key 在這裡是以頁數和session...