Springboot集成RabbitMQ并驗證五種消息模型
更新時間:2024年03月08日 09:18:52 作者:道法自然 實事求是
RabbitMQ 提供了5種常用消息模型,本文主要介紹了Springboot集成RabbitMQ并驗證五種消息模型,具有一定的參考價值,感興趣的可以了解一下
一、添加依賴
<!--AMQP依賴,包含RabbitMQ--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <!-- 引入knife4j-spring-ui包 /doc.html--> <dependency> <groupId>com.github.xiaoymin</groupId> <artifactId>knife4j-spring-boot-starter</artifactId> <version>3.0.3</version> </dependency>
二、配置文件中添加RabbitMQ訪問配置
spring.rabbitmq.host=192.168.0.104 spring.rabbitmq.port=5672 spring.rabbitmq.virtual-host=/ spring.rabbitmq.username=admin spring.rabbitmq.password=admin123
三、消息生產(chǎn)者代碼
import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RestController; @Api(tags = "生產(chǎn)者服務(wù)") @RestController public class ProducerController { @Autowired private RabbitTemplate rabbitTemplate; @ApiOperation(value = "基本消息模型") @PostMapping("/testHello") public String testHello() { rabbitTemplate.convertAndSend("hello","hello world"); return "ok"; } @ApiOperation(value = "work消息模型") @PostMapping("/testWork") public String testWork() { for (int i = 0; i < 10; i++) { rabbitTemplate.convertAndSend("work","hello work!"); } return "ok"; } @ApiOperation(value = "訂閱模型-Fanout 廣播模式") @PostMapping("/testFanout") public String testFanout() { rabbitTemplate.convertAndSend("logs","","這是日志廣播"); return "ok"; } @ApiOperation(value = "訂閱模型-Direct") @PostMapping("/testDirect") public String testDirect() { rabbitTemplate.convertAndSend("directs","error","error 的日志信息"); return "ok"; } @ApiOperation(value = "訂閱模型-Topic") @PostMapping("/testTopic") public String testTopic() { rabbitTemplate.convertAndSend("topics","user.save.findAll","user.save.findAll 的消息"); return "ok"; } }
四、消息消費者代碼
import org.springframework.amqp.rabbit.annotation.Exchange; import org.springframework.amqp.rabbit.annotation.Queue; import org.springframework.amqp.rabbit.annotation.QueueBinding; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; @Component public class SpringRabbitListener { //基本消息模型 @RabbitListener(queuesToDeclare = @Queue("hello")) public void receive(String message) { System.out.println("message = " + message); } //work消息模型 @RabbitListener(queuesToDeclare = @Queue("work")) public void workReceive1(String message) { System.out.println("workReceive1 message = " + message); } //work消息模型 @RabbitListener(queuesToDeclare = @Queue("work")) public void workReceive2(String message) { System.out.println("workReceive2 message = " + message); } //訂閱模型-Fanout 廣播模式 @RabbitListener(bindings = @QueueBinding(value = @Queue, exchange = @Exchange(name="logs",type = "fanout"))) public void fanoutReceive(String message) { System.out.println("fanoutReceive message = " + message); } //訂閱模型-Direct @RabbitListener(bindings ={@QueueBinding(value = @Queue(),key={"info","error"},exchange = @Exchange(type = "direct",name="directs"))}) public void directReceive(String message) { System.out.println("directReceive message = " + message); } //訂閱模型-Topic @RabbitListener(bindings = {@QueueBinding( value = @Queue,key = {"user.*"},exchange = @Exchange(type = "topic",name = "topics"))}) public void topicReceive1(String message) { System.out.println("topicReceive1 message = " + message); } //訂閱模型-Topic @RabbitListener(bindings = {@QueueBinding(value = @Queue,key = {"user.#"},exchange = @Exchange(type = "topic",name = "topics"))}) public void topicReceive2(String message) { System.out.println("topicReceive2 message = " + message); } }
五、驗證
瀏覽器輸入:ip:8080/doc.html 對接口逐個進行測試
參考資料
到此這篇關(guān)于Springboot集成RabbitMQ并驗證五種消息模型的文章就介紹到這了,更多相關(guān)Springboot RabbitMQ驗證消息模型內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
GraalVM和Spring Native嘗鮮一步步讓Springboot啟動飛起來66ms完成啟動
GraalVM是高性能的JDK,支持Java/Python/JavaScript等語言,它可以讓Java變成二進制文件來執(zhí)行,讓程序在任何地方運行更快,這篇文章主要介紹了GraalVM和Spring Native嘗鮮一步步讓Springboot啟動飛起來66ms完成啟動,需要的朋友可以參考下2023-02-02Spring?Boot虛擬線程Webflux在JWT驗證和MySQL查詢性能比較
這篇文章主要為大家介紹了Spring Boot虛擬線程與Webflux在JWT驗證和MySQL查詢上的性能比較,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-09-09SpringBoot實現(xiàn)Tomcat集群的會話管理功能
在使用 Tomcat 集群時,由于每個 Tomcat 實例的 Session 存儲是獨立的,導(dǎo)致無法實現(xiàn) Session 的共享,這可能影響到用戶跨節(jié)點的訪問,為了實現(xiàn)跨 Tomcat 實例共享 Session,可以使用 Spring Session 配合 Redis 進行集中式會話管理,需要的朋友可以參考下2024-12-12解決idea啟動報錯javax.imageio.IIOException的問題
這篇文章主要介紹了idea啟動報錯javax.imageio.IIOException,解決打不開idea問題,本文通過圖文并茂的形式給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-09-09