支持读取abl配置信息
648540858
parent
c1ac16bf62
commit
999192fa8a
|
|
@ -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);
|
||||
|
|
|
|||
|
|
@ -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<String, Object> 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<String, Object> 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());
|
||||
// }
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -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);
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -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<String, Field> 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;
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -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();
|
||||
}
|
||||
Loading…
Reference in New Issue