package com.netsdk.demo.units;
|
|
import java.io.File;
|
|
import com.netsdk.demo.customize.SDSnap.SnapCallback;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.NetSDKLib.EM_TRANSCODE_IMAGE_QUALITY;
|
import com.netsdk.lib.NetSDKLib.EM_TRANSCODE_VIDEO_COMPRESSION;
|
import com.netsdk.lib.NetSDKLib.LLong;
|
import com.netsdk.lib.NetSDKLib.LOG_SET_PRINT_INFO;
|
import com.netsdk.lib.NetSDKLib.NET_EM_AUDIO_FORMAT;
|
import com.netsdk.lib.NetSDKLib.NET_EM_BITRATE_CONTROL;
|
import com.netsdk.lib.NetSDKLib.NET_IN_DEL_VIRTUALCHANNEL_OF_TRANSCODE;
|
import com.netsdk.lib.NetSDKLib.NET_IN_GET_VIRTUALCHANNEL_OF_TRANSCODE;
|
import com.netsdk.lib.NetSDKLib.NET_IN_TRANDCODE_GET_CAPS;
|
import com.netsdk.lib.NetSDKLib.NET_OUT_DEL_VIRTUALCHANNEL_OF_TRANSCODE;
|
import com.netsdk.lib.NetSDKLib.NET_OUT_GET_VIRTUALCHANNEL_OF_TRANSCODE;
|
import com.netsdk.lib.NetSDKLib.NET_OUT_TRANSCODE_GET_CAPS;
|
import com.netsdk.lib.NetSDKLib.NET_TRANSCODE_AUDIO_FORMAT;
|
import com.netsdk.lib.NetSDKLib.NET_TRANSCODE_VIDEO_FORMAT;
|
import com.netsdk.lib.NetSDKLib.NET_VIDEO_SOURCE_INFO;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.ptr.IntByReference;
|
|
public class VirtualChannelUnit {
|
|
//实体化 SDK 调用对象
|
static NetSDKLib netsdkApi = NetSDKLib.NETSDK_INSTANCE;
|
static NetSDKLib configApi = NetSDKLib.CONFIG_INSTANCE;
|
//Begin:设备登入信息------------
|
private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
private static LLong loginHandle = new LLong(0);
|
private static int VirtualChannel = 0;
|
|
|
String address = "172.12.9.110"; // IP
|
int port = 37777; // 端口
|
String username = "admin"; // 登入用户名
|
String password = "admin123"; // 登入密码
|
//Finish:设备登入信息------------
|
|
//Begin:回调事件设置------------
|
//断线回调
|
private static class DisconnectCallback implements NetSDKLib.fDisConnect {
|
private static DisconnectCallback instance = new DisconnectCallback();
|
private DisconnectCallback() {}
|
public static DisconnectCallback getInstance() {
|
return instance;
|
}
|
|
public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser){
|
System.out.printf("Device Disconnect [%s:%d] Disconnect!\n" , pchDVRIP , nDVRPort);
|
}
|
}
|
|
//断线重练回调
|
private static class HaveReconnectCallback implements NetSDKLib.fHaveReConnect {
|
private static HaveReconnectCallback instance = new HaveReconnectCallback();
|
private HaveReconnectCallback() {}
|
public static HaveReconnectCallback getInstance() {
|
return instance;
|
}
|
|
public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser){
|
System.out.printf("Device[%s:%d] HaveReconnected!\n" , pchDVRIP , nDVRPort);
|
}
|
}
|
|
|
//Finish:回调事件设置------------
|
|
//开启设备
|
public void BeginTest()
|
{
|
// SDK资源初始化
|
netsdkApi.CLIENT_Init(DisconnectCallback.getInstance(), null);
|
// 设置断线重连回调，当设备断线后会自动重连并在重连后自动调用HaveReConnect(可选)
|
netsdkApi.CLIENT_SetAutoReconnect(HaveReconnectCallback.getInstance(), null);
|
|
// 向设备登入
|
int nSpecCap = 0;
|
IntByReference nError = new IntByReference(0);
|
loginHandle = netsdkApi.CLIENT_LoginEx2(address, port, username,
|
password, nSpecCap, null, deviceInfo, nError);
|
|
if(loginHandle.longValue() == 0) {
|
System.err.printf("Login Device [%s:%d] Failed ! Last Error[%x]\n", address, port, netsdkApi.CLIENT_GetLastError());
|
FinishTest();
|
return;
|
}
|
|
System.out.printf("Login Device [%s:%d] Success. \n", address, port);
|
|
// 打开SDK日志（可选）
|
LOG_SET_PRINT_INFO setLog = new LOG_SET_PRINT_INFO();
|
String logPath = new File(".").getAbsoluteFile().getParent() + File.separator + "sdk_log" + File.separator + "sdk.log";
|
setLog.bSetFilePath = 1;
|
System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
|
setLog.bSetPrintStrategy = 1;
|
setLog.nPrintStrategy = 0;
|
if (!netsdkApi.CLIENT_LogOpen(setLog)) {
|
System.err.println("Failed to open NetSDK log !!!");
|
}
|
|
netsdkApi.CLIENT_SetSnapRevCallBack(SnapCallback.getInstance(), null);
|
|
|
}
|
|
//关闭设备
|
public void FinishTest() {
|
|
// 停止订阅报警
|
if (netsdkApi.CLIENT_StopListen(loginHandle)) {
|
System.out.println("取消订阅报警信息.");
|
}
|
|
System.out.println("Finish Test");
|
if( loginHandle.longValue() != 0)
|
{
|
netsdkApi.CLIENT_Logout(loginHandle);
|
}
|
System.out.println("See You...");
|
|
netsdkApi.CLIENT_Cleanup();
|
System.exit(0);
|
}
|
|
// 获取虚拟通道测试
|
public void Test_GetVirtualChannel()
|
{
|
//方法参数定义
|
NET_IN_GET_VIRTUALCHANNEL_OF_TRANSCODE pInParam = new NET_IN_GET_VIRTUALCHANNEL_OF_TRANSCODE();
|
NET_OUT_GET_VIRTUALCHANNEL_OF_TRANSCODE pOutParam = new NET_OUT_GET_VIRTUALCHANNEL_OF_TRANSCODE();
|
//入参初始化
|
{
|
//netVideoSourceInfo初始化
|
NET_VIDEO_SOURCE_INFO netVideoSourceInfo = new NET_VIDEO_SOURCE_INFO();
|
netVideoSourceInfo.emProtocolType = NetSDKLib.EM_DEV_PROTOCOL_TYPE.EM_DEV_PROTOCOL_GENERAL; //general
|
/*byte[] szIp="172.23.12.27".getBytes();
|
System.arraycopy(szIp, 0, netVideoSourceInfo.szIp, 0, szIp.length);
|
netVideoSourceInfo.nPort=554;
|
|
byte[] username="admin".getBytes(); //用户名
|
System.arraycopy(username, 0, netVideoSourceInfo.szUser, 0, username.length);
|
byte[] szPwd="admin11111".getBytes(); //密码
|
System.arraycopy(szPwd, 0, netVideoSourceInfo.szPwd, 0, szPwd.length);
|
|
netVideoSourceInfo.nChannelID=1;*/
|
//byte[] url="rtsp://admin:admin11111@172.23.12.27:554/cam/realmonitor?channel=1&subtype=0".getBytes();
|
byte[] url="rtsp://10.80.50.221:8319/dss/monitor/param?cameraid=Y1ZjU88nA1BOO1FFANNLFT&substream=1&trackID=0&urlType=2".getBytes();
|
System.arraycopy(url, 0, netVideoSourceInfo.szStreamUrl, 0, url.length);
|
|
|
// 视频源url地址, emProtocolType为EM_DEV_PROTOCOL_GENERAL 时有效
|
|
//netTranscodeVideoFormat初始化
|
NET_TRANSCODE_VIDEO_FORMAT netTranscodeVideoFormat = new NET_TRANSCODE_VIDEO_FORMAT();
|
netTranscodeVideoFormat.emCompression=EM_TRANSCODE_VIDEO_COMPRESSION.EM_TRANSCODE_VIDEO_H264; //视频压缩格式
|
netTranscodeVideoFormat.nWidth=720;
|
netTranscodeVideoFormat.nHeight=576;
|
netTranscodeVideoFormat.emBitRateControl=NET_EM_BITRATE_CONTROL.EM_BITRATE_CBR; //码流控制模式
|
netTranscodeVideoFormat.nBitRate=384;
|
netTranscodeVideoFormat.fFrameRate=25; //fps http://172.23.12.14/
|
netTranscodeVideoFormat.nIFrameInterval=50; //I帧间隔
|
netTranscodeVideoFormat.emImageQuality=EM_TRANSCODE_IMAGE_QUALITY.EM_TRANSCODE_IMAGE_QUALITY_Q60;
|
|
//netTranscodeAudioFormat初始化
|
NET_TRANSCODE_AUDIO_FORMAT netTranscodeAudioFormat = new NET_TRANSCODE_AUDIO_FORMAT();
|
netTranscodeAudioFormat.emCompression = NET_EM_AUDIO_FORMAT.EM_AUDIO_FORMAT_PCM; //音频压缩格式
|
netTranscodeAudioFormat.nFrequency = 44000; //音频采样频率
|
|
pInParam.stuVideoSourceInfo = netVideoSourceInfo;
|
pInParam.stuTransVideoFormat = netTranscodeVideoFormat;
|
pInParam.stuTransAudioFormat = netTranscodeAudioFormat;
|
pInParam.stuVirtualChnPolicy.bDeleteByCaller=1;
|
pInParam.stuVirtualChnPolicy.bContinuous=1;
|
//pInParam.write();
|
|
}
|
//方法调用
|
boolean bRet = netsdkApi.CLIENT_GetVirtualChannelOfTransCode(loginHandle,pInParam,pOutParam,3000);
|
if(bRet){
|
VirtualChannel=pOutParam.nVirtualChannel;
|
System.out.println("获取转码虚拟通道号成功"+pOutParam.nVirtualChannel);
|
}
|
else{
|
System.err.printf("获取转码虚拟通道号失败 Last Error[%x]\n",netsdkApi.CLIENT_GetLastError());
|
}
|
}
|
|
// 获取转码能力测试
|
public void Test_GetTransCodeCaps()
|
{
|
//方法参数定义
|
NET_IN_TRANDCODE_GET_CAPS pInParam = new NET_IN_TRANDCODE_GET_CAPS();
|
NET_OUT_TRANSCODE_GET_CAPS pOutParam = new NET_OUT_TRANSCODE_GET_CAPS();
|
//方法调用
|
boolean getCapsOfTransCode = netsdkApi.CLIENT_GetCapsOfTransCode(loginHandle,pInParam,pOutParam,3000);
|
if(getCapsOfTransCode){
|
//输出参数解析
|
System.out.println("最小虚拟通道号:"+pOutParam.nMinVirtualChannel);
|
System.out.println("最大虚拟通道号:"+pOutParam.nMaxVirtualChannel);
|
System.out.println("是否支持压缩错误码实时上报:"+pOutParam.bSupportErrorCode);
|
System.out.println("是否支持持续转码:"+pOutParam.bSupportContinuous);
|
System.out.println("是否支持由用户管理虚拟通道:"+pOutParam.bSupportDelByCaller);
|
}
|
else{
|
System.out.println("获取转码能力集失败");
|
}
|
return;
|
}
|
|
// 删除虚拟通道测试
|
public void Test_DeleteVirtualChannel()
|
{
|
NET_IN_DEL_VIRTUALCHANNEL_OF_TRANSCODE pInParam = new NET_IN_DEL_VIRTUALCHANNEL_OF_TRANSCODE();
|
NET_OUT_DEL_VIRTUALCHANNEL_OF_TRANSCODE pOutParam = new NET_OUT_DEL_VIRTUALCHANNEL_OF_TRANSCODE();
|
pInParam.nVirtualChannel = VirtualChannel;
|
boolean bRet = netsdkApi.CLIENT_DelVirtualChannelOfTransCode(loginHandle, pInParam, pOutParam, 5000);
|
if (!bRet)
|
{
|
System.err.printf("CLIENT_DelVirtualChannelOfTransCode Error[0x%x]\n", netsdkApi.CLIENT_GetLastError());
|
return;
|
}
|
|
if (-1 == pInParam.nVirtualChannel)
|
{
|
System.out.println("已删除全部虚拟通道号");
|
}
|
else
|
{
|
System.out.println("已删除虚拟通道号:"+pInParam.nVirtualChannel);
|
}
|
return;
|
}
|
|
public static void main(String[] args) {
|
VirtualChannelUnit demo = new VirtualChannelUnit();
|
demo.BeginTest();
|
demo.Test_GetVirtualChannel();
|
demo.Test_GetTransCodeCaps();
|
demo.Test_DeleteVirtualChannel();
|
demo.FinishTest();
|
}
|
|
}
|
