Merge branch 'refs/heads/master' into develop-add-api-key

leesam

2024-04-10 16b7e4a7ef473a6af29ec78aeb2f471fa398efdd

 src/main/java/com/genersoft/iot/vmp/media/event/mediaServer/MediaServerStatusEventListener.java

File was renamed from src/main/java/com/genersoft/iot/vmp/media/zlm/event/ZLMStatusEventListener.java
@@ -1,6 +1,5 @@
package com.genersoft.iot.vmp.media.zlm.event;
package com.genersoft.iot.vmp.media.event.mediaServer;

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;
@@ -20,9 +19,9 @@
 * @date: 2020年5月6日 下午1:51:23
 */
@Component
public class ZLMStatusEventListener {
public class MediaServerStatusEventListener {
   
   private final static Logger logger = LoggerFactory.getLogger(ZLMStatusEventListener.class);
   private final static Logger logger = LoggerFactory.getLogger(MediaServerStatusEventListener.class);

   @Autowired
   private IStreamPushService streamPushService;
@@ -31,15 +30,12 @@
   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());
   public void onApplicationEvent(MediaServerOnlineEvent event) {
      logger.info("[媒体节点] 上线 ID：" + event.getMediaServerId());
      streamPushService.zlmServerOnline(event.getMediaServerId());
      streamProxyService.zlmServerOnline(event.getMediaServerId());
      playService.zlmServerOnline(event.getMediaServerId());
@@ -47,11 +43,10 @@

   @Async("taskExecutor")
   @EventListener
   public void onApplicationEvent(ZLMOfflineEvent event) {
   public void onApplicationEvent(MediaServerOfflineEvent event) {

      logger.info("[ZLM] 离线，ID：" + event.getMediaServerId());
      logger.info("[媒体节点] 离线，ID：" + event.getMediaServerId());
      // 处理ZLM离线
      mediaServerService.zlmServerOffline(event.getMediaServerId());
      streamProxyService.zlmServerOffline(event.getMediaServerId());
      streamPushService.zlmServerOffline(event.getMediaServerId());
      playService.zlmServerOffline(event.getMediaServerId());