目錄

• SpringBoot中使用RabbitMQ
• • 搭建初始環(huán)境
  • • 引入依賴
    • 配置配置文件
    • 測(cè)試類 注入 rabbitTemplate
  • 消息隊(duì)列RabbitMQ之五種消息模型
  • • 第一種直連模型使用
    • • 開發(fā)生產(chǎn)者
      • 開發(fā)消費(fèi)者
    • 第二種work模型使用
    • • 開發(fā)生產(chǎn)者
      • 開發(fā)消費(fèi)者
    • 第三種 Fanout 廣播模型
    • • 開發(fā)生產(chǎn)者
      • 開發(fā)消費(fèi)者
    • 第四種 Route 路由模型
    • • 開發(fā)生產(chǎn)者
      • 開發(fā)消費(fèi)者
    • 第五種 Topic 訂閱模型(動(dòng)態(tài)路由模型)
    • • 開發(fā)生產(chǎn)者
      • 開發(fā)消費(fèi)者

SpringBoot中使用RabbitMQ

搭建初始環(huán)境

引入依賴

<!-- 引入 rabbitmq 集成依賴 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>

配置配置文件

server:port: 9090spring:application:# 微服務(wù)系統(tǒng)有意義, 養(yǎng)成好習(xí)慣, 先寫出來(lái)name: rabbitmq-02-springbootrabbitmq:host: 127.0.0.1port: 5672username: codingcepassword: 123456virtual-host: /codingce

測(cè)試類 注入 rabbitTemplate

// 注入 rabbitTemplate@Autowiredprivate RabbitTemplate rabbitTemplate;

消息隊(duì)列RabbitMQ之五種消息模型

第一種直連模型使用

開發(fā)生產(chǎn)者

/*** 直連*/@Testvoid contextLoads() {rabbitTemplate.convertAndSend("hello", "hello word");}

開發(fā)消費(fèi)者

/*** @author mxz*/ @Component @RabbitListener(queuesToDeclare = @Queue("hello")) public class HelloCustomer {/*** @param message*/@RabbitHandlerpublic void receivel(String message) {System.out.println("message: " + message);}}

第二種work模型使用

開發(fā)生產(chǎn)者

/*** work*/@Testvoid testWork() {for (int i = 0; i < 10; i++) {rabbitTemplate.convertAndSend("work", "work模型");}}

開發(fā)消費(fèi)者

/*** 第二種模型 work 模型** @author mxz*/ @Component public class WorkCustomer {/*** 第1個(gè)消費(fèi)者** @param message*/@RabbitListener(queuesToDeclare = @Queue("work"))public void receivel(String message) {System.out.println("message1 = " + message);}/*** 第2個(gè)消費(fèi)者** @param message*/@RabbitListener(queuesToDeclare = @Queue("work"))public void receivel2(String message) {System.out.println("message2 = " + message);} }

第三種 Fanout 廣播模型

開發(fā)生產(chǎn)者

/*** fanout 廣播*/@Testvoid testFanout() {rabbitTemplate.convertAndSend("logs", "", "Fanout模型發(fā)送的消息");}

開發(fā)消費(fèi)者

/*** fanout** @author mxz*/ @Component public class FanoutCustomer {@RabbitListener(bindings = {@QueueBinding(value = @Queue, // 創(chuàng)建臨時(shí)隊(duì)列exchange = @Exchange(value = "logs", type = "fanout") // 綁定的交換機(jī))})public void receivel(String message) {System.out.println("message1 = " + message);}@RabbitListener(bindings = {@QueueBinding(value = @Queue, // 創(chuàng)建臨時(shí)隊(duì)列exchange = @Exchange(value = "logs", type = "fanout") // 綁定的交換機(jī))})public void receive2(String message) {System.out.println("message2 = " + message);} }

第四種 Route 路由模型

開發(fā)生產(chǎn)者

/*** route 路由*/@Testvoid testRoute() {// exchange 交換機(jī)名稱rabbitTemplate.convertAndSend("directs", "info", "info的key的路由消息");}

開發(fā)消費(fèi)者

/*** @author mxz*/ @Component public class RouteCustomer {@RabbitListener(bindings = {@QueueBinding(value = @Queue, // 綁定臨時(shí)隊(duì)列exchange = @Exchange(value = "directs", type = "direct"), // 自定義交換機(jī)名稱和類型key = {"info", "error", "warn"})})public void receivel(String message) {System.out.println("message1 = " + message);}@RabbitListener(bindings = {@QueueBinding(value = @Queue, // 綁定臨時(shí)隊(duì)列exchange = @Exchange(value = "directs", type = "direct"), // 自定義交換機(jī)名稱和類型key = {"error"})})public void receivel2(String message) {System.out.println("message1 = " + message);}}

第五種 Topic 訂閱模型(動(dòng)態(tài)路由模型)

開發(fā)生產(chǎn)者

/*** topic 訂閱模式 動(dòng)態(tài)路由*/@Testvoid testTopic() {rabbitTemplate.convertAndSend("topics", "user.save", "user.save 路由消息");}

開發(fā)消費(fèi)者

/*** 訂閱模型** @author mxz*/ @Component public class TopicCustomer {@RabbitListener(bindings = {@QueueBinding(value = @Queue,exchange = @Exchange(type = "topic", name = "topics"),key = {"user.save", "user.*"})})public void receivel(String message) {System.out.println("message1" + message);}@RabbitListener(bindings = {@QueueBinding(value = @Queue,exchange = @Exchange(type = "topic", name = "topics"),key = {"produce.#", "order.#"})})public void receivel2(String message) {System.out.println("message2" + message);} }

文章已上傳gitee https://gitee.com/codingce/hexo-blog
項(xiàng)目地址github: https://github.com/xzMhehe/codingce-java

總結(jié)

以上是生活随笔為你收集整理的SpringBoot整合RabbitMQ 实现五种消息模型的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。