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 | 32 +++++++++++++++++++++++++++++++-
1 files changed, 31 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 987e63c..146daa3 100644
--- a/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
+++ b/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
@@ -32,6 +32,7 @@
//鍏ㄧ綉鎼�
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";
@@ -46,6 +47,7 @@
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);
@@ -242,7 +244,7 @@
*/
public void addInternetSearchVideoUpdateMsg(InternetSearchVideoMQMsg msg) {
- cmqUtil.sendMsg(QUEUENAME_VIDEO_RESOURCE_DELETE, new Gson().toJson(msg));
+ cmqUtil.sendMsg(QUEUENAME_UPDATE_INTERNET_SEARCH, new Gson().toJson(msg));
}
public List<InternetSearchVideoMQMsg> consumeInternetSearchVideoUpdateMsg(int count) {
@@ -263,4 +265,32 @@
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