From 7e389247b3b2877c12f1eaae6e33c9c33e91d2dd Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 08 一月 2021 18:41:59 +0800
Subject: [PATCH] 活动添加后台完善
---
service-daylucky/src/main/java/com/ks/daylucky/util/mq/CMQManager.java | 119 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 119 insertions(+), 0 deletions(-)
diff --git a/service-daylucky/src/main/java/com/ks/daylucky/util/mq/CMQManager.java b/service-daylucky/src/main/java/com/ks/daylucky/util/mq/CMQManager.java
new file mode 100644
index 0000000..8a0eafe
--- /dev/null
+++ b/service-daylucky/src/main/java/com/ks/daylucky/util/mq/CMQManager.java
@@ -0,0 +1,119 @@
+package com.ks.daylucky.util.mq;
+
+import com.ks.lucky.utils.LuckyCMQConstant;
+import com.qcloud.cmq.Message;
+import org.yeshi.utils.CMQUtil;
+
+import java.util.Arrays;
+import java.util.List;
+
+public class CMQManager {
+
+
+ private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
+ private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
+ private static CMQManager cmqManager;
+ private static CMQUtil cmqUtil;
+ /**
+ * 娑堟伅
+ */
+ public static String QUEUENAME_DAY_LUCKY_MSG = "day-lucky-msg";
+
+ /**
+ * 娲诲姩涓閫氱煡
+ */
+ public static String QUEUENAME_DAY_LUCKY_ACTIVITY_DRAWN = "day-lucky-activity-drawn-notify";
+
+
+ static {
+ cmqUtil = CMQUtil.getInstance(secretId, secretKey);
+ // 鏈�澶ф秷鎭负1M
+ cmqUtil.createQueue(QUEUENAME_DAY_LUCKY_MSG, 1024 * 1024);
+ cmqUtil.createQueue(QUEUENAME_DAY_LUCKY_ACTIVITY_DRAWN, 1024 * 1024);
+
+ try {
+ cmqUtil.subscribeTopic(LuckyCMQConstant.TOPIC_ACTIVITY_STATE_CHANGE, QUEUENAME_DAY_LUCKY_MSG, QUEUENAME_DAY_LUCKY_MSG);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ try {
+ cmqUtil.subscribeTopic(LuckyCMQConstant.TOPIC_ASSIST, QUEUENAME_DAY_LUCKY_MSG, QUEUENAME_DAY_LUCKY_MSG);
+ } catch (Exception e) {
+
+ }
+
+ try {
+ cmqUtil.subscribeTopic(LuckyCMQConstant.TOPIC_ACTIVITY_DRAWN, QUEUENAME_DAY_LUCKY_MSG, QUEUENAME_DAY_LUCKY_MSG);
+ } catch (Exception e) {
+ }
+
+
+ try {
+ cmqUtil.subscribeTopic(LuckyCMQConstant.TOPIC_ACTIVITY_JOIN, QUEUENAME_DAY_LUCKY_MSG, QUEUENAME_DAY_LUCKY_MSG);
+ } catch (Exception e) {
+ }
+
+ try {
+ cmqUtil.subscribeTopic(LuckyCMQConstant.TOPIC_ACTIVITY_DRAWN, QUEUENAME_DAY_LUCKY_ACTIVITY_DRAWN, QUEUENAME_DAY_LUCKY_ACTIVITY_DRAWN);
+ } catch (Exception e) {
+ }
+
+ }
+
+ public static CMQManager getInstance() {
+ if (cmqManager == null) {
+ cmqManager = new CMQManager();
+ }
+ return cmqManager;
+ }
+
+
+ /**
+ * 娲诲姩娑堟伅娑堣垂
+ *
+ * @param count
+ * @return
+ */
+ public List<Message> consumeMsgMsg(int count) {
+ List<Message> list = cmqUtil.recieveMsg(count, QUEUENAME_DAY_LUCKY_MSG);
+ if (list == null) {
+ return null;
+ }
+ return list;
+ }
+
+ /**
+ * 鍒犻櫎娲诲姩娑堟伅
+ *
+ * @param receiptHandle
+ */
+ public void deleteMsgMsg(String receiptHandle) {
+ cmqUtil.deleteMsg(QUEUENAME_DAY_LUCKY_MSG, receiptHandle);
+ }
+
+
+ /**
+ * 娲诲姩娑堟伅娑堣垂
+ *
+ * @param count
+ * @return
+ */
+ public List<Message> consumeActivityDrawnMsg(int count) {
+ List<Message> list = cmqUtil.recieveMsg(count, QUEUENAME_DAY_LUCKY_ACTIVITY_DRAWN);
+ if (list == null) {
+ return null;
+ }
+ return list;
+ }
+
+ /**
+ * 鍒犻櫎娲诲姩娑堟伅
+ *
+ * @param receiptHandle
+ */
+ public void deleteActivityDrawnMsg(String receiptHandle) {
+ cmqUtil.deleteMsg(QUEUENAME_DAY_LUCKY_ACTIVITY_DRAWN, receiptHandle);
+ }
+
+
+}
--
Gitblit v1.8.0