From 8075103992e9482fddd4a579d97b9a50c5dcf550 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 24 十月 2020 18:26:43 +0800
Subject: [PATCH] 爱奇艺资源更新优化
---
src/main/java/com/yeshi/buwan/util/mq/CMQManager.java | 37 ++++++++++++++++++++++++++++++++++++-
1 files changed, 36 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 7a52f57..f5e76d0 100644
--- a/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
+++ b/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
@@ -1,6 +1,7 @@
package com.yeshi.buwan.util.mq;
import com.qcloud.cmq.Message;
+import com.yeshi.buwan.dto.mq.CMQConsumeMsg;
import com.yeshi.buwan.dto.mq.FunTVAlbum2MQMsg;
import com.yeshi.buwan.dto.mq.IqiyiAlbum2MQMsg;
import com.yeshi.buwan.dto.mq.SolrVideoMQMsg;
@@ -20,6 +21,9 @@
//瑙嗛鏇存柊-椋庤2
public static String QUEUENAME_VIDEO_UPDATE_FUNTV_2 = "buwan-video-update-funtv2";
+ //鍒犻櫎瑙嗛璧勬簮
+ public static String QUEUENAME_VIDEO_RESOURCE_DELETE = "buwan-video-resource-delete";
+
static {
cmqUtil = CMQUtil.getInstance(secretId, secretKey);
@@ -27,6 +31,7 @@
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_RESOURCE_DELETE, 1024 * 1024);
}
public static CMQManager getInstance() {
@@ -63,7 +68,7 @@
//娣诲姞涓撹緫鏇存柊娑堟伅
public void addFunTVAlbumUpdateMsg(String id) {
- cmqUtil.sendMsg(QUEUENAME_VIDEO_UPDATE_FUNTV_2, id );
+ cmqUtil.sendMsg(QUEUENAME_VIDEO_UPDATE_FUNTV_2, id);
}
//娑堣垂涓撹緫鏇存柊娑堟伅
@@ -118,4 +123,34 @@
cmqUtil.deleteMsg(QUEUENAME_SOLR, handler);
}
+
+ /**
+ * 鍒犻櫎瑙嗛璧勬簮
+ *
+ * @param videoId
+ */
+
+ public void addVideoResourceDeleteMsg(String videoId) {
+ cmqUtil.sendMsg(QUEUENAME_VIDEO_RESOURCE_DELETE, videoId);
+ }
+
+ public List<CMQConsumeMsg> consumeVideoResourceDeleteMsg(int count) {
+ List<CMQConsumeMsg> list = new ArrayList<>();
+ List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_VIDEO_RESOURCE_DELETE);
+ if (msgList != null)
+ for (Message msg : msgList) {
+ CMQConsumeMsg mm = new CMQConsumeMsg();
+ 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);
+ }
+
+
}
--
Gitblit v1.8.0