| package com.genersoft.iot.vmp.media.zlm; | 
|   | 
| import com.alibaba.fastjson2.JSON; | 
| import com.alibaba.fastjson2.JSONArray; | 
| import com.alibaba.fastjson2.JSONObject; | 
| import com.genersoft.iot.vmp.conf.DynamicTask; | 
| import com.genersoft.iot.vmp.conf.MediaConfig; | 
| import com.genersoft.iot.vmp.gb28181.event.EventPublisher; | 
| import com.genersoft.iot.vmp.media.zlm.dto.HookSubscribeFactory; | 
| import com.genersoft.iot.vmp.media.zlm.dto.HookSubscribeForServerStarted; | 
| import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem; | 
| import com.genersoft.iot.vmp.media.zlm.dto.StreamProxyItem; | 
| import com.genersoft.iot.vmp.service.IMediaServerService; | 
| import org.slf4j.Logger; | 
| import org.slf4j.LoggerFactory; | 
| import org.springframework.beans.factory.annotation.Autowired; | 
| import org.springframework.boot.CommandLineRunner; | 
| import org.springframework.core.annotation.Order; | 
| import org.springframework.scheduling.annotation.Async; | 
| import org.springframework.stereotype.Component; | 
|   | 
| import java.util.HashMap; | 
| import java.util.List; | 
| import java.util.Map; | 
| import java.util.Set; | 
| import java.util.concurrent.ConcurrentHashMap; | 
|   | 
| @Component | 
| @Order(value=12) | 
| public class ZLMRunner implements CommandLineRunner { | 
|   | 
|     private final static Logger logger = LoggerFactory.getLogger(ZLMRunner.class); | 
|   | 
|     private Map<String, Boolean> startGetMedia; | 
|   | 
|     @Autowired | 
|     private ZLMRESTfulUtils zlmresTfulUtils; | 
|   | 
|     @Autowired | 
|     private ZlmHttpHookSubscribe hookSubscribe; | 
|   | 
|     @Autowired | 
|     private EventPublisher publisher; | 
|   | 
|     @Autowired | 
|     private IMediaServerService mediaServerService; | 
|   | 
|     @Autowired | 
|     private MediaConfig mediaConfig; | 
|   | 
|     @Autowired | 
|     private DynamicTask dynamicTask; | 
|   | 
|   | 
|     @Override | 
|     public void run(String... strings) throws Exception { | 
|         mediaServerService.clearMediaServerForOnline(); | 
|         MediaServerItem defaultMediaServer = mediaServerService.getDefaultMediaServer(); | 
|         if (defaultMediaServer == null) { | 
|             mediaServerService.addToDatabase(mediaConfig.getMediaSerItem()); | 
|         }else { | 
|             MediaServerItem mediaSerItem = mediaConfig.getMediaSerItem(); | 
|             mediaServerService.updateToDatabase(mediaSerItem); | 
|         } | 
|         mediaServerService.syncCatchFromDatabase(); | 
|         HookSubscribeForServerStarted hookSubscribeForServerStarted = HookSubscribeFactory.on_server_started(); | 
|         // 订阅 zlm启动事件, 新的zlm也会从这里进入系统 | 
|         hookSubscribe.addSubscribe(hookSubscribeForServerStarted, | 
|                 (mediaServerItem, hookParam)->{ | 
|             ZLMServerConfig zlmServerConfig = (ZLMServerConfig)hookParam; | 
|             if (zlmServerConfig !=null ) { | 
|                 if (startGetMedia != null) { | 
|                     startGetMedia.remove(zlmServerConfig.getGeneralMediaServerId()); | 
|                     if (startGetMedia.size() == 0) { | 
|                         hookSubscribe.removeSubscribe(HookSubscribeFactory.on_server_started()); | 
|                     } | 
|                 } | 
|             } | 
|         }); | 
|   | 
|         // 获取zlm信息 | 
|         logger.info("[zlm] 等待默认zlm中..."); | 
|   | 
|         // 获取所有的zlm, 并开启主动连接 | 
|         List<MediaServerItem> all = mediaServerService.getAllFromDatabase(); | 
|         Map<String, MediaServerItem> allMap = new HashMap<>(); | 
|         mediaServerService.updateVmServer(all); | 
|         if (all.size() == 0) { | 
|             all.add(mediaConfig.getMediaSerItem()); | 
|         } | 
|         for (MediaServerItem mediaServerItem : all) { | 
|             if (startGetMedia == null) { | 
|                 startGetMedia = new ConcurrentHashMap<>(); | 
|             } | 
|             startGetMedia.put(mediaServerItem.getId(), true); | 
|             connectZlmServer(mediaServerItem); | 
|             allMap.put(mediaServerItem.getId(), mediaServerItem); | 
|         } | 
|         String taskKey = "zlm-connect-timeout"; | 
|         dynamicTask.startDelay(taskKey, ()->{ | 
|             if (startGetMedia != null && startGetMedia.size() > 0) { | 
|                 Set<String> allZlmId = startGetMedia.keySet(); | 
|                 for (String id : allZlmId) { | 
|                     logger.error("[ {} ]]主动连接失败,不再尝试连接", id); | 
|                 } | 
|                 startGetMedia = null; | 
|             } | 
|             // 获取redis中所有的zlm | 
|             List<MediaServerItem> allInRedis = mediaServerService.getAll(); | 
|             for (MediaServerItem mediaServerItem : allInRedis) { | 
|                 if (!allMap.containsKey(mediaServerItem.getId())) { | 
|                     mediaServerService.delete(mediaServerItem.getId()); | 
|                 } | 
|             } | 
|         }, 60 * 1000 ); | 
|     } | 
|   | 
|     @Async("taskExecutor") | 
|     public void connectZlmServer(MediaServerItem mediaServerItem){ | 
|         String connectZlmServerTaskKey = "connect-zlm-" + mediaServerItem.getId(); | 
|         ZLMServerConfig zlmServerConfigFirst = getMediaServerConfig(mediaServerItem); | 
|         if (zlmServerConfigFirst != null) { | 
|             zlmServerConfigFirst.setIp(mediaServerItem.getIp()); | 
|             zlmServerConfigFirst.setHttpPort(mediaServerItem.getHttpPort()); | 
|             startGetMedia.remove(mediaServerItem.getId()); | 
|             if (startGetMedia.size() == 0) { | 
|                 hookSubscribe.removeSubscribe(HookSubscribeFactory.on_server_started()); | 
|             } | 
|             mediaServerService.zlmServerOnline(zlmServerConfigFirst); | 
|         }else { | 
|             logger.info("[ {} ]-[ {}:{} ]主动连接失败, 清理相关资源, 开始尝试重试连接", | 
|                     mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); | 
|             publisher.zlmOfflineEventPublish(mediaServerItem.getId()); | 
|         } | 
|   | 
|         dynamicTask.startCron(connectZlmServerTaskKey, ()->{ | 
|             ZLMServerConfig zlmServerConfig = getMediaServerConfig(mediaServerItem); | 
|             if (zlmServerConfig != null) { | 
|                 dynamicTask.stop(connectZlmServerTaskKey); | 
|                 zlmServerConfig.setIp(mediaServerItem.getIp()); | 
|                 zlmServerConfig.setHttpPort(mediaServerItem.getHttpPort()); | 
|                 startGetMedia.remove(mediaServerItem.getId()); | 
|                 if (startGetMedia.size() == 0) { | 
|                     hookSubscribe.removeSubscribe(HookSubscribeFactory.on_server_started()); | 
|                 } | 
|                 mediaServerService.zlmServerOnline(zlmServerConfig); | 
|             } | 
|         }, 2000); | 
|     } | 
|   | 
|     public ZLMServerConfig getMediaServerConfig(MediaServerItem mediaServerItem) { | 
|         if (startGetMedia == null) { return null;} | 
|         if (!mediaServerItem.isDefaultServer() && mediaServerService.getOne(mediaServerItem.getId()) == null) { | 
|             return null; | 
|         } | 
|         if ( startGetMedia.get(mediaServerItem.getId()) == null || !startGetMedia.get(mediaServerItem.getId())) { | 
|             return null; | 
|         } | 
|         JSONObject responseJson = zlmresTfulUtils.getMediaServerConfig(mediaServerItem); | 
|         ZLMServerConfig zlmServerConfig = null; | 
|         if (responseJson != null) { | 
|             JSONArray data = responseJson.getJSONArray("data"); | 
|             if (data != null && data.size() > 0) { | 
|                 zlmServerConfig = JSON.parseObject(JSON.toJSONString(data.get(0)), ZLMServerConfig.class); | 
|             } | 
|         } else { | 
|             logger.error("[ {} ]-[ {}:{} ]主动连接失败, 2s后重试", | 
|                     mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); | 
|         } | 
|         return zlmServerConfig; | 
|   | 
|     } | 
| } |