當(dāng)前位置：首頁 > 前端技术 > javascript >内容正文

javascript

RabbitMQ整合SpringBoot(web)

發(fā)布時(shí)間：2025/3/15 javascript 16 豆豆

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

一、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 動態(tài)路由訂閱模式@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", "發(fā)送info的key的路由信息");return "testRoute";}//fanout 廣播@GetMapping("/testFanout")@ResponseBodypublic String testFanout() {rabbitTemplate.convertAndSend("logs", "", "Fanout的模型發(fā)送的消息");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";} }

三、回調(diào)層

FanoutCustomer

@Component public class FanoutCustomer {@RabbitListener(bindings = {@QueueBinding(value = @Queue,//創(chuàng)建臨時(shí)隊(duì)列exchange =@Exchange(value = "logs",type = "fanout") //綁定的交換機(jī))})public void receive1(String message){System.out.println("message1 = " + message);}@RabbitListener(bindings = {@QueueBinding(value = @Queue,//創(chuàng)建臨時(shí)隊(duì)列exchange =@Exchange(value = "log",type = "fanout") //綁定的交換機(jī))})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,//創(chuàng)建臨時(shí)隊(duì)列exchange = @Exchange(value = "directs",type = "direct"),//自定交換機(jī)名稱和類型key = {"info","error","warn"})})public void receive1(String message){System.out.println("message1 = " + message);}@RabbitListener(bindings = {@QueueBinding(value = @Queue,//創(chuàng)建臨時(shí)隊(duì)列exchange = @Exchange(value = "directs",type = "direct"),//自定交換機(jī)名稱和類型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 {//一個(gè)消費(fèi)者@RabbitListener(queuesToDeclare = @Queue("work"))public void receive1(String message){System.out.println("message1 = "+message);}//一個(gè)消費(fèi)者@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

總結(jié)

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

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

上一篇： 2021年中国医药营销数字化研究报告
下一篇： Docker安装zookeeper 单节