From 133695076fbde70f807ba85e8b041840f4ce57cf Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期四, 19 六月 2025 16:55:52 +0800
Subject: [PATCH] Merge branch 'dev' of http://120.76.84.145:10101/gitblit/r/java/mx_charging_pile
---
ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/util/RocketMQEnhanceTemplate.java | 23 +++++++++++++++++++++--
1 files changed, 21 insertions(+), 2 deletions(-)
diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/util/RocketMQEnhanceTemplate.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/util/RocketMQEnhanceTemplate.java
index f54f22e..b6a1141 100644
--- a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/util/RocketMQEnhanceTemplate.java
+++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/rocket/util/RocketMQEnhanceTemplate.java
@@ -56,7 +56,13 @@
// 注意分隔符
return send(buildDestination(topic,tag), message);
}
-
+ /**
+ * 发送异步消息
+ */
+ public <T extends BaseMessage> void sendAsynchronous(String topic, String tag, T message) {
+ // 注意分隔符
+ sendAsynchronous(buildDestination(topic,tag), message);
+ }
public <T extends BaseMessage> SendResult send(String destination, T message) {
// 设置业务键，此处根据公共的参数进行处理
@@ -64,9 +70,22 @@
Message<T> sendMessage = MessageBuilder.withPayload(message).setHeader(RocketMQHeaders.TAGS, message.getKey()).build();
SendResult sendResult = template.syncSend(destination, sendMessage);
// 此处为了方便查看给日志转了json，根据选择选择日志记录方式，例如ELK采集
- log.info("[{}]同步消息[{}]发送结果[{}]", destination, JSONObject.toJSON(message), JSONObject.toJSON(sendResult));
+ log.info("[{}]同步消息[{}]---->发送结果[{}]", destination, JSONObject.toJSON(message), JSONObject.toJSON(sendResult));
return sendResult;
}
+
+ public <T extends BaseMessage> void sendAsynchronous(String destination, T message) {
+ try {
+ // 设置业务键，此处根据公共的参数进行处理
+ // 更多的其它基础业务处理...
+ Message<T> sendMessage = MessageBuilder.withPayload(message).setHeader(RocketMQHeaders.TAGS, message.getKey()).build();
+ template.send(destination, sendMessage);
+ // 此处为了方便查看给日志转了json，根据选择选择日志记录方式，例如ELK采集
+ log.info("[{}]异步消息[{}]", destination, JSONObject.toJSON(message));
+ }catch (Exception e){
+ e.printStackTrace();
+ }
+ }
/**
* 发送延迟消息
--
Gitblit v1.7.1