package com.genersoft.iot.vmp.gb28181.event.platformNotRegister;
|
|
import com.genersoft.iot.vmp.conf.SipConfig;
|
import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform;
|
import com.genersoft.iot.vmp.gb28181.bean.SendRtpItem;
|
import com.genersoft.iot.vmp.gb28181.event.SipSubscribe;
|
import com.genersoft.iot.vmp.gb28181.transmit.cmd.impl.SIPCommanderFroPlatform;
|
import com.genersoft.iot.vmp.media.zlm.ZLMRTPServerFactory;
|
import com.genersoft.iot.vmp.media.zlm.dto.IMediaServerItem;
|
import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
|
import com.genersoft.iot.vmp.service.IMediaServerService;
|
import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
|
import com.genersoft.iot.vmp.storager.IVideoManagerStorager;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.ApplicationListener;
|
import org.springframework.stereotype.Component;
|
|
import java.util.*;
|
|
/**
|
* @Description: 平台未注册事件,来源有二:
|
* 1、平台新添加
|
* 2、平台心跳超时
|
* @author: panll
|
* @date: 2020年11月24日 10:00
|
*/
|
@Component
|
public class PlatformNotRegisterEventLister implements ApplicationListener<PlatformNotRegisterEvent> {
|
|
private final static Logger logger = LoggerFactory.getLogger(PlatformNotRegisterEventLister.class);
|
|
@Autowired
|
private IVideoManagerStorager storager;
|
@Autowired
|
private IRedisCatchStorage redisCatchStorage;
|
@Autowired
|
private IMediaServerService mediaServerService;
|
|
@Autowired
|
private SIPCommanderFroPlatform sipCommanderFroPlatform;
|
|
@Autowired
|
private ZLMRTPServerFactory zlmrtpServerFactory;
|
|
@Autowired
|
private SipConfig config;
|
|
// @Autowired
|
// private RedisUtil redis;
|
|
@Override
|
public void onApplicationEvent(PlatformNotRegisterEvent event) {
|
|
logger.info("平台未注册事件触发，平台国标ID：" + event.getPlatformGbID());
|
|
ParentPlatform parentPlatform = storager.queryParentPlatByServerGBId(event.getPlatformGbID());
|
if (parentPlatform == null) {
|
logger.info("平台未注册事件触发，但平台已经删除!!! 平台国标ID：" + event.getPlatformGbID());
|
return;
|
}
|
// 查询是否有推流， 如果有则都停止
|
List<SendRtpItem> sendRtpItems = redisCatchStorage.querySendRTPServer(event.getPlatformGbID());
|
logger.info("停止[ {} ]的所有推流size", sendRtpItems.size());
|
if (sendRtpItems != null && sendRtpItems.size() > 0) {
|
logger.info("停止[ {} ]的所有推流", event.getPlatformGbID());
|
StringBuilder app = new StringBuilder();
|
StringBuilder stream = new StringBuilder();
|
for (SendRtpItem sendRtpItem : sendRtpItems) {
|
if (app.length() != 0) {
|
app.append(",");
|
}
|
app.append(sendRtpItem.getApp());
|
if (stream.length() != 0) {
|
stream.append(",");
|
}
|
stream.append(sendRtpItem.getStreamId());
|
redisCatchStorage.deleteSendRTPServer(event.getPlatformGbID(), sendRtpItem.getChannelId());
|
IMediaServerItem mediaInfo = mediaServerService.getOne(sendRtpItem.getMediaServerId());
|
Map<String, Object> param = new HashMap<>();
|
param.put("vhost", "__defaultVhost__");
|
param.put("app", app.toString());
|
param.put("stream", stream.toString());
|
zlmrtpServerFactory.stopSendRtpStream(mediaInfo, param);
|
}
|
|
|
}
|
|
Timer timer = new Timer();
|
SipSubscribe.Event okEvent = (responseEvent)->{
|
timer.cancel();
|
};
|
logger.info("向平台注册，平台国标ID：" + event.getPlatformGbID());
|
sipCommanderFroPlatform.register(parentPlatform, null, okEvent);
|
// 设置注册失败则每隔15秒发起一次注册
|
timer.schedule(new TimerTask() {
|
@Override
|
public void run() {
|
logger.info("再次向平台注册，平台国标ID：" + event.getPlatformGbID());
|
sipCommanderFroPlatform.register(parentPlatform, null, okEvent);
|
}
|
}, config.getRegisterTimeInterval(), config.getRegisterTimeInterval());//十五秒后再次发起注册
|
}
|
}
|
