|  |  | 
 |  |  |         } | 
 |  |  |         mediaServerService.syncCatchFromDatabase(); | 
 |  |  |         // 订阅 zlm启动事件, 新的zlm也会从这里进入系统 | 
 |  |  |         hookSubscribe.addSubscribe(ZLMHttpHookSubscribe.HookType.on_server_started,null, | 
 |  |  |         hookSubscribe.addSubscribe(ZLMHttpHookSubscribe.HookType.on_server_started,new JSONObject(), | 
 |  |  |                 (MediaServerItem mediaServerItem, JSONObject response)->{ | 
 |  |  |             ZLMServerConfig zlmServerConfig = JSONObject.toJavaObject(response, ZLMServerConfig.class); | 
 |  |  |             if (zlmServerConfig !=null ) { | 
 |  |  | 
 |  |  |         }); | 
 |  |  |  | 
 |  |  |         // 订阅 zlm保活事件, 当zlm离线时做业务的处理 | 
 |  |  |         hookSubscribe.addSubscribe(ZLMHttpHookSubscribe.HookType.on_server_keepalive,null, | 
 |  |  |         hookSubscribe.addSubscribe(ZLMHttpHookSubscribe.HookType.on_server_keepalive,new JSONObject(), | 
 |  |  |                 (MediaServerItem mediaServerItem, JSONObject response)->{ | 
 |  |  |                     String mediaServerId = response.getString("mediaServerId"); | 
 |  |  |                     if (mediaServerId !=null ) { | 
 |  |  | 
 |  |  |  | 
 |  |  |         // 获取所有的zlm, 并开启主动连接 | 
 |  |  |         List<MediaServerItem> all = mediaServerService.getAllFromDatabase(); | 
 |  |  |         mediaServerService.updateVmServer(all); | 
 |  |  |         if (all.size() == 0) { | 
 |  |  |             all.add(mediaConfig.getMediaSerItem()); | 
 |  |  |         } |