整合

• • 第一步創建一個springboot的項目
  • fanout模式
  • • 創建fanout的消費者

完整版鏈接點擊= SpringBoot整合RabbotMq完整版

第一步創建一個springboot的項目

創建springboot項目 選好所需要的骨架

編寫yml文件

fanout模式

編寫消費者

@Component public class OrderService {@Autowiredprivate RabbitTemplate rabbitTemplate;public void makeOrder(String userid, String proder, int num){String orderId = UUID.randomUUID().toString();System.out.println("訂單生成成功！！！！！！"+orderId);String jiaohuanji = "jiaohuanji";String luyou = "";rabbitTemplate.convertAndSend(jiaohuanji,luyou,orderId);} }

聲明訂單(綁定-訂單)

//聲明訂單 @Configuration public class RabbitmqConfiguration {@Beanpublic FanoutExchange fanoutExchange() {return new FanoutExchange("jiaohuanji", true, false);}@Beanpublic Queue sQueue() {return new Queue("s.fanout.queue", true);}@Beanpublic Queue duanxingQueue() {return new Queue("duanxing.fanout.queue", true);}@Beanpublic Queue youxiangQueue() {return new Queue("youxiang.fanout.queue", true);}//隊列與交換機綁定@Beanpublic Binding sBingding() {return BindingBuilder.bind(sQueue()).to(fanoutExchange());}@Beanpublic Binding duanxingBingding() {return BindingBuilder.bind(duanxingQueue()).to(fanoutExchange());}@Beanpublic Binding youxiangBingding() {return BindingBuilder.bind(youxiangQueue()).to(fanoutExchange());} }

//測試

@SpringBootTest class SpringBootRabbitmqApplicationTests {@Autowiredprivate OrderService orderService;@Testvoid contextLoads() {orderService.makeOrder("111","111",22);} //到游覽器訪問mq的web界面 看看數據提供了沒 }

創建fanout的消費者

創建一個module- - - 和上面一樣
結構

先把yml文件寫入

在寫消費者
DuanxingConsumer

@RabbitListener(queues = {"duanxing.fanout.queue"}) @Controller public class DuanxingConsumer {@RabbitHandlerpublic void abc(String message){System.out.println("duanxing fanout queue收到的訂單是：----》"+message);} }

sConsumer

@RabbitListener(queues = {"s.fanout.queue"}) @Controller public class sConsumer {@RabbitHandlerpublic void abc(String message){System.out.println("接收的訂單信息是:s fanout queue ----->"+message);} }

YouxiangConsumer

@RabbitListener(queues = {"youxiang.fanout.queue"}) @Controller public class YouxiangConsumer {@RabbitHandlerpublic void reviceMessage(String message){System.out.println("duanxing fanout queue-----接收的訂單信息是:->>"+message);} }

運行消費者的run

總結

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

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