From 56481656c7de11cdca69c1a7dd69db176ffd9ecd Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 08 五月 2021 12:49:30 +0800
Subject: [PATCH] 华为屏蔽金币任务中的看海量视频,新增广告平台概率控制
---
src/main/java/com/yeshi/buwan/util/mq/CMQManager.java | 218 +++++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 212 insertions(+), 6 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 8653ea4..3e5b181 100644
--- a/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
+++ b/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
@@ -1,7 +1,9 @@
package com.yeshi.buwan.util.mq;
+import com.google.gson.Gson;
import com.qcloud.cmq.Message;
-import com.yeshi.buwan.dto.mq.IqiyiAlbum2MQMsg;
+import com.yeshi.buwan.dto.mq.*;
+import com.yeshi.buwan.util.StringUtil;
import java.util.ArrayList;
import java.util.List;
@@ -12,9 +14,26 @@
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";
+
+ //鏇存柊瑙嗛闄勫姞淇℃伅
+ public static String QUEUENAME_UPDATE_VIDEO_EXTRAINFO = "buwan-video-video-update-extrainfo";
+
+ //鍏ㄧ綉鎼�
+ public static String QUEUENAME_UPDATE_INTERNET_SEARCH = "buwan-video-update-internet-search";
+
+
+ private static String TOPIC_VIDEO_EXTRAINFO = "buwan_topic_video_extrainfo_change";
static {
@@ -22,6 +41,22 @@
// 鏈�澶ф秷鎭负1M
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.createTopic(TOPIC_VIDEO_EXTRAINFO);
+ //璁㈤槄涓婚
+ try {
+ List<String> filters = new ArrayList<>();
+ filters.add("resource");
+ filters.add("category");
+ cmqUtil.subscribeTopic(TOPIC_VIDEO_EXTRAINFO, StringUtil.Md5(TOPIC_VIDEO_EXTRAINFO + "#" + QUEUENAME_UPDATE_VIDEO_EXTRAINFO), QUEUENAME_UPDATE_VIDEO_EXTRAINFO, filters);
+ } catch (Exception e) {
+ }
}
public static CMQManager getInstance() {
@@ -32,12 +67,12 @@
//娣诲姞涓撹緫鏇存柊娑堟伅
- public void addAlbumUpdateMsg(Long id) {
+ public void addIqiyiAlbumUpdateMsg(Long id) {
cmqUtil.sendMsg(QUEUENAME_VIDEO_UPDATE_IQIYI_2, id + "");
}
//娑堣垂涓撹緫鏇存柊娑堟伅
- public List<IqiyiAlbum2MQMsg> consumeAlbumUpdateMsg(int count) {
+ public List<IqiyiAlbum2MQMsg> consumeIqiyiAlbumUpdateMsg(int count) {
List<IqiyiAlbum2MQMsg> list = new ArrayList<>();
List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_VIDEO_UPDATE_IQIYI_2);
if (msgList != null)
@@ -51,10 +86,181 @@
}
//鍒犻櫎涓撹緫鏇存柊娑堟伅
- public void deleteAlbumUpdateMsg(String handler) {
+ public void deleteIqiyiAlbumUpdateMsg(String handler) {
cmqUtil.deleteMsg(QUEUENAME_VIDEO_UPDATE_IQIYI_2, handler);
}
- //鎼滅储寮曟搸
+
+ //娣诲姞涓撹緫鏇存柊娑堟伅
+ public void addFunTVAlbumUpdateMsg(String id) {
+ cmqUtil.sendMsg(QUEUENAME_VIDEO_UPDATE_FUNTV_2, id);
+ }
+
+ //娑堣垂涓撹緫鏇存柊娑堟伅
+ public List<FunTVAlbum2MQMsg> consumeFunTVAlbumUpdateMsg(int count) {
+ List<FunTVAlbum2MQMsg> list = new ArrayList<>();
+ List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_VIDEO_UPDATE_FUNTV_2);
+ if (msgList != null)
+ for (Message msg : msgList) {
+ FunTVAlbum2MQMsg mm = new FunTVAlbum2MQMsg();
+ mm.setHandler(msg.receiptHandle);
+ mm.setId(msg.msgBody);
+ list.add(mm);
+ }
+ 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);
+ }
+
+
+ /**
+ * 鎼滅储寮曟搸
+ * @param id
+ */
+
+ /**
+ * 鎼滅储寮曟搸娑堟伅
+ *
+ * @param id
+ */
+ public void addSolrMsg(String id) {
+ cmqUtil.sendMsg(QUEUENAME_SOLR, id);
+ }
+
+ public List<SolrVideoMQMsg> consumeSolrMsg(int count) {
+ List<SolrVideoMQMsg> list = new ArrayList<>();
+ List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_SOLR);
+ if (msgList != null)
+ for (Message msg : msgList) {
+ SolrVideoMQMsg mm = new SolrVideoMQMsg();
+ mm.setHandler(msg.receiptHandle);
+ mm.setId(msg.msgBody);
+ list.add(mm);
+ }
+ return list;
+ }
+
+
+ public void deleteSolrMsg(String handler) {
+ cmqUtil.deleteMsg(QUEUENAME_SOLR, handler);
+ }
+
+
+ /**
+ * 鍒犻櫎瑙嗛璧勬簮
+ *
+ * @param videoId
+ */
+
+ public void addVideoResourceDeleteMsg(String videoId) {
+ cmqUtil.sendMsg(QUEUENAME_VIDEO_RESOURCE_DELETE, videoId);
+ }
+
+ public List<CMQResult> consumeVideoResourceDeleteMsg(int count) {
+ List<CMQResult> list = new ArrayList<>();
+ List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_VIDEO_RESOURCE_DELETE);
+ if (msgList != null)
+ for (Message msg : msgList) {
+ CMQResult mm = new CMQResult();
+ mm.setHandler(msg.receiptHandle);
+ mm.setData(msg.msgBody);
+ list.add(mm);
+ }
+ return list;
+ }
+
+
+ public void deleteVideoResourceDeleteMsg(String handler) {
+ cmqUtil.deleteMsg(QUEUENAME_VIDEO_RESOURCE_DELETE, handler);
+ }
+
+
+ /**
+ * 瑙嗛闄勫姞淇℃伅鏀瑰彉
+ */
+ public void addVideoExtraInfoChanged(VideoExtraInfoChangeMQMsg msg) {
+ List<String> list = new ArrayList<>();
+ list.add(msg.getType());
+ cmqUtil.publishTopicMessage(TOPIC_VIDEO_EXTRAINFO, new Gson().toJson(msg), list);
+ }
+
+
+ public List<CMQResult> consumeUpdateVideoExtraInfoMsg(int count) {
+ List<CMQResult> list = new ArrayList<>();
+ List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_UPDATE_VIDEO_EXTRAINFO);
+ if (msgList != null)
+ for (Message msg : msgList) {
+ CMQResult mm = new CMQResult();
+ mm.setHandler(msg.receiptHandle);
+ mm.setData(new Gson().fromJson(msg.msgBody, VideoExtraInfoChangeMQMsg.class));
+ list.add(mm);
+ }
+ return list;
+ }
+
+ public void deleteUpdateVideoExtraInfoMsg(String handler) {
+ cmqUtil.deleteMsg(QUEUENAME_UPDATE_VIDEO_EXTRAINFO, handler);
+ }
+
+
+ /**
+ * 鍏ㄧ綉鎼�
+ *
+ * @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);
+ }
}
--
Gitblit v1.8.0