當前位置：首頁 > 前端技术 > javascript >内容正文

javascript

RabbitMQ整合SpringBoot(web)

發布時間：2025/3/15 javascript 25 豆豆

生活随笔收集整理的這篇文章主要介紹了 RabbitMQ整合SpringBoot(web) 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

一、index.html

<!DOCTYPE html> <html lang="en"> <head><meta charset="UTF-8"><title>Title</title> </head> <body> <a href="/testFanout">testFanout</a> <a href="/testHello">testHello</a> <a href="/testRoute">testRoute</a> <a href="/testTopic">testTopic</a> <a href="/testWork">testWork</a> </body> </html>

二、controller

@RestController public class MyController {//注入rabbitTemplate@Autowiredprivate RabbitTemplate rabbitTemplate;//topic 動態路由訂閱模式@GetMapping("/testTopic")@ResponseBodypublic String testTopic() {rabbitTemplate.convertAndSend("topics", "product.save.add", "produce.save.add 路由消息");return "testTopic";}//route 路由模式@GetMapping("/testRoute")@ResponseBodypublic String testRoute() {rabbitTemplate.convertAndSend("directs", "error", "發送info的key的路由信息");return "testRoute";}//fanout 廣播@GetMapping("/testFanout")@ResponseBodypublic String testFanout() {rabbitTemplate.convertAndSend("logs", "", "Fanout的模型發送的消息");return "testFanout";}//work@GetMapping("/testWork")@ResponseBodypublic String testWork() {for (int i = 0; i < 10; i++) {rabbitTemplate.convertAndSend("work", "work模型" + i);}return "testWork";}//hello world@GetMapping("/testHello")@ResponseBodypublic String testHello() {rabbitTemplate.convertAndSend("hello", "hello world");return "testHello";} }

三、回調層

FanoutCustomer

@Component public class FanoutCustomer {@RabbitListener(bindings = {@QueueBinding(value = @Queue,//創建臨時隊列exchange =@Exchange(value = "logs",type = "fanout") //綁定的交換機)})public void receive1(String message){System.out.println("message1 = " + message);}@RabbitListener(bindings = {@QueueBinding(value = @Queue,//創建臨時隊列exchange =@Exchange(value = "log",type = "fanout") //綁定的交換機)})public void receive2(String message){System.out.println("message2 = " + message);} }

HelloCustomer

@Component @RabbitListener(queuesToDeclare = @Queue(value = "hello")) public class HelloCustomer {@RabbitHandlerpublic void receive1(String message){System.out.println("message = " + message);} }

RouteCustomer

@Component public class RouteCustomer {@RabbitListener(bindings = {@QueueBinding(value = @Queue,//創建臨時隊列exchange = @Exchange(value = "directs",type = "direct"),//自定交換機名稱和類型key = {"info","error","warn"})})public void receive1(String message){System.out.println("message1 = " + message);}@RabbitListener(bindings = {@QueueBinding(value = @Queue,//創建臨時隊列exchange = @Exchange(value = "directs",type = "direct"),//自定交換機名稱和類型key = {"error",})})public void receive2(String message){System.out.println("message2 = " + message);} }

TopicCustomer

@Component public class TopicCustomer {@RabbitListener(bindings = {@QueueBinding(value = @Queue,exchange = @Exchange(type = "topic",name="topics"),key={"user.save","user.*"})})public void receive1(String message){System.out.println("message1 = " + message);}@RabbitListener(bindings = {@QueueBinding(value = @Queue,exchange = @Exchange(type = "topic",name="topics"),key={"order.#","product.#","user.*"})})public void receive2(String message){System.out.println("message2 = " + message);} } @Component public class WorkCustomer {//一個消費者@RabbitListener(queuesToDeclare = @Queue("work"))public void receive1(String message){System.out.println("message1 = "+message);}//一個消費者@RabbitListener(queuesToDeclare = @Queue("work"))public void receive2(String message){System.out.println("message2 = "+message);} }

四、yml

spring:application:name: rabbitmq-springbootrabbitmq:host:x.x.x.xport: 5672username: emspassword: 123virtual-host: /ems

總結

以上是生活随笔為你收集整理的RabbitMQ整合SpringBoot(web)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇： 2021年中国医药营销数字化研究报告
下一篇： Spring Ioc 之 Bean的加载

日韩av黄I国产麻豆传媒I国产91av视频在线观看I日韩一区二区三区在线看I美女国产在线I麻豆视频国产在线观看I成人黄色短片

javascript

RabbitMQ整合SpringBoot(web)

一、index.html

二、controller

三、回調層

四、yml

總結

一、index.html

三、回調層

四、yml