From 9b1af8ef1396de45884fe86c56844714045b82ec Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期二, 07 十二月 2021 21:13:55 +0800
Subject: [PATCH] 适配zlm的hook保活
---
src/main/java/com/genersoft/iot/vmp/service/impl/MediaServerServiceImpl.java | 93 ++++++++++++----------------------------------
1 files changed, 24 insertions(+), 69 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/service/impl/MediaServerServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/service/impl/MediaServerServiceImpl.java
index b6bfc00..e02bd3f 100644
--- a/src/main/java/com/genersoft/iot/vmp/service/impl/MediaServerServiceImpl.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/impl/MediaServerServiceImpl.java
@@ -97,6 +97,7 @@
if (!redisUtil.hasKey(key)) {
redisUtil.set(key, mediaServerItem);
}
+
}
}
@@ -272,6 +273,7 @@
WVPResult<String> result = new WVPResult<>();
mediaServerItem.setCreateTime(this.format.format(System.currentTimeMillis()));
mediaServerItem.setUpdateTime(this.format.format(System.currentTimeMillis()));
+ mediaServerItem.setHookAliveInterval(120);
JSONObject responseJSON = zlmresTfulUtils.getMediaServerConfig(mediaServerItem);
if (responseJSON != null) {
JSONArray data = responseJSON.getJSONArray("data");
@@ -329,6 +331,7 @@
logger.warn("[鏈敞鍐岀殑zlm] 鎷掓帴鎺ュ叆锛氭潵鑷獅}锛歿}", zlmServerConfig.getIp(),zlmServerConfig.getHttpPort() );
return;
}
+ serverItem.setHookAliveInterval(zlmServerConfig.getHookAliveInterval());
if (serverItem.getHttpPort() == 0) {
serverItem.setHttpPort(zlmServerConfig.getHttpPort());
}
@@ -352,85 +355,29 @@
}
if (StringUtils.isEmpty(serverItem.getId())) {
serverItem.setId(zlmServerConfig.getGeneralMediaServerId());
+ }
+ serverItem.setStatus(true);
+ if (StringUtils.isEmpty(serverItem.getId())) {
+ serverItem.setId(zlmServerConfig.getGeneralMediaServerId());
mediaServerMapper.updateByHostAndPort(serverItem);
}else {
mediaServerMapper.update(serverItem);
}
- if (redisUtil.get(VideoManagerConstants.MEDIA_SERVER_PREFIX + userSetup.getServerId() + "_" + serverItem.getId()) == null) {
+ String key = VideoManagerConstants.MEDIA_SERVER_PREFIX + userSetup.getServerId() + "_" + serverItem.getId();
+ if (redisUtil.get(key) == null) {
SsrcConfig ssrcConfig = new SsrcConfig(serverItem.getId(), null, sipConfig.getDomain());
serverItem.setSsrcConfig(ssrcConfig);
- redisUtil.set(VideoManagerConstants.MEDIA_SERVER_PREFIX + userSetup.getServerId() + "_" + serverItem.getId(), serverItem);
+ redisUtil.set(key, serverItem);
}
- serverItem.setStatus(true);
resetOnlineServerItem(serverItem);
+ updateMediaServerKeepalive(serverItem.getId(), null);
setZLMConfig(serverItem);
+ }
-// if (zlmServerConfig.getGeneralMediaServerId().equals(mediaConfig.getId())
-// || (zlmServerConfig.getIp().equals(mediaConfig.getIp()) && zlmServerConfig.getHttpPort() == mediaConfig.getHttpPort())) {
-// // 閰嶇疆鏂囦欢鐨剒lm
-// // 濡傛灉鏄厤缃枃浠朵腑鐨剒lm銆� 涔熷氨鏄粯璁lm銆� 涓�鍒囦互閰嶇疆鏂囦欢鍐呭涓哄噯
-// // wvp浜掓儬淇敼zlm鐨勭鍙ｏ紝闇�瑕佽嚜琛岄厤缃��
-// MediaServerItem serverItemFromConfig = mediaConfig.getMediaSerItem();
-// serverItemFromConfig.setId(zlmServerConfig.getGeneralMediaServerId());
-// if (mediaConfig.getHttpPort() == 0) {
-// serverItemFromConfig.setHttpPort(zlmServerConfig.getHttpPort());
-// }
-// if (mediaConfig.getHttpSSlPort() == 0) {
-// serverItemFromConfig.setHttpSSlPort(zlmServerConfig.getHttpSSLport());
-// }
-// if (mediaConfig.getRtmpPort() == 0) {
-// serverItemFromConfig.setRtmpPort(zlmServerConfig.getRtmpPort());
-// }
-// if (mediaConfig.getRtmpSSlPort() == 0) {
-// serverItemFromConfig.setRtmpSSlPort(zlmServerConfig.getRtmpSslPort());
-// }
-// if (mediaConfig.getRtspPort() == 0) {
-// serverItemFromConfig.setRtspPort(zlmServerConfig.getRtspPort());
-// }
-// if (mediaConfig.getRtspSSLPort() == 0) {
-// serverItemFromConfig.setRtspSSLPort(zlmServerConfig.getRtspSSlport());
-// }
-// if (mediaConfig.getRtpProxyPort() == 0) {
-// serverItemFromConfig.setRtpProxyPort(zlmServerConfig.getRtpProxyPort());
-// }
-// if (serverItem != null){
-// mediaServerMapper.delDefault();
-// mediaServerMapper.add(serverItemFromConfig);
-// String key = VideoManagerConstants.MEDIA_SERVER_PREFIX + serverItemFromConfig.getId();
-// MediaServerItem serverItemInRedis = (MediaServerItem)redisUtil.get(key);
-// if (serverItemInRedis != null) {
-// serverItemFromConfig.setSsrcConfig(serverItemInRedis.getSsrcConfig());
-// }else {
-// serverItemFromConfig.setSsrcConfig(new SsrcConfig(serverItemFromConfig.getId(), null, sipConfig.getDomain()));
-// }
-// redisUtil.set(key, serverItemFromConfig);
-// }else {
-// String key = VideoManagerConstants.MEDIA_SERVER_PREFIX + serverItemFromConfig.getId();
-// serverItemFromConfig.setSsrcConfig(new SsrcConfig(serverItemFromConfig.getId(), null, sipConfig.getDomain()));
-// redisUtil.set(key, serverItemFromConfig);
-// mediaServerMapper.add(serverItemFromConfig);
-// }
-// resetOnlineServerItem(serverItemFromConfig);
-// setZLMConfig(serverItemFromConfig);
-// }
- // 绉婚櫎鏈坊鍔犵殑zlm鐨勬帴鍏ワ紝鎵�鏈夌殑zlm蹇呴』鍏堟坊鍔犲悗鎵嶅彲浠ュ姞鍏ヤ娇鐢�
-// else {
-// String now = this.format.format(System.currentTimeMillis());
-// if (serverItem == null){
-// // 涓�涓柊鐨剒lm鎺ュ叆wvp
-// serverItem = new MediaServerItem(zlmServerConfig, sipConfig.getIp());
-// serverItem.setCreateTime(now);
-// serverItem.setUpdateTime(now);
-// String key = VideoManagerConstants.MEDIA_SERVER_PREFIX + serverItem.getId();
-// serverItem.setSsrcConfig(new SsrcConfig(serverItem.getId(), null, sipConfig.getDomain()));
-// redisUtil.set(key, serverItem);
-// // 瀛樺叆鏁版嵁搴�
-// mediaServerMapper.add(serverItem);
-// setZLMConfig(serverItem);
-// }
-// resetOnlineServerItem(serverItem);
-// }
+ @Override
+ public void zlmServerOffline(String mediaServerId) {
+ delete(mediaServerId);
}
@Override
@@ -611,9 +558,17 @@
@Override
public void delete(String id) {
- redisUtil.zRemove(VideoManagerConstants.MEDIA_SERVERS_ONLINE_PREFIX + userSetup.getServerId() + "_", id);
+ redisUtil.zRemove(VideoManagerConstants.MEDIA_SERVERS_ONLINE_PREFIX + userSetup.getServerId(), id);
String key = VideoManagerConstants.MEDIA_SERVER_PREFIX + userSetup.getServerId() + "_" + id;
redisUtil.del(key);
mediaServerMapper.delOne(id);
}
+
+ @Override
+ public void updateMediaServerKeepalive(String mediaServerId, JSONObject data) {
+ MediaServerItem mediaServerItem = getOne(mediaServerId);
+ String key = VideoManagerConstants.MEDIA_SERVER_KEEPALIVE_PREFIX + userSetup.getServerId() + "_" + mediaServerId;
+ int hookAliveInterval = mediaServerItem.getHookAliveInterval() + 2;
+ redisUtil.set(key, data, hookAliveInterval);
+ }
}
--
Gitblit v1.8.0