| | |
| | | if (startGetMedia != null) { |
| | | startGetMedia.remove(zlmServerConfig.getGeneralMediaServerId()); |
| | | } |
| | | mediaServerService.zlmServerOnline(zlmServerConfig); |
| | | } |
| | | }); |
| | | |
| | | // 订阅 zlm保活事件, 当zlm离线时做业务的处理 |
| | | hookSubscribe.addSubscribe(ZLMHttpHookSubscribe.HookType.on_server_keepalive,new JSONObject(), |
| | | (MediaServerItem mediaServerItem, JSONObject response)->{ |
| | | String mediaServerId = response.getString("mediaServerId"); |
| | | if (mediaServerId !=null ) { |
| | | mediaServerService.updateMediaServerKeepalive(mediaServerId, response.getJSONObject("data")); |
| | | } |
| | | }); |
| | | |
| | | // 获取zlm信息 |
| | | logger.info("[zlm接入]等待默认zlm中..."); |
| | | logger.info("[zlm] 等待默认zlm中..."); |
| | | |
| | | // 获取所有的zlm, 并开启主动连接 |
| | | List<MediaServerItem> all = mediaServerService.getAllFromDatabase(); |
| | |
| | | } |
| | | startGetMedia = null; |
| | | } |
| | | hookSubscribe.removeSubscribe(ZLMHttpHookSubscribe.HookType.on_server_started, new JSONObject()); |
| | | // TODO 清理数据库中与redis不匹配的zlm |
| | | }, 60 * 1000 ); |
| | | } |