背景：
為了減輕服務(wù)器的壓力，現(xiàn)在原有項(xiàng)目的基礎(chǔ)上集成消息隊(duì)列來異步處理消息!
此項(xiàng)目是企業(yè)真實(shí)需求，項(xiàng)目的代碼屬于線上生產(chǎn)代碼，直接用于生產(chǎn)即可！

此項(xiàng)目采用MQ發(fā)送消息模式為:路由模式，如果對RabbitMQ不熟悉，請學(xué)習(xí)RabbitMQ專欄進(jìn)行相關(guān)知識點(diǎn)的學(xué)習(xí)！遇到問題，可以給我留言！看到后定會(huì)回復(fù)！

文章目錄

• 一、RabbitMQ 路由模式快速入門
• • 1. RabbitMQ 路由模式簡述
  • 2. RabbitMQ 路由符模式圖示
  • 3. MQ角色組成
• 二、SSM集成RabbitMQ
• • 2.1. 引依賴
  • 2.2. 生產(chǎn)者配置文件
  • 2.3. 消費(fèi)者配置文件
  • 2.4. 連接配置文件
  • 2.5. 生產(chǎn)者代碼
  • 2.6 消費(fèi)者
  • 2.7 MQ工具類
• 三、管控臺隊(duì)列綁定交換機(jī)
• • 3.1. 復(fù)制隊(duì)列名稱
  • 3.2. 隊(duì)列綁定交換機(jī)
• 四、驗(yàn)證測試
• • 4.1. 啟動(dòng)項(xiàng)目
  • 4.2. 清空控制臺
  • 4.4. 生產(chǎn)者①請求
  • 4.5. 生產(chǎn)者②請求
• 五、啟動(dòng)RabbitMQ
• • 5.1. 進(jìn)入sbin目錄，雙擊運(yùn)行
  • 5.2. 啟動(dòng)圖示

一、RabbitMQ 路由模式快速入門

1. RabbitMQ 路由模式簡述

生產(chǎn)者申明一個(gè)direct類型交換機(jī)，然后發(fā)送消息到這個(gè)交換機(jī)指定路由鍵。
消費(fèi)者指定消費(fèi)這個(gè)交換機(jī)的這個(gè)路由鍵，即可接收到消息，其他消費(fèi)者收不到。

2. RabbitMQ 路由符模式圖示

3. MQ角色組成

序號說明角色

①	生產(chǎn)者	PRODUCER
②	消費(fèi)者	CONSUMER
③	消息隊(duì)列	QUEUE
④	交換機(jī)	EXCHANGE
⑤	路由routingKey	ROUTINGKEY
⑥	交換機(jī)和隊(duì)列綁定	EXCHANGE和ROUTINGKEY綁定
⑦	消息區(qū)配規(guī)則	區(qū)配一個(gè)詞還是多個(gè)詞

二、SSM集成RabbitMQ

2.1. 引依賴

<!--spring整合rabbitmq--><dependency><groupId>org.springframework.amqp</groupId><artifactId>spring-rabbit</artifactId><version>1.4.0.RELEASE</version></dependency>

2.2. 生產(chǎn)者配置文件

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:rabbit="http://www.springframework.org/schema/rabbit"xsi:schemaLocation="http://www.springframework.org/schema/rabbithttp://www.springframework.org/schema/rabbit/spring-rabbit-1.4.xsdhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-3.1.xsd"><!--生產(chǎn)者者配置如下：--><!-- 定義RabbitMQ的連接工廠 --><rabbit:connection-factory id="connectionFactory"host="${rabbitmq.host}" port="${rabbitmq.port}" username="${rabbitmq.username}"password="${rabbitmq.password}" virtual-host="${rabbitmq.vhost}"/><!-- 管理消息隊(duì)列 --><rabbit:admin connection-factory="connectionFactory"/><!-- 定義交換機(jī) 自動(dòng)聲明--><rabbit:direct-exchange name="ORDER-TRACE-EXCHANGE"auto-declare="true" durable="true"/><!-- 定義MQ消息模板 --><rabbit:template id="rabbitTemplate"connection-factory="connectionFactory" exchange="ORDER-TRACE-EXCHANGE"/> </beans>

2.3. 消費(fèi)者配置文件

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:rabbit="http://www.springframework.org/schema/rabbit"xsi:schemaLocation="http://www.springframework.org/schema/rabbithttp://www.springframework.org/schema/rabbit/spring-rabbit-1.4.xsdhttp://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-3.1.xsd"><!--消費(fèi)者配置如下：--><!-- 定義RabbitMQ的連接工廠 --><rabbit:connection-factory id="connectionFactory"host="${rabbitmq.host}" port="${rabbitmq.port}" username="${rabbitmq.username}"password="${rabbitmq.password}" virtual-host="${rabbitmq.vhost}"/><!-- 管理消息隊(duì)列 --><rabbit:admin connection-factory="connectionFactory"/><!-- 定義一個(gè)隊(duì)列或者多個(gè)隊(duì)列 --><rabbit:queue name="ORDER-MENU-CATEGORY-QUEUE" auto-declare="true" durable="true"/><!-- 聲明多個(gè)消費(fèi)者對象 --><bean id="mQSimpleMsgHandler" class="com.gblfy.order.mqhandler.MQSimpleMsgHandler"/><!-- 監(jiān)聽隊(duì)列 --><rabbit:listener-container connection-factory="connectionFactory"><rabbit:listener ref="mQSimpleMsgHandler" method="execute" queue-names="ORDER-MENU-CATEGORY-QUEUE"/></rabbit:listener-container> </beans>

2.4. 連接配置文件

rabbitmq.host=127.0.0.1 rabbitmq.port=5672 rabbitmq.username=admin rabbitmq.password=admin rabbitmq.vhost=/admin

2.5. 生產(chǎn)者代碼

package com.gblfy.order.controller;import com.gblfy.order.utils.MQSendMsgUtils; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.ResponseBody;import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.Date;@Controller @Slf4j public class SimpleMQMsgSendController {@Autowiredprivate MQSendMsgUtils mqSendMsgUtils;@RequestMapping(value = "/sendSimpleMQMsg", method = RequestMethod.GET)@ResponseBodypublic String snedSimpleMQMsg() {/*** 模擬發(fā)送數(shù)據(jù)* 1. serviceName 接口名稱* 2. type 路由routingKey*/String serviceName = "my name serviceName";String type = "menu";//發(fā)送消息到MQ的交換機(jī)，通知其他系統(tǒng)mqSendMsgUtils.sendMsg(serviceName, type);return "snedSimpleMQMsg success !!!";}@RequestMapping(value = "/sendSimpleMQMsg2", method = RequestMethod.GET)@ResponseBodypublic String snedSimpleMQMsg2() {/*** 模擬發(fā)送數(shù)據(jù)* 1. serviceName 接口名稱* 2. type 路由routingKey*/String serviceName = "my name serviceName2";String type = "category";//發(fā)送消息到MQ的交換機(jī)，通知其他系統(tǒng)mqSendMsgUtils.sendMsg(serviceName, type);return "snedSimpleMQMsg success !!!";}public static void main(String[] args) {DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");System.out.println(dateFormat.format(new Date()));} }

2.6 消費(fèi)者

package com.gblfy.order.mqhandler;import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import lombok.extern.slf4j.Slf4j;@Slf4j public class MQSimpleMsgHandler {private static final ObjectMapper MAPPER = new ObjectMapper();/*** 接收MQ消息** @param msg*/public void execute(String msg) {try {JsonNode jsonNode = MAPPER.readTree(msg);String serviceName = jsonNode.get("serviceName").asText();String routingKey = jsonNode.get("routingKey").asText();String currentDate = jsonNode.get("currentDate").asText();log.info("接口名稱:" + serviceName);log.info("路由routingKey:" + routingKey);log.info("當(dāng)前時(shí)間:" + currentDate);} catch (Exception e) {e.printStackTrace();}} }

2.7 MQ工具類

package com.gblfy.order.utils;import com.alibaba.fastjson.JSON; import com.fasterxml.jackson.databind.ObjectMapper; import com.gblfy.order.pojo.FisCallingTrace; import com.gblfy.order.pojo.RequestInfo; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component;import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.Date; import java.util.HashMap; import java.util.Map;/*** MQ發(fā)送消息公用工具類* <p>* MQ發(fā)送消息模式采用 通配符模式* order.* 區(qū)配一個(gè)詞* order.# 區(qū)配一個(gè)或者多個(gè)詞* <p>** @author gblfy*/ @Component @Slf4j public class MQSendMsgUtils {//格式化時(shí)間public static final DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");// 日期格式//引入json工具類private static final ObjectMapper MAPPER = new ObjectMapper();@Autowired//注入發(fā)送消息模板private RabbitTemplate rabbitTemplate;/*** 發(fā)送MQ消息公用類** @param mFisCallingTrace 軌跡保存的數(shù)據(jù)對象* @param type 路由routingKey 字符串拼接* @param reqXml 請求報(bào)文* @param resXml 響應(yīng)報(bào)文* @param uuid 隨機(jī)生成的uuid*/public void sendMsg(FisCallingTrace mFisCallingTrace, String type, String reqXml, String resXml, String uuid) {try {RequestInfo requestInfo = new RequestInfo().builder().fisCallingTrace(mFisCallingTrace).mReqXml(reqXml).mResXml(resXml).mUUID(uuid).serviceName(mFisCallingTrace.getServicename()).type(type).build();//發(fā)送消息到MQ的交換機(jī)，通知其他系統(tǒng)String jsonStr = JSON.toJSONString(requestInfo);rabbitTemplate.convertAndSend("order." + type, jsonStr);} catch (Exception e) {e.printStackTrace();}}/*** 發(fā)送MQ消息公用類** @param serviceName 接口名稱* @param type 路由routingKey*/public void sendMsg(String serviceName, String type) {try {//發(fā)送消息到MQ的交換機(jī)，通知其他系統(tǒng)Map<String, Object> msg = new HashMap<String, Object>();msg.put("serviceName", serviceName);msg.put("routingKey", type);msg.put("currentDate", dateFormat.format(new Date()));rabbitTemplate.convertAndSend("order." + type, MAPPER.writeValueAsString(msg));} catch (Exception e) {e.printStackTrace();}}// public static void main(String[] args) { // //使用fastjson 實(shí)體類對象轉(zhuǎn)jsonStr // User ly = new User().builder() // .id(1) // .name("ly") // .build(); // String jsonStr = JSON.toJSONString(ly); // log.info("轉(zhuǎn)換后jsonStr的用戶:" + jsonStr); // // //使用fastjson 進(jìn)行jsonObject轉(zhuǎn)實(shí)體類對象 // String userString = "{\"id\":1,\"name\":\"ly\"}"; // // JSONObject userJson = JSONObject.parseObject(userString); // User user = JSON.toJavaObject(userJson, User.class); // // log.info("用戶姓名:" + user.getName()); // log.info("用戶ID:" + user.getId()); // } }

三、管控臺隊(duì)列綁定交換機(jī)

3.1. 復(fù)制隊(duì)列名稱

3.2. 隊(duì)列綁定交換機(jī)

點(diǎn)擊聲明的交換機(jī)

配置文件中聲明的交換機(jī)

在交換機(jī)中綁定【ORDER-MENU-CATEGORY-QUEUE】隊(duì)列和路由key(order.category)

在交換機(jī)中綁定【ORDER-MENU-CATEGORY-QUEUE】隊(duì)列和路由key(order.menu)

在交換機(jī)菜單中查看，綁定的隊(duì)列

在隊(duì)列菜單中查看，綁定的交換機(jī)

四、驗(yàn)證測試

4.1. 啟動(dòng)項(xiàng)目

4.2. 清空控制臺

4.4. 生產(chǎn)者①請求

http://localhost:8888/sendSimpleMQMsg

4.5. 生產(chǎn)者②請求

http://localhost:8888/sendSimpleMQMsg2

五、啟動(dòng)RabbitMQ

5.1. 進(jìn)入sbin目錄，雙擊運(yùn)行

5.2. 啟動(dòng)圖示

總結(jié)

以上是生活随笔為你收集整理的（需求实战_进阶_01）SSM集成RabbitMQ 关键代码讲解、开发、测试的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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