From 47e3087067abd35e6337c011f96d2338c0bb1aae Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 25 七月 2024 13:39:31 +0800
Subject: [PATCH] 优化自动化代码
---
src/main/java/org/yeshi/utils/mq/TDMQUtil.java | 82 +++++++++++++++++++++++++----------------
1 files changed, 50 insertions(+), 32 deletions(-)
diff --git a/src/main/java/org/yeshi/utils/mq/TDMQUtil.java b/src/main/java/org/yeshi/utils/mq/TDMQUtil.java
index 11902f3..92b42bc 100644
--- a/src/main/java/org/yeshi/utils/mq/TDMQUtil.java
+++ b/src/main/java/org/yeshi/utils/mq/TDMQUtil.java
@@ -2,6 +2,8 @@
import com.qcloud.cmq.Account;
import com.qcloud.cmq.Message;
+import com.qcloud.cmq.Queue;
+import com.qcloud.cmq.entity.CmqResponse;
import com.tencentcloudapi.common.Credential;
import com.tencentcloudapi.common.exception.TencentCloudSDKException;
import com.tencentcloudapi.common.profile.ClientProfile;
@@ -10,6 +12,7 @@
import com.tencentcloudapi.tdmq.v20200217.models.*;
import java.util.Arrays;
+import java.util.Date;
import java.util.List;
//鑵捐CMQ娑堟伅
@@ -204,6 +207,21 @@
public String sendMsg(String queueName, String msg) {
return this.sendMsg(queueName, msg, 0L);
+ }
+
+ // 鍙戦�佹秷鎭�
+ public List<CmqResponse> batchSendMsg(String queueName, List<String> msgList, long delaySeconds) throws Exception {
+ Queue queue = account.getQueue(queueName);
+ if (delaySeconds > 0) {
+ return queue.batchSend(msgList, (int) delaySeconds);
+ } else {
+ return queue.batchSend(msgList);
+ }
+ }
+
+ // 鍙戦�佹秷鎭�
+ public List<CmqResponse> batchSendMsg(String queueName, List<String> msgList) throws Exception {
+ return batchSendMsg(queueName, msgList, 0);
}
@@ -451,32 +469,32 @@
public static void main(String[] args) {
TDMQUtil.getInstance().init("AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25", "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo", true);
- String queueName = "test1";
- String topicName = "topic_test";
-
- //鍒涘缓
- TDMQUtil.getInstance().createQueue(queueName);
-
- //鍙戦�佹秷鎭�
- TDMQUtil.getInstance().sendMsg(queueName, "娴嬭瘯娑堟伅");
-
- //鍒涘缓涓婚
- TDMQUtil.getInstance().createTopic(topicName);
-
- //鍒涘缓璁㈤槄
- TDMQUtil.getInstance().subscribeTopic(topicName, topicName + queueName, queueName);
-
- //鍙戦�佽闃呮秷鎭�
- TDMQUtil.getInstance().publishTopicMessage(topicName, "涓婚娑堟伅");
+ String queueName = "makemoney-goldcorn-settle";
+// String topicName = "topic_test";
+//
+// //鍒涘缓
+// TDMQUtil.getInstance().createQueue(queueName);
+//
+// //鍙戦�佹秷鎭�
+// TDMQUtil.getInstance().sendMsg(queueName, "娴嬭瘯娑堟伅");
+//
+// //鍒涘缓涓婚
+// TDMQUtil.getInstance().createTopic(topicName);
+//
+// //鍒涘缓璁㈤槄
+// TDMQUtil.getInstance().subscribeTopic(topicName, topicName + queueName, queueName);
+//
+// //鍙戦�佽闃呮秷鎭�
+// TDMQUtil.getInstance().publishTopicMessage(topicName, "涓婚娑堟伅");
//娑堣垂娑堟伅
- try {
- Message message = TDMQUtil.getInstance().recieveMsg(queueName);
- System.out.println("鎺ュ彈鍒扮殑娑堟伅:" + message.msgBody);
- TDMQUtil.getInstance().deleteMsg(queueName, message.receiptHandle);
- } catch (Exception e) {
- e.printStackTrace();
- }
+// try {
+// Message message = TDMQUtil.getInstance().recieveMsg(queueName);
+// System.out.println("鎺ュ彈鍒扮殑娑堟伅:" + message.msgBody);
+// TDMQUtil.getInstance().deleteMsg(queueName, message.receiptHandle);
+// } catch (Exception e) {
+// e.printStackTrace();
+// }
try {
List<Message> messages = TDMQUtil.getInstance().recieveMsg(10, queueName);
@@ -489,14 +507,14 @@
}
- //鍒犻櫎璁㈤槄
- TDMQUtil.getInstance().deleteSubscribeTopic(topicName, topicName + queueName);
-
- //鍒犻櫎涓婚
- TDMQUtil.getInstance().deleteTopic(topicName);
-
- //鍒犻櫎闃熷垪
- TDMQUtil.getInstance().deleteQueue(queueName);
+// //鍒犻櫎璁㈤槄
+// TDMQUtil.getInstance().deleteSubscribeTopic(topicName, topicName + queueName);
+//
+// //鍒犻櫎涓婚
+// TDMQUtil.getInstance().deleteTopic(topicName);
+//
+// //鍒犻櫎闃熷垪
+// TDMQUtil.getInstance().deleteQueue(queueName);
}
--
Gitblit v1.8.0