Merge branch '648540858:wvp-28181-2.0' into wvp-28181-2.0

mk1990

2022-04-18 22e1d92a9d8ae6aa257889f882722b8e48648abc

 src/main/java/com/genersoft/iot/vmp/gb28181/event/offline/OfflineEventListener.java

@@ -1,5 +1,13 @@
package com.genersoft.iot.vmp.gb28181.event.offline;



import com.genersoft.iot.vmp.conf.UserSetting;

import com.genersoft.iot.vmp.gb28181.bean.DeviceChannel;

import com.genersoft.iot.vmp.gb28181.bean.SsrcTransaction;

import com.genersoft.iot.vmp.gb28181.event.EventPublisher;

import com.genersoft.iot.vmp.gb28181.event.subscribe.catalog.CatalogEvent;

import com.genersoft.iot.vmp.gb28181.session.VideoStreamSessionManager;

import com.genersoft.iot.vmp.media.zlm.ZLMRTPServerFactory;

import com.genersoft.iot.vmp.service.IMediaServerService;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

@@ -7,12 +15,14 @@
import org.springframework.stereotype.Component;



import com.genersoft.iot.vmp.common.VideoManagerConstants;

import com.genersoft.iot.vmp.storager.IVideoManagerStorager;

import com.genersoft.iot.vmp.storager.IVideoManagerStorage;

import com.genersoft.iot.vmp.utils.redis.RedisUtil;



import java.util.List;



/**

 * @Description: 离线事件监听器，监听到离线后，修改设备离在线状态。 设备离线有两个来源：

 *               1、设备主动注销，发送注销指令，{@link com.genersoft.iot.vmp.gb28181.transmit.request.impl.RegisterRequestProcessor}

 * @description: 离线事件监听器，监听到离线后，修改设备离在线状态。 设备离线有两个来源：

 *               1、设备主动注销，发送注销指令，{@link com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.RegisterRequestProcessor}

 *               2、设备未知原因离线，心跳超时,{@link com.genersoft.iot.vmp.gb28181.event.offline.OfflineEventListener}

 * @author: swwheihei

 * @date: 2020年5月6日 下午1:51:23

@@ -23,10 +33,27 @@
   private final static Logger logger = LoggerFactory.getLogger(OfflineEventListener.class);

   

   @Autowired

   private IVideoManagerStorager storager;

   private IVideoManagerStorage storager;



   @Autowired

   private VideoStreamSessionManager streamSession;

   

   @Autowired

    private RedisUtil redis;



   @Autowired

    private UserSetting userSetting;



   @Autowired

    private EventPublisher eventPublisher;





   @Autowired

    private IMediaServerService mediaServerService;





   @Autowired

    private ZLMRTPServerFactory zlmrtpServerFactory;



   @Override

   public void onApplicationEvent(OfflineEvent event) {

@@ -35,24 +62,39 @@
         logger.debug("设备离线事件触发，deviceId：" + event.getDeviceId() + ",from:" + event.getFrom());

      }



      String key = VideoManagerConstants.KEEPLIVEKEY_PREFIX + event.getDeviceId();

      String key = VideoManagerConstants.KEEPLIVEKEY_PREFIX + userSetting.getServerId() + "_" + event.getDeviceId();



      switch (event.getFrom()) {

      // 心跳超时触发的离线事件，说明redis中已删除，无需处理

      case VideoManagerConstants.EVENT_OUTLINE_TIMEOUT:

         break;

      // 设备主动注销触发的离线事件，需要删除redis中的超时监听

      case VideoManagerConstants.EVENT_OUTLINE_UNREGISTER:

         redis.del(key);

         break;

      default:

         boolean exist = redis.hasKey(key);

         if (exist) {

         // 心跳超时触发的离线事件，说明redis中已删除，无需处理

         case VideoManagerConstants.EVENT_OUTLINE_TIMEOUT:

            break;

         // 设备主动注销触发的离线事件，需要删除redis中的超时监听

         case VideoManagerConstants.EVENT_OUTLINE_UNREGISTER:

            redis.del(key);

            break;

         default:

            boolean exist = redis.hasKey(key);

            if (exist) {

               redis.del(key);

            }

      }



      List<DeviceChannel> deviceChannelList = storager.queryOnlineChannelsByDeviceId(event.getDeviceId());

      eventPublisher.catalogEventPublish(null, deviceChannelList, CatalogEvent.OFF);

      // 处理离线监听

      storager.outline(event.getDeviceId());



      // TODO 离线取消订阅



      // 离线释放所有ssrc

      List<SsrcTransaction> ssrcTransactions = streamSession.getSsrcTransactionForAll(event.getDeviceId(), null, null, null);

      if (ssrcTransactions != null && ssrcTransactions.size() > 0) {

         for (SsrcTransaction ssrcTransaction : ssrcTransactions) {

            mediaServerService.releaseSsrc(ssrcTransaction.getMediaServerId(), ssrcTransaction.getSsrc());

            mediaServerService.closeRTPServer(event.getDeviceId(), ssrcTransaction.getChannelId(), ssrcTransaction.getStream());

            streamSession.remove(event.getDeviceId(), ssrcTransaction.getChannelId(), ssrcTransaction.getStream());

         }

      }



      // 处理离线监听

      storager.outline(event.getDeviceId());

   }

}