From 999192fa8afd1a5739953db8dc875ca1d0b0d811 Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: Sat, 23 Mar 2024 23:40:32 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=AF=E6=8C=81=E8=AF=BB=E5=8F=96abl?= =?UTF-8?q?=E9=85=8D=E7=BD=AE=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../vmp/media/abl/ABLHttpHookListener.java | 2 +- .../media/abl/ABLMediaServerStatusManger.java | 185 ++--- .../iot/vmp/media/abl/ABLRESTfulUtils.java | 2 +- .../vmp/media/abl/bean/AblServerConfig.java | 775 ++++++++++++++++++ .../iot/vmp/media/abl/bean/ConfigKeyId.java | 10 + 5 files changed, 878 insertions(+), 96 deletions(-) create mode 100644 src/main/java/com/genersoft/iot/vmp/media/abl/bean/ConfigKeyId.java diff --git a/src/main/java/com/genersoft/iot/vmp/media/abl/ABLHttpHookListener.java b/src/main/java/com/genersoft/iot/vmp/media/abl/ABLHttpHookListener.java index 026134ac..e3c19b1b 100755 --- a/src/main/java/com/genersoft/iot/vmp/media/abl/ABLHttpHookListener.java +++ b/src/main/java/com/genersoft/iot/vmp/media/abl/ABLHttpHookListener.java @@ -60,7 +60,7 @@ import java.util.UUID; * ABL服务Hook事件 */ @RestController -@RequestMapping("/index/hook") +@RequestMapping("/index/hook/abl") public class ABLHttpHookListener { private final static Logger logger = LoggerFactory.getLogger(ABLHttpHookListener.class); diff --git a/src/main/java/com/genersoft/iot/vmp/media/abl/ABLMediaServerStatusManger.java b/src/main/java/com/genersoft/iot/vmp/media/abl/ABLMediaServerStatusManger.java index 28181e89..0d2f043c 100644 --- a/src/main/java/com/genersoft/iot/vmp/media/abl/ABLMediaServerStatusManger.java +++ b/src/main/java/com/genersoft/iot/vmp/media/abl/ABLMediaServerStatusManger.java @@ -1,6 +1,5 @@ package com.genersoft.iot.vmp.media.abl; -import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSONArray; import com.alibaba.fastjson2.JSONObject; import com.genersoft.iot.vmp.conf.DynamicTask; @@ -12,9 +11,6 @@ import com.genersoft.iot.vmp.media.event.MediaServerChangeEvent; import com.genersoft.iot.vmp.media.event.MediaServerDeleteEvent; import com.genersoft.iot.vmp.media.service.IMediaServerService; import com.genersoft.iot.vmp.media.zlm.dto.MediaServer; -import com.genersoft.iot.vmp.media.zlm.dto.ZLMServerConfig; -import com.genersoft.iot.vmp.media.zlm.event.HookZlmServerKeepaliveEvent; -import com.genersoft.iot.vmp.media.zlm.event.HookZlmServerStartEvent; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; @@ -28,7 +24,6 @@ import org.springframework.util.ObjectUtils; import java.io.File; import java.util.HashMap; import java.util.Map; -import java.util.Objects; import java.util.concurrent.ConcurrentHashMap; /** @@ -136,17 +131,18 @@ public class ABLMediaServerStatusManger { continue; } logger.info("[ABL-尝试连接] ID：{}, 地址： {}:{}", mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); - JSONObject responseJson = ablResTfulUtils.getMediaServerConfig(mediaServerItem); + JSONObject responseJson = ablResTfulUtils.getServerConfig(mediaServerItem); AblServerConfig ablServerConfig = null; if (responseJson == null) { logger.info("[ABL-尝试连接]失败, ID：{}, 地址： {}:{}", mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); continue; } - JSONArray data = responseJson.getJSONArray("data"); + JSONArray data = responseJson.getJSONArray("params"); if (data == null || data.isEmpty()) { logger.info("[ABL-尝试连接]失败, ID：{}, 地址： {}:{}", mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); }else { - ablServerConfig = JSON.parseObject(JSON.toJSONString(data.get(0)), AblServerConfig.class); +// ablServerConfig = JSON.parseObject(JSON.toJSONString(data.get(0)), AblServerConfig.class); + ablServerConfig = AblServerConfig.getInstance(data); initPort(mediaServerItem, ablServerConfig); online(mediaServerItem, ablServerConfig); } @@ -158,21 +154,22 @@ public class ABLMediaServerStatusManger { continue; } logger.info("[ABL-尝试连接] ID：{}, 地址： {}:{}", mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); - JSONObject responseJson = ablResTfulUtils.getMediaServerConfig(mediaServerItem); - ZLMServerConfig zlmServerConfig = null; + JSONObject responseJson = ablResTfulUtils.getServerConfig(mediaServerItem); + AblServerConfig ablServerConfig = null; if (responseJson == null) { logger.info("[ABL-尝试连接]失败, ID：{}, 地址： {}:{}", mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); offlineAblTimeMap.put(mediaServerItem.getId(), System.currentTimeMillis()); continue; } - JSONArray data = responseJson.getJSONArray("data"); + JSONArray data = responseJson.getJSONArray("params"); if (data == null || data.isEmpty()) { logger.info("[ABL-尝试连接]失败, ID：{}, 地址： {}:{}", mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); offlineAblTimeMap.put(mediaServerItem.getId(), System.currentTimeMillis()); }else { - zlmServerConfig = JSON.parseObject(JSON.toJSONString(data.get(0)), ZLMServerConfig.class); - initPort(mediaServerItem, zlmServerConfig); - online(mediaServerItem, zlmServerConfig); +// ablServerConfig = JSON.parseObject(JSON.toJSONString(data.get(0)), ZLMServerConfig.class); + ablServerConfig = AblServerConfig.getInstance(data); + initPort(mediaServerItem, ablServerConfig); + online(mediaServerItem, ablServerConfig); } } } @@ -189,16 +186,16 @@ public class ABLMediaServerStatusManger { mediaServerService.update(mediaServerItem); if(mediaServerItem.isAutoConfig()) { if (config == null) { - JSONObject responseJSON = ablResTfulUtils.getMediaServerConfig(mediaServerItem); - JSONArray data = responseJSON.getJSONArray("data"); + JSONObject responseJSON = ablResTfulUtils.getServerConfig(mediaServerItem); + JSONArray data = responseJSON.getJSONArray("params"); if (data != null && !data.isEmpty()) { - config = JSON.parseObject(JSON.toJSONString(data.get(0)), AblServerConfig.class); +// config = JSON.parseObject(JSON.toJSONString(data.get(0)), AblServerConfig.class); + config = AblServerConfig.getInstance(data); } } if (config != null) { initPort(mediaServerItem, config); - setZLMConfig(mediaServerItem, "0".equals(config.getHookEnable()) - || !Objects.equals(mediaServerItem.getHookAliveInterval(), config.getHookAliveInterval())); + setAblConfig(mediaServerItem, false); } } mediaServerService.update(mediaServerItem); @@ -216,90 +213,90 @@ public class ABLMediaServerStatusManger { } private void initPort(MediaServer mediaServerItem, AblServerConfig ablServerConfig) { // 端口只会从配置中读取一次，一旦自己配置或者读取过了将不在配置 - if (mediaServerItem.getHttpSSlPort() == 0) { - mediaServerItem.setHttpSSlPort(ablServerConfig.getHttpSSLport()); - } +// if (mediaServerItem.getHttpSSlPort() == 0) { +// mediaServerItem.setHttpSSlPort(ablServerConfig.getHttpSSLport()); +// } if (mediaServerItem.getRtmpPort() == 0) { mediaServerItem.setRtmpPort(ablServerConfig.getRtmpPort()); } - if (mediaServerItem.getRtmpSSlPort() == 0) { - mediaServerItem.setRtmpSSlPort(ablServerConfig.getRtmpSslPort()); - } +// if (mediaServerItem.getRtmpSSlPort() == 0) { +// mediaServerItem.setRtmpSSlPort(ablServerConfig.getRtmpSslPort()); +// } if (mediaServerItem.getRtspPort() == 0) { mediaServerItem.setRtspPort(ablServerConfig.getRtspPort()); } - if (mediaServerItem.getRtspSSLPort() == 0) { - mediaServerItem.setRtspSSLPort(ablServerConfig.getRtspSSlport()); - } - if (mediaServerItem.getRtpProxyPort() == 0) { - mediaServerItem.setRtpProxyPort(ablServerConfig.getRtpProxyPort()); - } +// if (mediaServerItem.getRtspSSLPort() == 0) { +// mediaServerItem.setRtspSSLPort(ablServerConfig.getRtspSSlport()); +// } +// if (mediaServerItem.getRtpProxyPort() == 0) { +// mediaServerItem.setRtpProxyPort(ablServerConfig.getRtpProxyPort()); +// } mediaServerItem.setHookAliveInterval(10F); } - public void setZLMConfig(MediaServer mediaServerItem, boolean restart) { - logger.info("[媒体服务节点] 正在设置 ：{} -> {}:{}", - mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); - String protocol = sslEnabled ? "https" : "http"; - String hookPrefix = String.format("%s://%s:%s/index/hook", protocol, mediaServerItem.getHookIp(), serverPort); - - Map param = new HashMap<>(); - param.put("api.secret",mediaServerItem.getSecret()); // -profile:v Baseline - if (mediaServerItem.getRtspPort() != 0) { - param.put("ffmpeg.snap", "%s -rtsp_transport tcp -i %s -y -f mjpeg -frames:v 1 %s"); - } - param.put("hook.enable","1"); - param.put("hook.on_flow_report",""); - param.put("hook.on_play",String.format("%s/on_play", hookPrefix)); - param.put("hook.on_http_access",""); - param.put("hook.on_publish", String.format("%s/on_publish", hookPrefix)); - param.put("hook.on_record_ts",""); - param.put("hook.on_rtsp_auth",""); - param.put("hook.on_rtsp_realm",""); - param.put("hook.on_server_started",String.format("%s/on_server_started", hookPrefix)); - param.put("hook.on_shell_login",""); - param.put("hook.on_stream_changed",String.format("%s/on_stream_changed", hookPrefix)); - param.put("hook.on_stream_none_reader",String.format("%s/on_stream_none_reader", hookPrefix)); - param.put("hook.on_stream_not_found",String.format("%s/on_stream_not_found", hookPrefix)); - param.put("hook.on_server_keepalive",String.format("%s/on_server_keepalive", hookPrefix)); - param.put("hook.on_send_rtp_stopped",String.format("%s/on_send_rtp_stopped", hookPrefix)); - param.put("hook.on_rtp_server_timeout",String.format("%s/on_rtp_server_timeout", hookPrefix)); - param.put("hook.on_record_mp4",String.format("%s/on_record_mp4", hookPrefix)); - param.put("hook.timeoutSec","30"); - param.put("hook.alive_interval", mediaServerItem.getHookAliveInterval()); - // 推流断开后可以在超时时间内重新连接上继续推流，这样播放器会接着播放。 - // 置0关闭此特性(推流断开会导致立即断开播放器) - // 此参数不应大于播放器超时时间 - // 优化此消息以更快的收到流注销事件 - param.put("protocol.continue_push_ms", "3000" ); - // 最多等待未初始化的Track时间，单位毫秒，超时之后会忽略未初始化的Track, 设置此选项优化那些音频错误的不规范流， - // 等zlm支持给每个rtpServer设置关闭音频的时候可以不设置此选项 - if (mediaServerItem.isRtpEnable() && !ObjectUtils.isEmpty(mediaServerItem.getRtpPortRange())) { - param.put("rtp_proxy.port_range", mediaServerItem.getRtpPortRange().replace(",", "-")); - } - - if (!ObjectUtils.isEmpty(mediaServerItem.getRecordPath())) { - File recordPathFile = new File(mediaServerItem.getRecordPath()); - param.put("protocol.mp4_save_path", recordPathFile.getParentFile().getPath()); - param.put("protocol.downloadRoot", recordPathFile.getParentFile().getPath()); - param.put("record.appName", recordPathFile.getName()); - } - - JSONObject responseJSON = ablResTfulUtils.setServerConfig(mediaServerItem, param); - - if (responseJSON != null && responseJSON.getInteger("code") == 0) { - if (restart) { - logger.info("[媒体服务节点] 设置成功,开始重启以保证配置生效 {} -> {}:{}", - mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); - ablResTfulUtils.restartServer(mediaServerItem); - }else { - logger.info("[媒体服务节点] 设置成功 {} -> {}:{}", - mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); - } - }else { - logger.info("[媒体服务节点] 设置媒体服务节点失败 {} -> {}:{}", - mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); - } + public void setAblConfig(MediaServer mediaServerItem, boolean restart) { +// logger.info("[媒体服务节点] 正在设置 ：{} -> {}:{}", +// mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); +// String protocol = sslEnabled ? "https" : "http"; +// String hookPrefix = String.format("%s://%s:%s/index/hook", protocol, mediaServerItem.getHookIp(), serverPort); +// +// Map param = new HashMap<>(); +// param.put("api.secret",mediaServerItem.getSecret()); // -profile:v Baseline +// if (mediaServerItem.getRtspPort() != 0) { +// param.put("ffmpeg.snap", "%s -rtsp_transport tcp -i %s -y -f mjpeg -frames:v 1 %s"); +// } +// param.put("hook.enable","1"); +// param.put("hook.on_flow_report",""); +// param.put("hook.on_play",String.format("%s/on_play", hookPrefix)); +// param.put("hook.on_http_access",""); +// param.put("hook.on_publish", String.format("%s/on_publish", hookPrefix)); +// param.put("hook.on_record_ts",""); +// param.put("hook.on_rtsp_auth",""); +// param.put("hook.on_rtsp_realm",""); +// param.put("hook.on_server_started",String.format("%s/on_server_started", hookPrefix)); +// param.put("hook.on_shell_login",""); +// param.put("hook.on_stream_changed",String.format("%s/on_stream_changed", hookPrefix)); +// param.put("hook.on_stream_none_reader",String.format("%s/on_stream_none_reader", hookPrefix)); +// param.put("hook.on_stream_not_found",String.format("%s/on_stream_not_found", hookPrefix)); +// param.put("hook.on_server_keepalive",String.format("%s/on_server_keepalive", hookPrefix)); +// param.put("hook.on_send_rtp_stopped",String.format("%s/on_send_rtp_stopped", hookPrefix)); +// param.put("hook.on_rtp_server_timeout",String.format("%s/on_rtp_server_timeout", hookPrefix)); +// param.put("hook.on_record_mp4",String.format("%s/on_record_mp4", hookPrefix)); +// param.put("hook.timeoutSec","30"); +// param.put("hook.alive_interval", mediaServerItem.getHookAliveInterval()); +// // 推流断开后可以在超时时间内重新连接上继续推流，这样播放器会接着播放。 +// // 置0关闭此特性(推流断开会导致立即断开播放器) +// // 此参数不应大于播放器超时时间 +// // 优化此消息以更快的收到流注销事件 +// param.put("protocol.continue_push_ms", "3000" ); +// // 最多等待未初始化的Track时间，单位毫秒，超时之后会忽略未初始化的Track, 设置此选项优化那些音频错误的不规范流， +// // 等zlm支持给每个rtpServer设置关闭音频的时候可以不设置此选项 +// if (mediaServerItem.isRtpEnable() && !ObjectUtils.isEmpty(mediaServerItem.getRtpPortRange())) { +// param.put("rtp_proxy.port_range", mediaServerItem.getRtpPortRange().replace(",", "-")); +// } +// +// if (!ObjectUtils.isEmpty(mediaServerItem.getRecordPath())) { +// File recordPathFile = new File(mediaServerItem.getRecordPath()); +// param.put("protocol.mp4_save_path", recordPathFile.getParentFile().getPath()); +// param.put("protocol.downloadRoot", recordPathFile.getParentFile().getPath()); +// param.put("record.appName", recordPathFile.getName()); +// } +// +// JSONObject responseJSON = ablResTfulUtils.setServerConfig(mediaServerItem, param); +// +// if (responseJSON != null && responseJSON.getInteger("code") == 0) { +// if (restart) { +// logger.info("[媒体服务节点] 设置成功,开始重启以保证配置生效 {} -> {}:{}", +// mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); +// ablResTfulUtils.restartServer(mediaServerItem); +// }else { +// logger.info("[媒体服务节点] 设置成功 {} -> {}:{}", +// mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); +// } +// }else { +// logger.info("[媒体服务节点] 设置媒体服务节点失败 {} -> {}:{}", +// mediaServerItem.getId(), mediaServerItem.getIp(), mediaServerItem.getHttpPort()); +// } } } diff --git a/src/main/java/com/genersoft/iot/vmp/media/abl/ABLRESTfulUtils.java b/src/main/java/com/genersoft/iot/vmp/media/abl/ABLRESTfulUtils.java index ce943249..02a9b667 100755 --- a/src/main/java/com/genersoft/iot/vmp/media/abl/ABLRESTfulUtils.java +++ b/src/main/java/com/genersoft/iot/vmp/media/abl/ABLRESTfulUtils.java @@ -281,7 +281,7 @@ public class ABLRESTfulUtils { return sendPost(mediaServerItem, "delStreamProxy",param, null); } - public JSONObject getMediaServerConfig(MediaServer mediaServerItem){ + public JSONObject getServerConfig(MediaServer mediaServerItem){ return sendPost(mediaServerItem, "getServerConfig",null, null); } diff --git a/src/main/java/com/genersoft/iot/vmp/media/abl/bean/AblServerConfig.java b/src/main/java/com/genersoft/iot/vmp/media/abl/bean/AblServerConfig.java index 48983265..e7aac3a7 100644 --- a/src/main/java/com/genersoft/iot/vmp/media/abl/bean/AblServerConfig.java +++ b/src/main/java/com/genersoft/iot/vmp/media/abl/bean/AblServerConfig.java @@ -1,4 +1,779 @@ package com.genersoft.iot.vmp.media.abl.bean; +import com.alibaba.fastjson2.JSONArray; +import com.alibaba.fastjson2.JSONObject; + +import java.lang.reflect.Field; +import java.util.HashMap; +import java.util.Map; + public class AblServerConfig { + + @ConfigKeyId("secret") + private String secret; + + @ConfigKeyId("ServerIP") + private String serverIp; + + @ConfigKeyId("mediaServerID") + private String mediaServerId; + + @ConfigKeyId("hook_enable") + private Integer hookEnable; + + @ConfigKeyId("enable_audio") + private Integer enableAudio; + + @ConfigKeyId("httpServerPort") + private Integer httpServerPort; + + @ConfigKeyId("rtspPort") + private Integer rtspPort; + + @ConfigKeyId("rtmpPort") + private Integer rtmpPort; + + @ConfigKeyId("httpFlvPort") + private Integer httpFlvPort; + + @ConfigKeyId("hls_enable") + private Integer hlsEnable; + + @ConfigKeyId("hlsPort") + private Integer hlsPort; + + @ConfigKeyId("wsPort") + private Integer wsPort; + + @ConfigKeyId("mp4Port") + private Integer mp4Port; + + @ConfigKeyId("ps_tsRecvPort") + private Integer psTsRecvPort; + + @ConfigKeyId("hlsCutType") + private Integer hlsCutType; + + @ConfigKeyId("h265CutType") + private Integer h265CutType; + + @ConfigKeyId("RecvThreadCount") + private Integer RecvThreadCount; + + @ConfigKeyId("SendThreadCount") + private Integer SendThreadCount; + + @ConfigKeyId("GB28181RtpTCPHeadType") + private Integer GB28181RtpTCPHeadType; + + @ConfigKeyId("ReConnectingCount") + private Integer ReConnectingCount; + + @ConfigKeyId("maxTimeNoOneWatch") + private Integer maxTimeNoOneWatch; + + @ConfigKeyId("pushEnable_mp4") + private Integer pushEnableMp4; + + @ConfigKeyId("fileSecond") + private Integer fileSecond; + + @ConfigKeyId("fileKeepMaxTime") + private Integer fileKeepMaxTime; + + @ConfigKeyId("httpDownloadSpeed") + private Integer httpDownloadSpeed; + + @ConfigKeyId("RecordReplayThread") + private Integer RecordReplayThread; + + @ConfigKeyId("convertMaxObject") + private Integer convertMaxObject; + + @ConfigKeyId("version") + private String version; + + @ConfigKeyId("recordPath") + private String recordPath; + + @ConfigKeyId("picturePath") + private String picturePath; + + @ConfigKeyId("noneReaderDuration") + private Integer noneReaderDuration; + + @ConfigKeyId("on_server_started") + private String onServerStarted; + + @ConfigKeyId("on_server_keepalive") + private String onServerKeepalive; + + @ConfigKeyId("on_play") + private String onPlay; + + @ConfigKeyId("on_publish") + private String onPublish; + + @ConfigKeyId("on_stream_arrive") + private String onStreamArrive; + + @ConfigKeyId("on_stream_not_arrive") + private String onStreamNotArrive; + + @ConfigKeyId("on_stream_none_reader") + private String onStreamNoneReader; + + @ConfigKeyId("on_stream_disconnect") + private String onStreamDisconnect; + + @ConfigKeyId("on_delete_record_mp4") + private String onDeleteRecordMp4; + + @ConfigKeyId("on_record_progress") + private String onRecordProgress; + + @ConfigKeyId("on_record_ts") + private String onRecordTs; + + @ConfigKeyId("enable_GetFileDuration") + private Integer enableGetFileDuration; + + @ConfigKeyId("keepaliveDuration") + private Integer keepaliveDuration; + + @ConfigKeyId("captureReplayType") + private Integer captureReplayType; + + @ConfigKeyId("videoFileFormat") + private Integer videoFileFormat; + + @ConfigKeyId("MaxDiconnectTimeoutSecond") + private Integer maxDiconnectTimeoutSecond; + + @ConfigKeyId("G711ConvertAAC") + private Integer g711ConvertAAC; + + @ConfigKeyId("filterVideo_enable") + private Integer filterVideoEnable; + + @ConfigKeyId("filterVideo_text") + private String filterVideoText; + + @ConfigKeyId("FilterFontSize") + private Integer filterFontSize; + + @ConfigKeyId("FilterFontColor") + private String filterFontColor; + + @ConfigKeyId("FilterFontLeft") + private Integer filterFontLeft; + + @ConfigKeyId("FilterFontTop") + private Integer filterFontTop; + + @ConfigKeyId("FilterFontAlpha") + private Double filterFontAlpha; + + @ConfigKeyId("convertOutWidth") + private Integer convertOutWidth; + + @ConfigKeyId("convertOutHeight") + private Integer convertOutHeight; + + @ConfigKeyId("convertOutBitrate") + private Integer convertOutBitrate; + + @ConfigKeyId("flvPlayAddMute") + private Integer flvPlayAddMute; + + @ConfigKeyId("gb28181LibraryUse") + private Integer gb28181LibraryUse; + + @ConfigKeyId("rtc.listening-ip") + private String rtcListeningIp; + + @ConfigKeyId("rtc.listening-port") + private Integer rtcListeningIpPort; + + @ConfigKeyId("rtc.external-ip") + private String rtcExternalIp; + + @ConfigKeyId("rtc.realm") + private String rtcRealm; + + @ConfigKeyId("rtc.user") + private String rtcUser; + + @ConfigKeyId("rtc.min-port") + private Integer rtcMinPort; + + @ConfigKeyId("rtc.max-port") + private Integer rtcMaxPort; + + public static AblServerConfig getInstance(JSONArray jsonArray) { + if (jsonArray == null || jsonArray.isEmpty()) { + return null; + } + AblServerConfig ablServerConfig = new AblServerConfig(); + Field[] fields = AblServerConfig.class.getDeclaredFields(); + Map fieldMap = new HashMap<>(); + for (Field field : fields) { + if (field.isAnnotationPresent(ConfigKeyId.class)) { + ConfigKeyId configKeyId = field.getAnnotation(ConfigKeyId.class); + fieldMap.put(configKeyId.value(), field); + } + } + for (int i = 0; i < jsonArray.size(); i++) { + JSONObject jsonObject = jsonArray.getJSONObject(i); + if (jsonObject == null) { + continue; + } + for (String key : fieldMap.keySet()) { + if (jsonObject.containsKey(key)) { + Field field = fieldMap.get(key); + field.setAccessible(true); + try { + field.set(ablServerConfig, jsonObject.getObject(key, fieldMap.get(key).getType())); + } catch (IllegalAccessException e) {} + } + } + } + return ablServerConfig; + } + + public String getSecret() { + return secret; + } + + public void setSecret(String secret) { + this.secret = secret; + } + + public String getServerIp() { + return serverIp; + } + + public void setServerIp(String serverIp) { + this.serverIp = serverIp; + } + + public String getMediaServerId() { + return mediaServerId; + } + + public void setMediaServerId(String mediaServerId) { + this.mediaServerId = mediaServerId; + } + + public Integer getHookEnable() { + return hookEnable; + } + + public void setHookEnable(Integer hookEnable) { + this.hookEnable = hookEnable; + } + + public Integer getEnableAudio() { + return enableAudio; + } + + public void setEnableAudio(Integer enableAudio) { + this.enableAudio = enableAudio; + } + + public Integer getHttpServerPort() { + return httpServerPort; + } + + public void setHttpServerPort(Integer httpServerPort) { + this.httpServerPort = httpServerPort; + } + + public Integer getRtspPort() { + return rtspPort; + } + + public void setRtspPort(Integer rtspPort) { + this.rtspPort = rtspPort; + } + + public Integer getRtmpPort() { + return rtmpPort; + } + + public void setRtmpPort(Integer rtmpPort) { + this.rtmpPort = rtmpPort; + } + + public Integer getHttpFlvPort() { + return httpFlvPort; + } + + public void setHttpFlvPort(Integer httpFlvPort) { + this.httpFlvPort = httpFlvPort; + } + + public Integer getHlsEnable() { + return hlsEnable; + } + + public void setHlsEnable(Integer hlsEnable) { + this.hlsEnable = hlsEnable; + } + + public Integer getHlsPort() { + return hlsPort; + } + + public void setHlsPort(Integer hlsPort) { + this.hlsPort = hlsPort; + } + + public Integer getWsPort() { + return wsPort; + } + + public void setWsPort(Integer wsPort) { + this.wsPort = wsPort; + } + + public Integer getMp4Port() { + return mp4Port; + } + + public void setMp4Port(Integer mp4Port) { + this.mp4Port = mp4Port; + } + + public Integer getPsTsRecvPort() { + return psTsRecvPort; + } + + public void setPsTsRecvPort(Integer psTsRecvPort) { + this.psTsRecvPort = psTsRecvPort; + } + + public Integer getHlsCutType() { + return hlsCutType; + } + + public void setHlsCutType(Integer hlsCutType) { + this.hlsCutType = hlsCutType; + } + + public Integer getH265CutType() { + return h265CutType; + } + + public void setH265CutType(Integer h265CutType) { + this.h265CutType = h265CutType; + } + + public Integer getRecvThreadCount() { + return RecvThreadCount; + } + + public void setRecvThreadCount(Integer recvThreadCount) { + RecvThreadCount = recvThreadCount; + } + + public Integer getSendThreadCount() { + return SendThreadCount; + } + + public void setSendThreadCount(Integer sendThreadCount) { + SendThreadCount = sendThreadCount; + } + + public Integer getGB28181RtpTCPHeadType() { + return GB28181RtpTCPHeadType; + } + + public void setGB28181RtpTCPHeadType(Integer GB28181RtpTCPHeadType) { + this.GB28181RtpTCPHeadType = GB28181RtpTCPHeadType; + } + + public Integer getReConnectingCount() { + return ReConnectingCount; + } + + public void setReConnectingCount(Integer reConnectingCount) { + ReConnectingCount = reConnectingCount; + } + + public Integer getMaxTimeNoOneWatch() { + return maxTimeNoOneWatch; + } + + public void setMaxTimeNoOneWatch(Integer maxTimeNoOneWatch) { + this.maxTimeNoOneWatch = maxTimeNoOneWatch; + } + + public Integer getPushEnableMp4() { + return pushEnableMp4; + } + + public void setPushEnableMp4(Integer pushEnableMp4) { + this.pushEnableMp4 = pushEnableMp4; + } + + public Integer getFileSecond() { + return fileSecond; + } + + public void setFileSecond(Integer fileSecond) { + this.fileSecond = fileSecond; + } + + public Integer getFileKeepMaxTime() { + return fileKeepMaxTime; + } + + public void setFileKeepMaxTime(Integer fileKeepMaxTime) { + this.fileKeepMaxTime = fileKeepMaxTime; + } + + public Integer getHttpDownloadSpeed() { + return httpDownloadSpeed; + } + + public void setHttpDownloadSpeed(Integer httpDownloadSpeed) { + this.httpDownloadSpeed = httpDownloadSpeed; + } + + public Integer getRecordReplayThread() { + return RecordReplayThread; + } + + public void setRecordReplayThread(Integer recordReplayThread) { + RecordReplayThread = recordReplayThread; + } + + public Integer getConvertMaxObject() { + return convertMaxObject; + } + + public void setConvertMaxObject(Integer convertMaxObject) { + this.convertMaxObject = convertMaxObject; + } + + public String getVersion() { + return version; + } + + public void setVersion(String version) { + this.version = version; + } + + public String getRecordPath() { + return recordPath; + } + + public void setRecordPath(String recordPath) { + this.recordPath = recordPath; + } + + public String getPicturePath() { + return picturePath; + } + + public void setPicturePath(String picturePath) { + this.picturePath = picturePath; + } + + public Integer getNoneReaderDuration() { + return noneReaderDuration; + } + + public void setNoneReaderDuration(Integer noneReaderDuration) { + this.noneReaderDuration = noneReaderDuration; + } + + public String getOnServerStarted() { + return onServerStarted; + } + + public void setOnServerStarted(String onServerStarted) { + this.onServerStarted = onServerStarted; + } + + public String getOnServerKeepalive() { + return onServerKeepalive; + } + + public void setOnServerKeepalive(String onServerKeepalive) { + this.onServerKeepalive = onServerKeepalive; + } + + public String getOnPlay() { + return onPlay; + } + + public void setOnPlay(String onPlay) { + this.onPlay = onPlay; + } + + public String getOnPublish() { + return onPublish; + } + + public void setOnPublish(String onPublish) { + this.onPublish = onPublish; + } + + public String getOnStreamArrive() { + return onStreamArrive; + } + + public void setOnStreamArrive(String onStreamArrive) { + this.onStreamArrive = onStreamArrive; + } + + public String getOnStreamNotArrive() { + return onStreamNotArrive; + } + + public void setOnStreamNotArrive(String onStreamNotArrive) { + this.onStreamNotArrive = onStreamNotArrive; + } + + public String getOnStreamNoneReader() { + return onStreamNoneReader; + } + + public void setOnStreamNoneReader(String onStreamNoneReader) { + this.onStreamNoneReader = onStreamNoneReader; + } + + public String getOnStreamDisconnect() { + return onStreamDisconnect; + } + + public void setOnStreamDisconnect(String onStreamDisconnect) { + this.onStreamDisconnect = onStreamDisconnect; + } + + public String getOnDeleteRecordMp4() { + return onDeleteRecordMp4; + } + + public void setOnDeleteRecordMp4(String onDeleteRecordMp4) { + this.onDeleteRecordMp4 = onDeleteRecordMp4; + } + + public String getOnRecordProgress() { + return onRecordProgress; + } + + public void setOnRecordProgress(String onRecordProgress) { + this.onRecordProgress = onRecordProgress; + } + + public String getOnRecordTs() { + return onRecordTs; + } + + public void setOnRecordTs(String onRecordTs) { + this.onRecordTs = onRecordTs; + } + + public Integer getEnableGetFileDuration() { + return enableGetFileDuration; + } + + public void setEnableGetFileDuration(Integer enableGetFileDuration) { + this.enableGetFileDuration = enableGetFileDuration; + } + + public Integer getKeepaliveDuration() { + return keepaliveDuration; + } + + public void setKeepaliveDuration(Integer keepaliveDuration) { + this.keepaliveDuration = keepaliveDuration; + } + + public Integer getCaptureReplayType() { + return captureReplayType; + } + + public void setCaptureReplayType(Integer captureReplayType) { + this.captureReplayType = captureReplayType; + } + + public Integer getVideoFileFormat() { + return videoFileFormat; + } + + public void setVideoFileFormat(Integer videoFileFormat) { + this.videoFileFormat = videoFileFormat; + } + + public Integer getMaxDiconnectTimeoutSecond() { + return maxDiconnectTimeoutSecond; + } + + public void setMaxDiconnectTimeoutSecond(Integer maxDiconnectTimeoutSecond) { + this.maxDiconnectTimeoutSecond = maxDiconnectTimeoutSecond; + } + + public Integer getG711ConvertAAC() { + return g711ConvertAAC; + } + + public void setG711ConvertAAC(Integer g711ConvertAAC) { + this.g711ConvertAAC = g711ConvertAAC; + } + + public Integer getFilterVideoEnable() { + return filterVideoEnable; + } + + public void setFilterVideoEnable(Integer filterVideoEnable) { + this.filterVideoEnable = filterVideoEnable; + } + + public String getFilterVideoText() { + return filterVideoText; + } + + public void setFilterVideoText(String filterVideoText) { + this.filterVideoText = filterVideoText; + } + + public Integer getFilterFontSize() { + return filterFontSize; + } + + public void setFilterFontSize(Integer filterFontSize) { + this.filterFontSize = filterFontSize; + } + + public String getFilterFontColor() { + return filterFontColor; + } + + public void setFilterFontColor(String filterFontColor) { + this.filterFontColor = filterFontColor; + } + + public Integer getFilterFontLeft() { + return filterFontLeft; + } + + public void setFilterFontLeft(Integer filterFontLeft) { + this.filterFontLeft = filterFontLeft; + } + + public Integer getFilterFontTop() { + return filterFontTop; + } + + public void setFilterFontTop(Integer filterFontTop) { + this.filterFontTop = filterFontTop; + } + + public Double getFilterFontAlpha() { + return filterFontAlpha; + } + + public void setFilterFontAlpha(Double filterFontAlpha) { + this.filterFontAlpha = filterFontAlpha; + } + + public Integer getConvertOutWidth() { + return convertOutWidth; + } + + public void setConvertOutWidth(Integer convertOutWidth) { + this.convertOutWidth = convertOutWidth; + } + + public Integer getConvertOutHeight() { + return convertOutHeight; + } + + public void setConvertOutHeight(Integer convertOutHeight) { + this.convertOutHeight = convertOutHeight; + } + + public Integer getConvertOutBitrate() { + return convertOutBitrate; + } + + public void setConvertOutBitrate(Integer convertOutBitrate) { + this.convertOutBitrate = convertOutBitrate; + } + + public Integer getFlvPlayAddMute() { + return flvPlayAddMute; + } + + public void setFlvPlayAddMute(Integer flvPlayAddMute) { + this.flvPlayAddMute = flvPlayAddMute; + } + + public Integer getGb28181LibraryUse() { + return gb28181LibraryUse; + } + + public void setGb28181LibraryUse(Integer gb28181LibraryUse) { + this.gb28181LibraryUse = gb28181LibraryUse; + } + + public String getRtcListeningIp() { + return rtcListeningIp; + } + + public void setRtcListeningIp(String rtcListeningIp) { + this.rtcListeningIp = rtcListeningIp; + } + + public Integer getRtcListeningIpPort() { + return rtcListeningIpPort; + } + + public void setRtcListeningIpPort(Integer rtcListeningIpPort) { + this.rtcListeningIpPort = rtcListeningIpPort; + } + + public String getRtcExternalIp() { + return rtcExternalIp; + } + + public void setRtcExternalIp(String rtcExternalIp) { + this.rtcExternalIp = rtcExternalIp; + } + + public String getRtcRealm() { + return rtcRealm; + } + + public void setRtcRealm(String rtcRealm) { + this.rtcRealm = rtcRealm; + } + + public String getRtcUser() { + return rtcUser; + } + + public void setRtcUser(String rtcUser) { + this.rtcUser = rtcUser; + } + + public Integer getRtcMinPort() { + return rtcMinPort; + } + + public void setRtcMinPort(Integer rtcMinPort) { + this.rtcMinPort = rtcMinPort; + } + + public Integer getRtcMaxPort() { + return rtcMaxPort; + } + + public void setRtcMaxPort(Integer rtcMaxPort) { + this.rtcMaxPort = rtcMaxPort; + } } diff --git a/src/main/java/com/genersoft/iot/vmp/media/abl/bean/ConfigKeyId.java b/src/main/java/com/genersoft/iot/vmp/media/abl/bean/ConfigKeyId.java new file mode 100644 index 00000000..244bb949 --- /dev/null +++ b/src/main/java/com/genersoft/iot/vmp/media/abl/bean/ConfigKeyId.java @@ -0,0 +1,10 @@ +package com.genersoft.iot.vmp.media.abl.bean; + +import java.lang.annotation.*; + +@Target(ElementType.FIELD) +@Retention(RetentionPolicy.RUNTIME) +@Documented +public @interface ConfigKeyId { + String value(); +}