package com.netsdk.demo.customize;
|
|
import static com.netsdk.lib.Utils.getOsPrefix;
|
|
import java.io.File;
|
import java.util.Scanner;
|
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.enumeration.CFG_EM_STREAM_TYPES;
|
import com.netsdk.lib.enumeration.ENUMERROR;
|
import com.netsdk.lib.structure.NET_IN_VIDEO_ENCODE_CAPS;
|
import com.netsdk.lib.structure.NET_OUT_VIDEO_ENCODE_CAPS;
|
import com.netsdk.lib.utils.Initialization;
|
import com.sun.jna.Pointer;
|
|
/**
|
* 隐私遮挡功能
|
*/
|
public class PrivacyMaskingCapsDemo {
|
|
public static NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;
|
public static NetSDKLib config = NetSDKLib.CONFIG_INSTANCE;
|
|
// 登陆句柄
|
public static NetSDKLib.LLong loginHandle;
|
|
public static NetSDKLib.NET_DEVICEINFO_Ex m_stDeviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
|
// 编码格式
|
public static String encode;
|
|
static {
|
String osPrefix = getOsPrefix();
|
if (osPrefix.toLowerCase().startsWith("win32-amd64")) {
|
encode = "GBK";
|
} else if (osPrefix.toLowerCase().startsWith("linux-amd64")) {
|
encode = "UTF-8";
|
}
|
|
}
|
|
/**
|
* 设备断线回调
|
*/
|
private static class DisconnectCallback implements NetSDKLib.fDisConnect {
|
private static DisconnectCallback instance = new DisconnectCallback();
|
|
private DisconnectCallback() {
|
}
|
|
public static DisconnectCallback getInstance() {
|
return instance;
|
}
|
|
public void invoke(NetSDKLib.LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
System.out.printf("Device[%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(NetSDKLib.LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
System.out.printf("Device[%s:%d] HaveReconnected!\n", pchDVRIP, nDVRPort);
|
}
|
}
|
|
public static void InitTest(String ip, int port, String user, String password) {
|
// 初始化SDK库
|
netSdk.CLIENT_Init(DisconnectCallback.getInstance(), null);
|
|
// 设置断线重连成功回调函数
|
netSdk.CLIENT_SetAutoReconnect(HaveReconnectCallback.getInstance(), null);
|
|
// 打开日志，可选0
|
NetSDKLib.LOG_SET_PRINT_INFO setLog = new NetSDKLib.LOG_SET_PRINT_INFO();
|
String logPath = new File(".").getAbsoluteFile().getParent() + File.separator + "sdk_log" + File.separator
|
+ "sdk.log";
|
System.out.println("logPath:" + logPath);
|
setLog.bSetFilePath = 1;
|
System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
|
setLog.bSetPrintStrategy = 1;
|
setLog.nPrintStrategy = 0;
|
if (!netSdk.CLIENT_LogOpen(setLog)) {
|
System.err.println("Open SDK Log Failed!!!");
|
}
|
|
loginWithHighLevel(ip, port, user, password);
|
}
|
|
/**
|
* 高安全登录
|
*/
|
public static void loginWithHighLevel(String ip, int port, String user, String password) {
|
// 输入结构体参数
|
NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY pstlnParam = new NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY() {
|
{
|
szIP = ip.getBytes();
|
nPort = port;
|
szUserName = user.getBytes();
|
szPassword = password.getBytes();
|
}
|
};
|
|
// 输出结构体参数
|
NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY pstOutParam = new NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY();
|
|
// 写入sdk
|
loginHandle = netSdk.CLIENT_LoginWithHighLevelSecurity(pstlnParam, pstOutParam);
|
if (loginHandle.longValue() == 0) {
|
System.err.printf("Login Device [%s:%d] Failed ! Last Error[%x]\n", ip, port,netSdk.CLIENT_GetLastError());
|
} else {
|
NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = pstOutParam.stuDeviceInfo; // 获取设备信息
|
System.out.println("Login Success");
|
System.out.println("Device Address：" + ip);
|
System.out.println("设备包含：" + deviceInfo.byChanNum + "个通道");
|
m_stDeviceInfo = pstOutParam.stuDeviceInfo;
|
}
|
|
}
|
|
/**
|
* 退出清理环境
|
*/
|
public static void loginOut() {
|
System.out.println("End Test");
|
if (loginHandle.longValue() != 0) {
|
netSdk.CLIENT_Logout(loginHandle);
|
}
|
System.out.println("See You...");
|
|
netSdk.CLIENT_Cleanup();
|
System.exit(0);
|
}
|
|
/**
|
* 获取能力集
|
*/
|
public static void queryVedioEncodeCaps() {
|
//入参
|
NET_IN_VIDEO_ENCODE_CAPS pInBuf = new NET_IN_VIDEO_ENCODE_CAPS();
|
pInBuf.stStreamType = CFG_EM_STREAM_TYPES.CFG_EM_STREAMTYPE_MAIN.getValue();// Main -主码流
|
pInBuf.write();
|
//出参
|
NET_OUT_VIDEO_ENCODE_CAPS pOutBuf = new NET_OUT_VIDEO_ENCODE_CAPS();
|
pOutBuf.write();
|
boolean flg = netSdk.CLIENT_QueryDevInfo(loginHandle, NetSDKLib.NET_QUERY_VIDEO_ENCODE_CAPS, pInBuf.getPointer(), pOutBuf.getPointer(), null, 3000);
|
if (flg) {
|
pOutBuf.read();
|
// 1：V1，2：V2(SD), 3:V3(IPC) ,参考枚举 {@link com.netsdk.lib.enumeration.EM_PRIVACY_MASKING_VERSION}
|
System.out.println("隐私遮档版本号:"+pOutBuf.stuPrivacyMaskingCaps.emVersion);
|
|
} else {
|
System.out.println("获取能力集:" + ENUMERROR.getErrorMessage());
|
}
|
|
|
}
|
|
public static void main(String[] args) {
|
PrivacyMaskingCapsDemo demo=new PrivacyMaskingCapsDemo();
|
// 初始化sdk库,设置断线配置,打开日志,设备登录
|
InitTest("172.29.4.150", 37777, "admin", "admin123");
|
if(loginHandle.longValue() == 0) {
|
loginOut();
|
}
|
|
// 隐私遮挡能力，根据能力决定使用配置还是RPC，本demo开放给用户选择
|
// queryVedioEncodeCaps()
|
|
Scanner scanner=new Scanner(System.in);
|
String id="";
|
while (true){
|
System.out.println("请选择以下功能");
|
System.out.println("1. 全屏隐私遮挡");
|
System.out.println("2. 局部隐私遮挡");
|
System.out.println("3. 取消隐私遮挡");
|
System.out.println("4. 退出程序");
|
System.out.println("Please input a item index to invoke the method:");
|
int step = scanner.nextInt();
|
if(step==0){
|
break;
|
}else if(step==1){
|
|
}else if(step==2) {
|
|
}else if(step==3){
|
|
} else{
|
break;
|
}
|
|
}
|
Initialization.LoginOut();
|
}
|
}
|
|
|
|
