package com.netsdk.demo.customize.configuration;
|
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.Utils;
|
import com.netsdk.lib.enumeration.EM_SERVER_OPTION;
|
import com.netsdk.lib.enumeration.NET_EM_CFG_OPERATE_TYPE;
|
import com.netsdk.lib.structure.*;
|
import com.netsdk.module.ConfigModule;
|
import com.netsdk.module.entity.DeviceInfo;
|
import com.sun.jna.Memory;
|
import com.sun.jna.Pointer;
|
|
import java.nio.charset.Charset;
|
|
/**
|
* 第三方配置 获取/下发
|
*
|
* @author 47040
|
* @version 1.0.0
|
* @since Created in 2021/3/9 13:50
|
*/
|
public class ThirdPartyConfiguration {
|
|
// netsdk 接口
|
private final NetSDKLib netSdkApi = NetSDKLib.NETSDK_INSTANCE;
|
|
private final ConfigInitAndLogon initModule = new ConfigInitAndLogon(netSdkApi);
|
|
// 多平台 编码
|
private Charset encode = Charset.forName(Utils.getPlatformEncode());
|
|
/**
|
* 二次封装模块,包含一些设备配置的接口
|
*/
|
private final ConfigModule configModule = new ConfigModule(netSdkApi);
|
|
/**
|
* 登录句柄值
|
*/
|
private long loginHandler;
|
|
////////////////////////////////////////////////////////////////////////////////////////////////
|
/////////////////////////////////// 第三方配置 获取/下发 /////////////////////////////////////////
|
////////////////////////////////////////////////////////////////////////////////////////////////
|
|
/**
|
* 获取 平台接入配置(国标服务端)
|
*/
|
public void getVspGaysServerConfig() {
|
NET_CFG_VSP_GAYS_SERVER_INFO config = new NET_CFG_VSP_GAYS_SERVER_INFO();
|
config.nSipServerInfoNum = 5; // 获取配置的数量 填最大值就行了
|
for (int i = 0; i < config.nSipServerInfoNum; i++) {
|
int nChannelNum = initModule.deviceInfo.getByChanNum();
|
|
config.stuSipServerInfo[i].nChannelInfoNum = nChannelNum; // 这里填设备通道数就行
|
config.stuSipServerInfo[i].pstuChannelInfo = new Memory((new NET_CHANNEL_INFO().size()) * nChannelNum);
|
|
config.stuSipServerInfo[i].nAlarmInfoNum = nChannelNum; // 这里也填设备通道数就行
|
config.stuSipServerInfo[i].pstuAlarmInfo = new Memory((new NET_ALARM_INFO().size()) * nChannelNum);
|
|
config.stuSipServerInfo[i].nAudioOutputChnInfoNum = nChannelNum; // 这里还是填设备通道数
|
config.stuSipServerInfo[i].pstuAudioOutputChnInfo = new Memory((new NET_AUDIO_OUTPUT_CHANNEL_INFO().size()) * nChannelNum);
|
|
}
|
|
config = (NET_CFG_VSP_GAYS_SERVER_INFO)
|
configModule.getConfig(
|
loginHandler, // 登录句柄
|
NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_VSP_GAYS_SERVER, // 枚举->平台接入配置(国标服务端)
|
config, // 配置结构体
|
-1 // 通道号 固定-1
|
);
|
if (config == null) {
|
System.err.println("获取平台接入配置(国标服务端)失败:" + ToolKits.getErrorCode());
|
return;
|
}
|
|
// 打印展示
|
StringBuilder info = new StringBuilder().append("---------- 设备平台接入配置信息 ----------").append("\n");
|
int retCount = config.nRetSipServerInfoNum;
|
info.append(String.format("( 共包含%d个配置 )", retCount)).append("\n");
|
for (int i = 0; i < retCount; i++) {
|
|
String serverOption = EM_SERVER_OPTION.getEnum(config.stuSipServerInfo[i].emServerOption).getNote();
|
String sipSvrId = new String(config.stuSipServerInfo[i].szSipSvrId, encode).trim();
|
String domain = new String(config.stuSipServerInfo[i].szDomain, encode).trim();
|
String sipSvrIp = new String(config.stuSipServerInfo[i].szSipSvrIp, encode).trim();
|
String deviceId = new String(config.stuSipServerInfo[i].szDeviceId, encode).trim();
|
String password = new String(config.stuSipServerInfo[i].szPassword, encode).trim();
|
String localSipPort = String.valueOf(config.stuSipServerInfo[i].nLocalSipPort);
|
String sipSvrPort = String.valueOf(config.stuSipServerInfo[i].nSipSvrPort);
|
String sipRegExpires = String.valueOf(config.stuSipServerInfo[i].nSipRegExpires);
|
String regInterval = String.valueOf(config.stuSipServerInfo[i].nRegInterval);
|
String keepAliveCircle = String.valueOf(config.stuSipServerInfo[i].nKeepAliveCircle);
|
String maxTimeoutTimes = String.valueOf(config.stuSipServerInfo[i].nMaxTimeoutTimes);
|
String civilCode = new String(config.stuSipServerInfo[i].szCivilCode, encode).trim();
|
String interVideoID = new String(config.stuSipServerInfo[i].szIntervideoID).trim();
|
|
info.append(String.format(">>>>> 第【%d】配置详情 <<<<<", i + 1)).append("\n")
|
.append(String.format(" %s: ", "启动选项")).append(serverOption).append("\n")
|
.append(String.format(" %s: ", "SIP服务器编号")).append(sipSvrId).append("\n")
|
.append(String.format(" %s: ", "SIP域")).append(domain).append("\n")
|
.append(String.format(" %s: ", "SIP服务器 IP")).append(sipSvrIp).append("\n")
|
.append(String.format(" %s: ", "设备编号")).append(deviceId).append("\n")
|
.append(String.format(" %s: ", "注册密码")).append(password).append("\n")
|
.append(String.format(" %s: ", "本地SIP服务端口")).append(localSipPort).append("\n")
|
.append(String.format(" %s: ", "SIP服务器端口")).append(sipSvrPort).append("\n")
|
.append(String.format(" %s: ", "注册有效期 单位秒")).append(sipRegExpires).append("\n")
|
.append(String.format(" %s: ", "注册失败后重注册间隔 单位秒")).append(regInterval).append("\n")
|
.append(String.format(" %s: ", "心跳周期 单位秒")).append(keepAliveCircle).append("\n")
|
.append(String.format(" %s: ", "最大心跳超时次数")).append(maxTimeoutTimes).append("\n")
|
.append(String.format(" %s: ", "行政区划代码")).append(civilCode).append("\n")
|
.append(String.format(" %s: ", "接入模块识别码")).append(interVideoID).append("\n");
|
|
info.append(" ------ 通道信息 ------").append("\n");
|
|
int retChannelInfoCount = config.stuSipServerInfo[i].nRetChannelInfoNum;
|
if (retChannelInfoCount != 0) {
|
NET_CHANNEL_INFO[] channelInfos = new NET_CHANNEL_INFO[retChannelInfoCount];
|
for (int j = 0; j < retChannelInfoCount; j++) {
|
channelInfos[j] = new NET_CHANNEL_INFO();
|
}
|
Pointer pChannelInfo = config.stuSipServerInfo[i].pstuChannelInfo;
|
ToolKits.GetPointerDataToStructArr(pChannelInfo, channelInfos);
|
|
for (int j = 0; j < retChannelInfoCount; j++) {
|
String channelID = new String(channelInfos[j].szID, encode);
|
String alarmLevel = String.valueOf(channelInfos[j].nAlarmLevel);
|
|
info.append(String.format(" >>> 第【%d】个通道信息详情 <<<", j + 1)).append("\n")
|
.append(String.format(" %s: ", "通道编号")).append(channelID).append("\n")
|
.append(String.format(" %s: ", "报警级别 范围 [1,6]")).append(alarmLevel).append("\n");
|
}
|
} else {
|
info.append(" 不存在通道信息").append("\n");
|
}
|
|
info.append(" ------ 报警通道信息 ------").append("\n");
|
|
int retAlarmInfoCount = config.stuSipServerInfo[i].nRetAlarmInfoNum;
|
if (retAlarmInfoCount != 0) {
|
NET_ALARM_INFO[] alarmInfos = new NET_ALARM_INFO[retAlarmInfoCount];
|
for (int j = 0; j < retAlarmInfoCount; j++) {
|
alarmInfos[j] = new NET_ALARM_INFO();
|
}
|
Pointer pAlarmInfo = config.stuSipServerInfo[i].pstuAlarmInfo;
|
ToolKits.GetPointerDataToStructArr(pAlarmInfo, alarmInfos);
|
|
for (int j = 0; j < retAlarmInfoCount; j++) {
|
String channelID = new String(alarmInfos[j].szID, encode);
|
String alarmLevel = String.valueOf(alarmInfos[j].nAlarmLevel);
|
|
info.append(String.format(" >>> 第【%d】个报警通道信息详情 <<<", j + 1)).append("\n")
|
.append(String.format(" %s: ", "通道编号")).append(channelID).append("\n")
|
.append(String.format(" %s: ", "报警级别 范围 [1,6]")).append(alarmLevel).append("\n");
|
}
|
} else {
|
info.append(" 不存在报警通道信息").append("\n");
|
}
|
|
info.append(" ------ 音频输出通道信息 ------").append("\n");
|
|
int retAudioOutputChnInfoCount = config.stuSipServerInfo[i].nRetAudioOutputChnInfoNum;
|
if (retAudioOutputChnInfoCount != 0) {
|
NET_AUDIO_OUTPUT_CHANNEL_INFO[] audioChannelInfos = new NET_AUDIO_OUTPUT_CHANNEL_INFO[retAudioOutputChnInfoCount];
|
for (int j = 0; j < retAudioOutputChnInfoCount; j++) {
|
audioChannelInfos[j] = new NET_AUDIO_OUTPUT_CHANNEL_INFO();
|
}
|
Pointer pAudioOutputChnInfo = config.stuSipServerInfo[i].pstuAudioOutputChnInfo;
|
ToolKits.GetPointerDataToStructArr(pAudioOutputChnInfo, audioChannelInfos);
|
|
for (int j = 0; j < retAudioOutputChnInfoCount; j++) {
|
String channelID = new String(audioChannelInfos[j].szID, encode);
|
|
info.append(String.format(" >>> 第【%d】个音频输出通道信息详情 <<<", j + 1)).append("\n")
|
.append(String.format(" %s: ", "通道编号")).append(channelID).append("\n");
|
}
|
} else {
|
info.append(" 不存在音频输出通道信息").append("\n");
|
}
|
}
|
System.out.println(info.toString());
|
}
|
|
/**
|
* 下发 平台接入配置(国标服务端)
|
* Demo 里修改了配置组的第一个配置
|
*/
|
public void setVspGaysServerConfig() {
|
|
// 我们推荐修改配置的方式都是 获取->修改->下发 这样的流程
|
// 配置下发载体的结构体越复杂越得这么做，特别是很多早期的结构体，往往承担着复数个配置的收发任务，缺少关键字段容易引起设备异常
|
|
//////////////////////////////////////// 获取配置 /////////////////////////////////////////////
|
//////////////////////////////////////////////////////////////////////////////////////////////
|
|
NET_CFG_VSP_GAYS_SERVER_INFO config = new NET_CFG_VSP_GAYS_SERVER_INFO();
|
config.nSipServerInfoNum = 5; // 获取配置的数量 填最大值就行了
|
int nChannelNum = initModule.deviceInfo.getByChanNum();
|
|
for (int i = 0; i < config.nSipServerInfoNum; i++) {
|
|
config.stuSipServerInfo[i].nChannelInfoNum = nChannelNum; // 这里填设备通道数就行
|
config.stuSipServerInfo[i].pstuChannelInfo = new Memory((new NET_CHANNEL_INFO().size()) * nChannelNum);
|
|
config.stuSipServerInfo[i].nAlarmInfoNum = nChannelNum; // 这里也填设备通道数就行
|
config.stuSipServerInfo[i].pstuAlarmInfo = new Memory((new NET_ALARM_INFO().size()) * nChannelNum);
|
|
config.stuSipServerInfo[i].nAudioOutputChnInfoNum = nChannelNum; // 这里还是填设备通道数
|
config.stuSipServerInfo[i].pstuAudioOutputChnInfo = new Memory((new NET_AUDIO_OUTPUT_CHANNEL_INFO().size()) * nChannelNum);
|
|
}
|
config = (NET_CFG_VSP_GAYS_SERVER_INFO) configModule.getConfig(loginHandler, NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_VSP_GAYS_SERVER, config, -1);
|
if (config == null) {
|
System.err.println("获取平台接入配置(国标服务端)失败:" + ToolKits.getErrorCode());
|
return;
|
}
|
System.out.println("获取平台接入配置(国标服务端)成功");
|
|
//////////////////////////////////////// 修改配置 /////////////////////////////////////////////
|
//////////////////////////////////////////////////////////////////////////////////////////////
|
|
// Demo这里只修改第1个配置 其他的配置原样下发
|
config.nSipServerInfoNum = config.nRetSipServerInfoNum; // 下发配置数量 设定成和接收时的一样
|
|
NET_SIP_SERVER_INFO sipServerInfo = config.stuSipServerInfo[0];
|
|
sipServerInfo.emServerOption = EM_SERVER_OPTION.EM_SERVER_OPTION_GB28181.getValue(); // 启用 28181 接入方式
|
|
byte[] bSipSvrId = "34020000002000000001".getBytes(encode); // SIP服务器编号
|
System.arraycopy(bSipSvrId, 0, sipServerInfo.szSipSvrId, 0, bSipSvrId.length);
|
|
byte[] bDomain = "3402000000".getBytes(encode); // SIP域
|
System.arraycopy(bDomain, 0, sipServerInfo.szDomain, 0, bDomain.length);
|
|
byte[] bSipSvrIp = "192.168.1.112".getBytes(encode); // SIP服务器 IP
|
System.arraycopy(bSipSvrIp, 0, sipServerInfo.szSipSvrIp, 0, bSipSvrIp.length);
|
|
byte[] bDeviceId = "34020000001320000001".getBytes(encode); // 设备编号
|
System.arraycopy(bDeviceId, 0, sipServerInfo.szDeviceId, 0, bDeviceId.length);
|
|
///// 注意: sdk虽然会发送修改后的密码，但可能该设置是无效的 这点请和产品、设备研发提前确认下 不同型号设备在实现上可能不同
|
///// 因为配置是明文发送的 sdk拿到的密码大多时候是 ****** 这样的字符串 看不到真实密码 当然密码也确实不能暴露在TCP报文中
|
byte[] bPassword = "helloWorld".getBytes(encode); // 注册密码
|
System.arraycopy(bPassword, 0, sipServerInfo.szPassword, 0, bPassword.length);
|
|
sipServerInfo.nLocalSipPort = 5060; // 本地SIP服务端口
|
sipServerInfo.nSipSvrPort = 5060; // SIP服务器端口
|
sipServerInfo.nSipRegExpires = 3600; // 注册有效期 单位秒
|
sipServerInfo.nRegInterval = 60; // 注册失败后重注册间隔 单位秒
|
sipServerInfo.nKeepAliveCircle = 60; // 心跳周期 单位秒
|
sipServerInfo.nMaxTimeoutTimes = 3; // 最大心跳超时次数
|
|
byte[] bCivilCode = "340200".getBytes(encode); // 行政区划代码
|
System.arraycopy(bCivilCode, 0, sipServerInfo.szCivilCode, 0, bCivilCode.length);
|
|
byte[] bInterVideoID = "000001019".getBytes(encode); // 接入模块识别码
|
System.arraycopy(bInterVideoID, 0, sipServerInfo.szIntervideoID, 0, bInterVideoID.length);
|
|
// Demo这里通道相关的信息都只修改第1个
|
|
// 通道信息
|
sipServerInfo.nChannelInfoNum = sipServerInfo.nRetChannelInfoNum; // 下发配置数量 设定成和接收的一样
|
NET_CHANNEL_INFO[] channelInfos = new NET_CHANNEL_INFO[sipServerInfo.nRetChannelInfoNum]; // 创建和数量相同的结构体组
|
for (int i = 0; i < sipServerInfo.nRetChannelInfoNum; i++) {
|
channelInfos[i] = new NET_CHANNEL_INFO(); // 结构体组必须先分配内存
|
}
|
if (sipServerInfo.nRetChannelInfoNum < nChannelNum) {
|
// 如果获取配置时 实际获取量比设定的小 那直接 GetPointerDataToStructArr 全拷贝就会把指针数据拷贝到未知内存
|
// 解决的办法是 新建一个和获取量大小相同的新指针 复制数据后替换掉原来的
|
int size = (channelInfos[0].size()) * sipServerInfo.nRetChannelInfoNum;
|
Pointer newStuChannelInfo = new Memory(size);
|
newStuChannelInfo.write(0, sipServerInfo.pstuChannelInfo.getByteArray(0, size), 0, size); // 复制数据
|
sipServerInfo.pstuChannelInfo = newStuChannelInfo; // 替换原指针
|
}
|
ToolKits.GetPointerDataToStructArr(sipServerInfo.pstuChannelInfo, channelInfos); // 把指针数据拷贝到结构体组里
|
|
// 现在修改它的第1个数据
|
byte[] bChannelID = "34020000001310000001".getBytes(encode);
|
System.arraycopy(bChannelID, 0, channelInfos[0].szID, 0, bChannelID.length);
|
channelInfos[0].nAlarmLevel = 1;
|
|
ToolKits.SetStructArrToPointerData(channelInfos, sipServerInfo.pstuChannelInfo); // 再把修改了的数据拷贝回去
|
|
// 报警通道信息
|
sipServerInfo.nAlarmInfoNum = sipServerInfo.nRetAlarmInfoNum; // 下发配置数量 设定成和接收的一样;
|
NET_ALARM_INFO[] alarmInfos = new NET_ALARM_INFO[sipServerInfo.nRetAlarmInfoNum];
|
for (int i = 0; i < sipServerInfo.nRetAlarmInfoNum; i++) {
|
alarmInfos[i] = new NET_ALARM_INFO(); // 结构体组必须先分配内存
|
}
|
if (sipServerInfo.nRetAlarmInfoNum < nChannelNum) {
|
// 如果获取配置时 实际获取量比设定的小 那直接 GetPointerDataToStructArr 全拷贝就会把指针数据拷贝到未知内存
|
// 解决的办法是 新建一个和获取量大小相同的新指针 复制数据后替换掉原来的
|
int size = (alarmInfos[0].size()) * sipServerInfo.nRetAlarmInfoNum;
|
Pointer newStuAlarmInfo = new Memory(size);
|
newStuAlarmInfo.write(0, sipServerInfo.pstuAlarmInfo.getByteArray(0, size), 0, size); // 复制数据
|
sipServerInfo.pstuAlarmInfo = newStuAlarmInfo; // 替换原指针
|
}
|
ToolKits.GetPointerDataToStructArr(sipServerInfo.pstuAlarmInfo, alarmInfos); // 把指针数据拷贝到结构体组里
|
|
// 现在修改它的第1个数据
|
byte[] bAlarmChannelID = "34020000002000000001".getBytes(encode);
|
System.arraycopy(bAlarmChannelID, 0, alarmInfos[0].szID, 0, bAlarmChannelID.length);
|
alarmInfos[0].nAlarmLevel = 1;
|
|
ToolKits.SetStructArrToPointerData(alarmInfos, sipServerInfo.pstuAlarmInfo); // 再把修改了的数据拷贝回去
|
|
// 音频输出通道信息
|
sipServerInfo.nAudioOutputChnInfoNum = sipServerInfo.nRetAudioOutputChnInfoNum; // 下发配置数量 设定成和接收的一样;
|
NET_AUDIO_OUTPUT_CHANNEL_INFO[] audioOutputChannelInfos = new NET_AUDIO_OUTPUT_CHANNEL_INFO[sipServerInfo.nRetAudioOutputChnInfoNum];
|
for (int i = 0; i < sipServerInfo.nRetAudioOutputChnInfoNum; i++) {
|
audioOutputChannelInfos[i] = new NET_AUDIO_OUTPUT_CHANNEL_INFO(); // 结构体组必须先分配内存
|
}
|
if (sipServerInfo.nRetAudioOutputChnInfoNum < nChannelNum) {
|
// 如果获取配置时 实际获取量比设定的小 那直接 GetPointerDataToStructArr 全拷贝就会把指针数据拷贝到未知内存
|
// 解决的办法是 新建一个和获取量大小相同的新指针 复制数据后替换掉原来的
|
int size = (alarmInfos[0].size()) * sipServerInfo.nRetAudioOutputChnInfoNum;
|
Pointer newStuAudioOutputInfo = new Memory(size);
|
newStuAudioOutputInfo.write(0, sipServerInfo.pstuAudioOutputChnInfo.getByteArray(0, size), 0, size); // 复制数据
|
sipServerInfo.pstuAudioOutputChnInfo = newStuAudioOutputInfo; // 替换原指针
|
}
|
ToolKits.GetPointerDataToStructArr(sipServerInfo.pstuAudioOutputChnInfo, audioOutputChannelInfos); // 把指针数据拷贝到结构体组里
|
|
// 现在修改它的第1个数据
|
byte[] bAudioOutputChannelID = "34020000002000000001".getBytes(encode);
|
System.arraycopy(bAudioOutputChannelID, 0, audioOutputChannelInfos[0].szID, 0, bAudioOutputChannelID.length);
|
|
ToolKits.SetStructArrToPointerData(audioOutputChannelInfos, sipServerInfo.pstuAudioOutputChnInfo); // 再把修改了的数据拷贝回去
|
|
//////////////////////////////////////// 下发配置 /////////////////////////////////////////////
|
//////////////////////////////////////////////////////////////////////////////////////////////
|
|
boolean ret = configModule.setConfig(
|
loginHandler, // 登录句柄
|
NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_VSP_GAYS_SERVER, // 枚举->平台接入配置(28181国标服务端)
|
config, // 配置结构体
|
-1 // 通道号 固定-1
|
);
|
if (!ret) {
|
System.err.println("平台接入配置(国标服务端)下发失败:" + ToolKits.getErrorCode());
|
return;
|
}
|
System.out.println("平台接入配置(国标服务端)下发成功");
|
}
|
|
|
////////////////////////////////////////////////////////////////////////////////////////////////
|
///////////////////////////////////////// 简易控制台 ////////////////////////////////////////////
|
////////////////////////////////////////////////////////////////////////////////////////////////
|
|
// 初始化测试
|
public void InitTest() {
|
initModule.init(initModule.defaultDisconnectCB, initModule.defaultReconnectCB); // 初始化SDK库
|
loginHandler = initModule.loginWithHighSecurity(m_strIp, m_nPort, m_strUser, m_strPassword); // 高安全登录
|
if (loginHandler == 0) {
|
System.err.println("登录失败, 请检查接口参数, See You..");
|
initModule.cleanAndExit();
|
}
|
}
|
|
// 加载测试内容
|
public void RunTest() {
|
CaseMenu menu = new CaseMenu();
|
menu.addItem(new CaseMenu.Item(this, "获取 平台接入配置(国标服务端)", "getVspGaysServerConfig"));
|
menu.addItem(new CaseMenu.Item(this, "下发 平台接入配置(国标服务端)", "setVspGaysServerConfig"));
|
menu.run();
|
}
|
|
// 结束测试
|
public void EndTest() {
|
System.out.println("End Test");
|
initModule.logout(loginHandler); // 登出
|
System.out.println("See You...");
|
initModule.cleanAndExit(); // 清理资源并退出
|
}
|
|
//////////////////// 配置登陆地址，端口，用户名，密码 ///////////////////////
|
// private String m_strIp = "172.8.2.7";
|
private String m_strIp = "172.23.12.112";
|
private int m_nPort = 37777;
|
private String m_strUser = "admin";
|
private String m_strPassword = "admin123";
|
/////////////////////////////////////////////////////////////////////////
|
|
public static void main(String[] args) {
|
ThirdPartyConfiguration demo = new ThirdPartyConfiguration();
|
|
if (args.length == 4) {
|
demo.m_strIp = args[0];
|
demo.m_nPort = Integer.parseInt(args[1]);
|
demo.m_strUser = args[2];
|
demo.m_strPassword = args[3];
|
}
|
|
demo.InitTest();
|
demo.RunTest();
|
demo.EndTest();
|
}
|
|
|
}
|
