From df4441322e9801c102299451da41d7c40b4502e9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 24 六月 2021 18:53:13 +0800
Subject: [PATCH] zookeeper地址修改，Maven采用私服

---
 service-daylucky/src/main/java/com/ks/daylucky/util/mq/CMQManager.java |  109 +++++++++++++++++++++++++++++++++++-------------------
 1 files changed, 71 insertions(+), 38 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
index fe9b442..8a0eafe 100644
--- 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
@@ -1,13 +1,11 @@
 package com.ks.daylucky.util.mq;
 
-import com.google.gson.Gson;
-import com.ks.daylucky.pojo.DTO.ActivityMQMsg;
+import com.ks.lucky.utils.LuckyCMQConstant;
 import com.qcloud.cmq.Message;
 import org.yeshi.utils.CMQUtil;
 
-import java.util.HashMap;
+import java.util.Arrays;
 import java.util.List;
-import java.util.Map;
 
 public class CMQManager {
 
@@ -16,12 +14,50 @@
     private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
     private static CMQManager cmqManager;
     private static CMQUtil cmqUtil;
-    public static String QUEUENAME_LUCKY_ACTIVITY = "lucky-activity";
+    /**
+     * 娑堟伅
+     */
+    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_LUCKY_ACTIVITY, 1024 * 1024);
+        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() {
@@ -33,44 +69,17 @@
 
 
     /**
-     * 娣诲姞娑堟伅
-     *
-     * @param queueName
-     * @param msg
-     */
-    public void addMsg(String queueName, String msg) {
-        cmqUtil.sendMsg(queueName, msg);
-    }
-
-
-    /**
-     * 娣诲姞娲诲姩娑堟伅
-     *
-     * @param msg
-     */
-    public void addActivityMsg(ActivityMQMsg msg) {
-        cmqUtil.sendMsg(QUEUENAME_LUCKY_ACTIVITY, new Gson().toJson(msg));
-    }
-
-    /**
      * 娲诲姩娑堟伅娑堣垂
      *
      * @param count
      * @return
      */
-    public Map<String, ActivityMQMsg> consumeActivityMsg(int count) {
-        List<Message> list = cmqUtil.recieveMsg(count, QUEUENAME_LUCKY_ACTIVITY);
+    public List<Message> consumeMsgMsg(int count) {
+        List<Message> list = cmqUtil.recieveMsg(count, QUEUENAME_DAY_LUCKY_MSG);
         if (list == null) {
             return null;
         }
-
-        Map<String, ActivityMQMsg> map = new HashMap<>();
-        Gson gson = new Gson();
-        for (Message msg : list) {
-            String result = msg.msgBody;
-            map.put(msg.receiptHandle, gson.fromJson(result, ActivityMQMsg.class));
-        }
-        return map;
+        return list;
     }
 
     /**
@@ -78,8 +87,32 @@
      *
      * @param receiptHandle
      */
-    public void deleteActivityMsg(String receiptHandle) {
-        cmqUtil.deleteMsg(QUEUENAME_LUCKY_ACTIVITY, 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