package com.netsdk.demo;
|
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.enumeration.EM_EVENT_IVS_TYPE;
|
import com.netsdk.lib.enumeration.EM_EVENT_TYPE;
|
import com.sun.jna.Memory;
|
import com.sun.jna.Pointer;
|
import java.io.File;
|
import java.io.UnsupportedEncodingException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
import static com.netsdk.lib.Utils.getOsPrefix;
|
|
/**
|
* @author 291189
|
* @version 1.0
|
* @description 2022基线功能
|
* 多设备登录，智能订阅 ，取消智能订阅；以及智能订阅dwUser的使用。
|
* @date 2022/10/10 15:54
|
*/
|
public class BaseMoreLoginDemo {
|
|
public static NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;
|
|
static List<Device> deviceList=new ArrayList<>();
|
|
static {
|
// 初始化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";
|
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!!!");
|
}
|
|
}
|
/**
|
* 设备断线回调
|
*/
|
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 NetSDKLib.LLong 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
|
NetSDKLib.LLong loginHandle = netSdk.CLIENT_LoginWithHighLevelSecurity(pstlnParam, pstOutParam);
|
if (loginHandle.longValue() == 0) {
|
// System.err.printf("Login Device[%s] Port[%d]Failed. %s\n", ip, port, netSdk.CLIENT_GetLastError());
|
System.out.println("Login Device[%s] Port[%d]Failed. "+ 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 + "个通道");
|
}
|
|
return loginHandle;
|
}
|
|
/**
|
* 退出清理环境
|
*/
|
public void LoginOut(NetSDKLib.LLong lLong){
|
System.out.println("End Test");
|
if( lLong.longValue() != 0)
|
{
|
netSdk.CLIENT_Logout(lLong);
|
}
|
System.out.println("See You...");
|
|
}
|
public class Device{
|
public String ip;
|
public int port;
|
public NetSDKLib.LLong loginHandler=new NetSDKLib.LLong(0);//登录句柄
|
public List<DeviceHandler> deviceHandlers=new ArrayList<>();//订阅句柄
|
|
public Device() {
|
}
|
|
@Override
|
public String toString() {
|
return "Device{" +
|
"ip='" + ip + '\'' +
|
", port=" + port +
|
", loginHandler=" + loginHandler.longValue()+
|
'}';
|
}
|
}
|
|
|
public class DeviceHandler{
|
public int channel;
|
public NetSDKLib.LLong attachHandler=new NetSDKLib.LLong(0);//订阅句柄
|
public String dwUser;
|
|
@Override
|
public String toString() {
|
return "DeviceHandler{" +
|
"channel=" + channel +
|
", attachHandler=" + attachHandler +
|
", dwUser=" + dwUser +
|
'}';
|
}
|
}
|
|
/**
|
* 订阅智能任务
|
*/
|
//存储dwuser,防止回收
|
static HashMap<NetSDKLib.LLong,Pointer> pointers=new HashMap<>();
|
|
public NetSDKLib.LLong AttachEventRealLoadPic(NetSDKLib.LLong loginHandle,NetSDKLib.LLong attachHandle,int channel,String dwUser) {
|
// 先退订，设备不会对重复订阅作校验，重复订阅后会有重复的事件返回
|
if(attachHandle.longValue()!=0){
|
this.DetachEventRealLoadPic(attachHandle);
|
}
|
|
Pointer dwUserData = GetStringToPointer(dwUser,encode);
|
|
// 需要图片
|
int bNeedPicture = 1;
|
attachHandle = netSdk.CLIENT_RealLoadPictureEx(loginHandle, channel, EM_EVENT_TYPE.EVENT_IVS_ALL.getType(), bNeedPicture,
|
AnalyzerDataCB.getInstance(), dwUserData, null);
|
if (attachHandle.longValue() != 0) {
|
System.out.printf("Chn[%d] CLIENT_RealLoadPictureEx Success\n", channel);
|
pointers.put(attachHandle,dwUserData);
|
} else {
|
System.out.printf("Chn[%d] CLIENT_RealLoadPictureEx Failed!LastError = %s\n", channel,
|
ToolKits.getErrorCode());
|
|
}
|
|
return attachHandle;
|
}
|
|
public static Pointer GetStringToPointer(String src,String charset) {
|
Pointer pointer = null;
|
try {
|
byte[] b = src.getBytes(charset);
|
|
pointer = new Memory(b.length + 1);
|
pointer.clear(b.length + 1);
|
|
pointer.write(0, b, 0, b.length);
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
return pointer;
|
}
|
|
public static String GetPointerDataToString(Pointer pointer,String charset) {
|
String str = "";
|
if (pointer == null) {
|
return str;
|
}
|
|
int length = 0;
|
byte[] bufferPlace = new byte[1];
|
|
for (int i = 0; i < 2048; i++) {
|
pointer.read(i, bufferPlace, 0, 1);
|
if (bufferPlace[0] == '\0') {
|
length = i;
|
break;
|
}
|
}
|
|
if (length > 0) {
|
byte[] buffer = new byte[length];
|
pointer.read(0, buffer, 0, length);
|
try {
|
str = new String(buffer, charset).trim();
|
} catch (UnsupportedEncodingException e) {
|
return str;
|
}
|
}
|
|
return str;
|
}
|
|
/**
|
* 报警事件（智能）回调
|
*/
|
public static class AnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack {
|
private final File picturePath;
|
private static AnalyzerDataCB instance;
|
|
private AnalyzerDataCB() {
|
picturePath = new File("./AnalyzerPicture/");
|
if (!picturePath.exists()) {
|
picturePath.mkdirs();
|
}
|
}
|
|
public static AnalyzerDataCB getInstance() {
|
if (instance == null) {
|
synchronized (AnalyzerDataCB.class) {
|
if (instance == null) {
|
instance = new AnalyzerDataCB();
|
}
|
}
|
}
|
return instance;
|
}
|
|
|
@Override
|
public int invoke(NetSDKLib.LLong lAnalyzerHandle, int dwAlarmType, Pointer pAlarmInfo, Pointer pBuffer, int dwBufSize,
|
Pointer dwUser, int nSequence, Pointer reserved) {
|
if (lAnalyzerHandle == null || lAnalyzerHandle.longValue() == 0) {
|
return -1;
|
}
|
|
String s = GetPointerDataToString(dwUser,encode);
|
System.out.println("方法一 dwUser的值:"+s);
|
for(int i=0;i<deviceList.size();i++){
|
Device device = deviceList.get(i);
|
|
List<DeviceHandler> deviceHandlers = device.deviceHandlers;
|
for(DeviceHandler deviceHandler:deviceHandlers){
|
if(deviceHandler.attachHandler.longValue()==lAnalyzerHandle.longValue()){
|
System.out.println("方法二 根据句柄关联:"+ "订阅句柄:"+deviceHandler.attachHandler+
|
",设备信息:"+device.ip+":"+device.port+",通道号:"+deviceHandler.channel);
|
}
|
}
|
}
|
|
switch (Objects.requireNonNull(EM_EVENT_IVS_TYPE.getEventType(dwAlarmType))) {
|
case EVENT_IVS_FACEDETECT : {
|
System.out.println("目标检测事件");
|
break;
|
}
|
//目标识别事件
|
case EVENT_IVS_FACERECOGNITION:{
|
|
System.out.println("目标识别事件");
|
|
break;
|
}
|
case EVENT_IVS_NUMBERSTAT:{
|
System.out.println("数量统计事件");
|
break;
|
}
|
default:
|
System.out.println("其他事件--------------------"+ dwAlarmType);
|
break;
|
}
|
return 0;
|
}
|
}
|
|
|
/**
|
* 停止侦听智能事件
|
*/
|
public void DetachEventRealLoadPic( NetSDKLib.LLong attachHandle) {
|
if (attachHandle.longValue() != 0) {
|
boolean b = netSdk.CLIENT_StopLoadPic(attachHandle);
|
if(b){
|
System.out.println("CLIENT_StopLoadPic success");
|
}else {
|
System.out.println("CLIENT_StopLoadPic fail!"+ToolKits.getErrorCode());
|
|
}
|
}
|
}
|
|
static Scanner scanner=new Scanner(System.in);
|
|
public static void main(String[] args) {
|
BaseMoreLoginDemo baseMoreLoginDemo=new BaseMoreLoginDemo();
|
|
baseMoreLoginDemo.runLogic();
|
|
}
|
|
|
public void runLogic(){
|
|
while (true){
|
System.out.println("0.退出");
|
System.out.println("1.设备登录");
|
System.out.println("2.选择设备 通道 智能订阅");
|
System.out.println("3.选择设备 通道 取消订阅");
|
|
for(int i=0;i<deviceList.size();i++){
|
Device device = deviceList.get(i);
|
System.out.println("设备下标："+i+":"+device.toString());
|
|
List<DeviceHandler> deviceHandlers = device.deviceHandlers;
|
|
for(int j=0;j<deviceHandlers.size();j++){
|
DeviceHandler deviceHandler = deviceHandlers.get(j);
|
System.out.println("订阅通道下标："+j+":"+deviceHandler.toString());
|
}
|
|
}
|
try {
|
int nextInt = scanner.nextInt();
|
|
if(nextInt==0){
|
break;
|
}else if(nextInt==1){
|
System.out.println("输入设备ip,端口,用户名,密码 逗号隔开;如：10.34.3.159,37777,admin,admin");
|
String next = scanner.next();
|
String[] split = next.split(",");
|
NetSDKLib.LLong lLong = loginWithHighLevel(split[0].trim(), Integer.parseInt(split[1].trim()), split[2], split[3]);
|
Device device=new Device();
|
device.ip=split[0].trim();
|
device.port=Integer.parseInt(split[1].trim());
|
device.loginHandler=lLong;
|
deviceList.add(device);
|
}else if(nextInt==2){
|
System.out.println("选择设备下标和通道号进行订阅 逗号隔开 如 1,-1 ");
|
|
String next = scanner.next();
|
|
String[] split = next.split(",");
|
|
Device device = deviceList.get(Integer.parseInt(split[0].trim()));
|
|
int channl = Integer.parseInt(split[1].trim());
|
|
List<DeviceHandler> deviceHandlers = device.deviceHandlers;
|
|
NetSDKLib.LLong attachHandler=new NetSDKLib.LLong(0);
|
|
boolean flag=false;
|
int m=-1;
|
//轮询 设备的订阅通道
|
for( int i=0;i<deviceHandlers.size();i++){
|
DeviceHandler deviceHandler= deviceHandlers.get(i);
|
|
if(deviceHandler.channel==channl){
|
m=i;
|
attachHandler=deviceHandler.attachHandler;
|
flag=true;
|
break;
|
}
|
}
|
DeviceHandler deviceHandler=new DeviceHandler();
|
|
String dwUser= "设备信息:"+device.ip + ":" + device.port+": 通道号:"+channl;
|
|
deviceHandler.dwUser=dwUser;
|
|
deviceHandler.channel=channl;
|
|
attachHandler = AttachEventRealLoadPic(device.loginHandler, attachHandler,channl ,dwUser);
|
|
deviceHandler.attachHandler=attachHandler;
|
|
if(!flag){
|
deviceHandlers.add(deviceHandler);
|
}else {
|
deviceHandlers.remove(m);
|
deviceHandlers.add(deviceHandler);
|
|
}
|
|
|
}else if(nextInt==3){
|
System.out.println("选择设备下标 和 订阅通道下标 进行取消订阅 逗号隔开 如 1,1 ");
|
String next = scanner.next();
|
|
String[] split = next.split(",");
|
|
Device device = deviceList.get(Integer.parseInt(split[0].trim()));
|
|
List<DeviceHandler> deviceHandlers = device.deviceHandlers;
|
|
DeviceHandler deviceHandler
|
= deviceHandlers.get(Integer.parseInt(split[1].trim()));
|
|
DetachEventRealLoadPic(deviceHandler.attachHandler);
|
|
pointers.remove(deviceHandler.attachHandler);
|
|
deviceHandlers.remove(Integer.parseInt(split[1].trim()));
|
|
|
}else {
|
System.out.println("输入有误");
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
|
|
|
}
|
|
Iterator<Device> iterator = deviceList.iterator();
|
|
while (iterator.hasNext()){
|
Device next = iterator.next();
|
if(next!=null&&next.loginHandler!=null&&next.loginHandler.longValue()!=0){
|
LoginOut(next.loginHandler);
|
}
|
|
}
|
|
netSdk.CLIENT_Cleanup();
|
}
|
// 编码格式
|
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";
|
}
|
|
}
|
|
}
|
