From 2e98b20bea4463e4465e3c19059d0744a09aec06 Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Tue, 27 Jun 2023 14:34:41 +0800
Subject: [PATCH] gb28181版本升级-补充
---
src/main/java/com/genersoft/iot/vmp/media/zlm/event/ZLMStatusEventListener.java | 59 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 59 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/media/zlm/event/ZLMStatusEventListener.java b/src/main/java/com/genersoft/iot/vmp/media/zlm/event/ZLMStatusEventListener.java
new file mode 100644
index 0000000..bad8e56
--- /dev/null
+++ b/src/main/java/com/genersoft/iot/vmp/media/zlm/event/ZLMStatusEventListener.java
@@ -0,0 +1,59 @@
+package com.genersoft.iot.vmp.media.zlm.event;
+
+import com.genersoft.iot.vmp.service.IMediaServerService;
+import com.genersoft.iot.vmp.service.IPlayService;
+import com.genersoft.iot.vmp.service.IStreamProxyService;
+import com.genersoft.iot.vmp.service.IStreamPushService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.event.EventListener;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+
+
+/**
+ * @description: 在线事件监听器，监听到离线后，修改设备离在线状态。 设备在线有两个来源：
+ * 1、设备主动注销，发送注销指令
+ * 2、设备未知原因离线，心跳超时
+ * @author: swwheihei
+ * @date: 2020年5月6日 下午1:51:23
+ */
+@Component
+public class ZLMStatusEventListener {
+
+ private final static Logger logger = LoggerFactory.getLogger(ZLMStatusEventListener.class);
+
+ @Autowired
+ private IStreamPushService streamPushService;
+
+ @Autowired
+ private IStreamProxyService streamProxyService;
+
+ @Autowired
+ private IMediaServerService mediaServerService;
+
+ @Autowired
+ private IPlayService playService;
+
+ @Async("taskExecutor")
+ @EventListener
+ public void onApplicationEvent(ZLMOnlineEvent event) {
+ logger.info("[ZLM] 上线 ID：" + event.getMediaServerId());
+ streamPushService.zlmServerOnline(event.getMediaServerId());
+ streamProxyService.zlmServerOnline(event.getMediaServerId());
+ playService.zlmServerOnline(event.getMediaServerId());
+ }
+
+ @Async("taskExecutor")
+ @EventListener
+ public void onApplicationEvent(ZLMOfflineEvent event) {
+
+ logger.info("[ZLM] 离线，ID：" + event.getMediaServerId());
+ // 处理ZLM离线
+ mediaServerService.zlmServerOffline(event.getMediaServerId());
+ streamProxyService.zlmServerOffline(event.getMediaServerId());
+ streamPushService.zlmServerOffline(event.getMediaServerId());
+ playService.zlmServerOffline(event.getMediaServerId());
+ }
+}
--
Gitblit v1.9.3