From 2f5935ed11672046c37f733d855214f6147b4b58 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期一, 28 三月 2022 11:33:19 +0800 Subject: [PATCH] TDMQ兼容 --- fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/PDDOrderCMQManager.java | 104 +++++++++++++++++++++++++++------------------------ 1 files changed, 55 insertions(+), 49 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/PDDOrderCMQManager.java b/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/PDDOrderCMQManager.java index 7499e8c..0c1d028 100644 --- a/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/PDDOrderCMQManager.java +++ b/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/PDDOrderCMQManager.java @@ -4,6 +4,7 @@ import java.util.List; import java.util.Map; +import com.yeshi.fanli.util.mq.cmq.TDMQUtil; import org.yeshi.utils.CMQUtil; import com.qcloud.cmq.Message; @@ -12,60 +13,65 @@ public class PDDOrderCMQManager { - private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25"; - private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo"; - private static PDDOrderCMQManager pddOrderCMQManager; - private static CMQUtil cmqUtil; + private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25"; + private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo"; + private static PDDOrderCMQManager pddOrderCMQManager; + private static CMQUtil cmqUtil; - public static String PDD_ORDER = "order-pdd"; + public static String PDD_ORDER = "order-pdd"; - static { - cmqUtil = CMQUtil.getInstance(secretId, secretKey); - PDD_ORDER += "-" + Constant.systemCommonConfig.getProjectName(); - cmqUtil.createQueue(PDD_ORDER); - } + static { + cmqUtil = CMQUtil.getInstance(secretId, secretKey); + TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC); + PDD_ORDER += "-" + Constant.systemCommonConfig.getProjectName(); + TDMQUtil.getInstance().createQueue(PDD_ORDER); + } - public static PDDOrderCMQManager getInstance() { - if (pddOrderCMQManager == null) - pddOrderCMQManager = new PDDOrderCMQManager(); - return pddOrderCMQManager; - } + public static PDDOrderCMQManager getInstance() { + if (pddOrderCMQManager == null) + pddOrderCMQManager = new PDDOrderCMQManager(); + return pddOrderCMQManager; + } - /** - * 娣诲姞浜笢璁㈠崟鍒伴槦鍒� - * - * @param orderId - */ - public void addPDDOrder(String orderId) { - if (StringUtil.isNullOrEmpty(orderId)) - return; - cmqUtil.sendMsg(PDD_ORDER, orderId); - } + /** + * 娣诲姞浜笢璁㈠崟鍒伴槦鍒� + * + * @param orderId + */ + public void addPDDOrder(String orderId) { + if (StringUtil.isNullOrEmpty(orderId)) + return; + TDMQUtil.getInstance().sendMsg(PDD_ORDER, orderId); + } - /** - * 娑堣垂闃熷垪娑堟伅 - * - * @param count - * @return - */ - public Map<String, String> consumePDDOrder(int count) { - List<Message> list = cmqUtil.recieveMsg(count, PDD_ORDER); - Map<String, String> map = new HashMap<>(); - if (list != null) - for (Message msg : list) { - String result = msg.msgBody; - map.put(msg.receiptHandle, result); - } - return map; - } + /** + * 娑堣垂闃熷垪娑堟伅 + * + * @param count + * @return + */ + public Map<String, String> consumePDDOrder(int count) { + List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, PDD_ORDER) : cmqUtil.recieveMsg(count, PDD_ORDER); + Map<String, String> map = new HashMap<>(); + if (list != null) + for (Message msg : list) { + String result = msg.msgBody; + map.put(msg.receiptHandle, result); + } + return map; + } - /** - * 鍒犻櫎浜笢闃熷垪 - * - * @param receiptHandle - */ - public void deletePDDOrder(String receiptHandle) { - cmqUtil.deleteMsg(PDD_ORDER, receiptHandle); - } + /** + * 鍒犻櫎浜笢闃熷垪 + * + * @param receiptHandle + */ + public void deletePDDOrder(String receiptHandle) { + if (Constant.TDMQ_CONSUMER) { + TDMQUtil.getInstance().deleteMsg(PDD_ORDER, receiptHandle); + } else { + cmqUtil.deleteMsg(PDD_ORDER, receiptHandle); + } + } } -- Gitblit v1.8.0