From f788607ff771a47bc60d6a86e00b3433c40f3d2c Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 24 九月 2021 15:22:03 +0800
Subject: [PATCH] 接入视频直播

---
 src/main/java/com/yeshi/buwan/util/mq/CMQManager.java |   97 ++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 96 insertions(+), 1 deletions(-)

diff --git a/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java b/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
index 259c9c3..146daa3 100644
--- a/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
+++ b/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
@@ -14,11 +14,14 @@
     private static CMQManager cmqManager;
     private static CMQUtil cmqUtil;
     // 鎼滅储寮曟搸
-    public static String QUEUENAME_SOLR = "buwan-solr";
+    public static String QUEUENAME_SOLR = "buwan-solr-new";
     //瑙嗛鏇存柊-鐖卞鑹�2
     public static String QUEUENAME_VIDEO_UPDATE_IQIYI_2 = "buwan-video-update-iqiyi2";
     //瑙嗛鏇存柊-椋庤2
     public static String QUEUENAME_VIDEO_UPDATE_FUNTV_2 = "buwan-video-update-funtv2";
+
+    //瑙嗛鏇存柊-PPTV
+    public static String QUEUENAME_VIDEO_UPDATE_PPTV = "buwan-video-update-pptv";
 
     //鍒犻櫎瑙嗛璧勬簮
     public static String QUEUENAME_VIDEO_RESOURCE_DELETE = "buwan-video-resource-delete";
@@ -26,6 +29,10 @@
     //鏇存柊瑙嗛闄勫姞淇℃伅
     public static String QUEUENAME_UPDATE_VIDEO_EXTRAINFO = "buwan-video-video-update-extrainfo";
 
+    //鍏ㄧ綉鎼�
+    public static String QUEUENAME_UPDATE_INTERNET_SEARCH = "buwan-video-update-internet-search";
+
+    public static String QUEUENAME_UPDATE_RESOURCE_VIDEO = "buwan-video-update-resource-video";
 
     private static String TOPIC_VIDEO_EXTRAINFO = "buwan_topic_video_extrainfo_change";
 
@@ -36,8 +43,11 @@
         cmqUtil.createQueue(QUEUENAME_SOLR, 1024 * 1024);
         cmqUtil.createQueue(QUEUENAME_VIDEO_UPDATE_IQIYI_2, 1024 * 1024);
         cmqUtil.createQueue(QUEUENAME_VIDEO_UPDATE_FUNTV_2, 1024 * 1024);
+        cmqUtil.createQueue(QUEUENAME_VIDEO_UPDATE_PPTV, 1024 * 1024);
         cmqUtil.createQueue(QUEUENAME_VIDEO_RESOURCE_DELETE, 1024 * 1024);
         cmqUtil.createQueue(QUEUENAME_UPDATE_VIDEO_EXTRAINFO, 1024 * 1024);
+        cmqUtil.createQueue(QUEUENAME_UPDATE_INTERNET_SEARCH, 1024 * 1024);
+        cmqUtil.createQueue(QUEUENAME_UPDATE_RESOURCE_VIDEO, 1024 * 1024);
 
         //鍒涘缓涓婚
         cmqUtil.createTopic(TOPIC_VIDEO_EXTRAINFO);
@@ -102,9 +112,38 @@
         return list;
     }
 
+
     //鍒犻櫎涓撹緫鏇存柊娑堟伅
     public void deleteFunTVAlbumUpdateMsg(String handler) {
         cmqUtil.deleteMsg(QUEUENAME_VIDEO_UPDATE_FUNTV_2, handler);
+    }
+
+
+    /**
+     * PPTV鍓ч泦鏇存柊
+     */
+
+    //娣诲姞涓撹緫鏇存柊娑堟伅
+    public void addPPTVSeriesUpdateMsg(PPTVMQMsg msg) {
+        cmqUtil.sendMsg(QUEUENAME_VIDEO_UPDATE_PPTV, new Gson().toJson(msg));
+    }
+
+    //娑堣垂涓撹緫鏇存柊娑堟伅
+    public List<PPTVMQMsg> consumePPTVSeriesUpdateMsg(int count) {
+        List<PPTVMQMsg> list = new ArrayList<>();
+        List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_VIDEO_UPDATE_PPTV);
+        if (msgList != null)
+            for (Message msg : msgList) {
+                PPTVMQMsg mm = new Gson().fromJson(msg.msgBody, PPTVMQMsg.class);
+                mm.setHandler(msg.receiptHandle);
+                list.add(mm);
+            }
+        return list;
+    }
+
+    //鍒犻櫎涓撹緫鏇存柊娑堟伅
+    public void deletePPTVSeriesUpdateMsg(String handler) {
+        cmqUtil.deleteMsg(QUEUENAME_VIDEO_UPDATE_PPTV, handler);
     }
 
 
@@ -198,4 +237,60 @@
     }
 
 
+    /**
+     * 鍏ㄧ綉鎼�
+     *
+     * @param msg
+     */
+
+    public void addInternetSearchVideoUpdateMsg(InternetSearchVideoMQMsg msg) {
+        cmqUtil.sendMsg(QUEUENAME_UPDATE_INTERNET_SEARCH, new Gson().toJson(msg));
+    }
+
+    public List<InternetSearchVideoMQMsg> consumeInternetSearchVideoUpdateMsg(int count) {
+        Gson gson = new Gson();
+        List<InternetSearchVideoMQMsg> list = new ArrayList<>();
+        List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_UPDATE_INTERNET_SEARCH);
+        if (msgList != null)
+            for (Message msg : msgList) {
+                InternetSearchVideoMQMsg mm = gson.fromJson(msg.msgBody, InternetSearchVideoMQMsg.class);
+                mm.setHandler(msg.receiptHandle);
+                list.add(mm);
+            }
+        return list;
+    }
+
+
+    public void deleteInternetSearchVideoUpdateMsg(String handler) {
+        cmqUtil.deleteMsg(QUEUENAME_UPDATE_INTERNET_SEARCH, handler);
+    }
+
+    /**
+     * 瑙嗛鏉ユ簮鏇存柊
+     *
+     * @param msg
+     */
+    public void addUpdateResourceVideoMsg(UpdateResourceVideoMQMsg msg) {
+        cmqUtil.sendMsg(QUEUENAME_UPDATE_RESOURCE_VIDEO, new Gson().toJson(msg));
+    }
+
+    public void deleteUpdateResourceVideoMsg(String handler) {
+        cmqUtil.deleteMsg(QUEUENAME_UPDATE_RESOURCE_VIDEO, handler);
+    }
+
+
+    public List<UpdateResourceVideoMQMsg> consumeUpdateResourceVideoMsg(int count) {
+        Gson gson = new Gson();
+        List<UpdateResourceVideoMQMsg> list = new ArrayList<>();
+        List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_UPDATE_RESOURCE_VIDEO);
+        if (msgList != null)
+            for (Message msg : msgList) {
+                UpdateResourceVideoMQMsg mm = gson.fromJson(msg.msgBody, UpdateResourceVideoMQMsg.class);
+                mm.setHandler(msg.receiptHandle);
+                list.add(mm);
+            }
+        return list;
+    }
+
+
 }

--
Gitblit v1.8.0