超脑对接初始化-v1.0

pom.xml

@@ -24,6 +24,7 @@
         <mysql.connector.java.version>8.0.28</mysql.connector.java.version>
         <lombok.versin>1.18.22</lombok.versin>
         <spring-cloud.version>Hoxton.SR12</spring-cloud.version>
+        <jna.version>3.0.9</jna.version>
     </properties>
     <dependencies>
         <!-- lombok -->
@@ -38,6 +39,17 @@
             <artifactId>fastjson</artifactId>
             <version>${fastjson.version}</version>
         </dependency>
+        <!-- 引入本地依赖 start -->
+        <dependency>
+            <groupId>com.sun.jna</groupId>
+            <artifactId>jna</artifactId>
+            <version>${jna.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.sun.jna</groupId>
+            <artifactId>examples</artifactId>
+            <version>${jna.version}</version>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>

src/main/java/com/unis/common/osSelect.java

@@ -0,0 +1,16 @@
+package com.unis.common;
+
+/**
+ * @author jiangxin
+ * @create 2022-01-19-16:40
+ */
+public class osSelect {
+
+    public static boolean isLinux() {
+        return System.getProperty("os.name").toLowerCase().contains("linux");
+    }
+
+    public static boolean isWindows() {
+        return System.getProperty("os.name").toLowerCase().contains("windows");
+    }
+}

src/main/java/com/unis/config/AddressModel.java

@@ -0,0 +1,31 @@
+package com.unis.config;
+
+import lombok.Data;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2024-07-31 9:24
+ */
+@Data
+@Component
+public class AddressModel {
+
+    // 推送地址
+    @Value("${address.pushToIntrusion}")
+    private String pushToIntrusion;
+    // 设备ip
+    @Value("${exceptionAlarm.deviceIP}")
+    private String deviceIP;
+    // 设备ip
+    @Value("${exceptionAlarm.org-code}")
+    private String orgCode;
+    // 设备登录用户名
+    @Value("${exceptionAlarm.userName}")
+    private String userName;
+    // 设备登录密码
+    @Value("${exceptionAlarm.password}")
+    private String password;
+}

src/main/java/com/unis/face/Alarm.java

@@ -0,0 +1,75 @@
+package com.unis.face;
+
+import com.sun.jna.Pointer;
+import com.unis.common.HCNetSDK;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * 报警布防/监听功能模块：功能：报警布防/监听实时接受设备的人脸比对报警事件，回调函数中获取的报警类型(lCommand)为COMM_SNAP_MATCH_ALARM，报警信息(pAlarmInfo)对应结构体：NET_VCA_FACESNAP_MATCH_ALARM。
+ * fSimilarity相似度大于0表示人脸比对成功，可以获取人脸库相关数据；fSimilarity相似度为0，需要通过NET_VCA_BLACKLIST_INFO结构体里面的byType类型判断，值为1表示陌生人模式，值为2表示人脸比对失败。
+ */
+@Slf4j
+public class Alarm {
+
+    public static HCNetSDK.FMSGCallBack_V31 fMSFCallBack_V31 = null;
+
+    /**
+     * 报警布防 （布防和监听选其一）
+     *
+     * @param lUserID 用户登录句柄
+     */
+    public static void SetAlarm(int lUserID) {
+        //尚未布防,需要布防
+        if (FaceMain.lAlarmHandle < 0) {
+
+            //设置报警回调函数，一个程序进程只需要而且只能调用一次，对接多台设备，可以SDK初始化之后就调用该接口设置报警回调函数
+            if (fMSFCallBack_V31 == null) {
+                fMSFCallBack_V31 = new FMSGCallBack_V31();
+                Pointer pUser = null;
+                if (!FaceMain.hCNetSDK.NET_DVR_SetDVRMessageCallBack_V31(fMSFCallBack_V31, pUser)) {
+                    log.error("设置回调函数失败!");
+                } else {
+                    log.info("设置回调函数成功!");
+                }
+            }
+
+            //报警布防参数设置
+            HCNetSDK.NET_DVR_SETUPALARM_PARAM m_strAlarmInfo = new HCNetSDK.NET_DVR_SETUPALARM_PARAM();
+            m_strAlarmInfo.dwSize = m_strAlarmInfo.size();
+            m_strAlarmInfo.byLevel = 1;  //布防等级
+            m_strAlarmInfo.byAlarmInfoType = 1;   // 智能交通报警信息上传类型：0- 老报警信息（NET_DVR_PLATE_RESULT），1- 新报警信息(NET_ITS_PLATE_RESULT)
+            m_strAlarmInfo.byDeployType = 1;   //布防类型 0：客户端布防 1：实时布防
+            m_strAlarmInfo.write();
+            FaceMain.lAlarmHandle = FaceMain.hCNetSDK.NET_DVR_SetupAlarmChan_V41(lUserID, m_strAlarmInfo);
+            log.info("lAlarmHandle: {}", FaceMain.lAlarmHandle);
+            if (FaceMain.lAlarmHandle == -1) {
+                log.error("布防失败，错误码为: {}", FaceMain.hCNetSDK.NET_DVR_GetLastError());
+            } else {
+                log.info("布防成功");
+            }
+        }
+    }
+
+    /**
+     * 报警监听
+     * <p>
+     * 注意: 设置监听前需要现在本机pc配置端口
+     * 具体步骤：库文件ClientDemo->登录设备->配置->网络参数配置->配置告警管理主机地址、告警管理主机端口（需要与NET_DVR_StartListen_V30接口中对应）
+     */
+    public void StartListen() {
+        if (fMSFCallBack_V31 == null) {
+            fMSFCallBack_V31 = new FMSGCallBack_V31();
+        }
+        /**
+         * 这里NET_DVR_StartListen_V30接口中的ip和端口需要和配置的ip和端口对应
+         * NET_DVR_StartListen_V30中传入的IP和端口是服务器或者测试PC的IP地址和端口，不是设备的IP和端口！！！
+         */
+        FaceMain.lListenHandle = FaceMain.hCNetSDK.NET_DVR_StartListen_V30("10.17.36.14", (short) 7201, fMSFCallBack_V31, null);
+        if (FaceMain.lListenHandle == -1) {
+            log.error("监听失败: {}", FaceMain.hCNetSDK.NET_DVR_GetLastError());
+        } else {
+            log.info("监听成功");
+        }
+    }
+
+}

src/main/java/com/unis/face/FMSGCallBack_V31.java

@@ -0,0 +1,181 @@
+package com.unis.face;
+
+import com.alibaba.fastjson.JSON;
+import com.sun.jna.Pointer;
+import com.unis.common.HCNetSDK;
+/*import com.unissoft.pushMsg.AlarmDSService;
+import com.unissoft.pushMsg.AlarmDSServiceImpl;*/
+import lombok.extern.slf4j.Slf4j;
+
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.nio.ByteBuffer;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+/**
+ * 人脸比对报警接收回调函数
+ */
+@Slf4j
+public class FMSGCallBack_V31 implements HCNetSDK.FMSGCallBack_V31 {
+    // this class call jna native callback,so is not spring manage class
+    /*private AlarmDSService alarmDSService = new AlarmDSServiceImpl();*/
+
+    //报警信息回调函数
+    public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
+        AlarmDataHandle(lCommand, pAlarmer, pAlarmInfo, dwBufLen, pUser);
+        return true;
+    }
+
+    public void AlarmDataHandle(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
+        log.info("报警事件发生,进入回调");
+        log.info(
+                "lCommand {} -> pAlarmer {} -> pAlarmInfo {} -> dwBufLen {} -> pUser {}",
+                lCommand, JSON.toJSONString(pAlarmer), JSON.toJSONString(pAlarmInfo),dwBufLen,JSON.toJSONString(pUser)
+        );
+        /*String hexString = Integer.toHexString(lCommand);
+        log.info("报警类型 hexString {}", hexString);*/
+        switch (lCommand) {
+            case HCNetSDK.COMM_ALARM_RULE://行为分析信息上传
+                HCNetSDK.NET_VCA_RULE_ALARM ruleAlarm = new HCNetSDK.NET_VCA_RULE_ALARM();
+                ruleAlarm.write();
+                Pointer ruleAlarmPointer = ruleAlarm.getPointer();
+                ruleAlarmPointer.write(0, pAlarmInfo.getByteArray(0, ruleAlarm.size()), 0, ruleAlarm.size());
+                ruleAlarm.read();
+                log.info("alarm type in the NET_VCA_RULE_ALARM ---------->: {}", JSON.toJSONString(ruleAlarm));
+//                alarmDSService.pushLCommand(lCommand);
+                break;
+            case HCNetSDK.COMM_SNAP_MATCH_ALARM:
+                //人脸黑名单比对报警
+                log.info("SNAP_MATCH_ALARM");
+                HCNetSDK.NET_VCA_FACESNAP_MATCH_ALARM strFaceSnapMatch = new HCNetSDK.NET_VCA_FACESNAP_MATCH_ALARM();
+                strFaceSnapMatch.write();
+                Pointer pFaceSnapMatch = strFaceSnapMatch.getPointer();
+                pFaceSnapMatch.write(0, pAlarmInfo.getByteArray(0, strFaceSnapMatch.size()), 0, strFaceSnapMatch.size());
+                strFaceSnapMatch.read();
+                //比对结果
+                log.info("比对结果: {}", strFaceSnapMatch.byContrastStatus == 1 ? "比对成功" : "比对失败");
+                //人脸库ID
+                if (strFaceSnapMatch.struBlockListInfo.dwFDIDLen > 0) {
+                    long offset1 = 0;
+                    ByteBuffer buffers1 = strFaceSnapMatch.struBlockListInfo.pFDID.getByteBuffer(offset1, strFaceSnapMatch.struBlockListInfo.dwFDIDLen);
+                    byte[] bytes1 = new byte[strFaceSnapMatch.struBlockListInfo.dwFDIDLen];
+                    buffers1.get(bytes1);
+                    log.info("人脸库ID: {}", new String(bytes1));
+                }
+                //人脸库图片ID
+                if (strFaceSnapMatch.struBlockListInfo.dwPIDLen > 0) {
+                    long offset2 = 0;
+                    ByteBuffer buffers2 = strFaceSnapMatch.struBlockListInfo.pPID.getByteBuffer(offset2, strFaceSnapMatch.struBlockListInfo.dwPIDLen);
+                    byte[] bytes2 = new byte[strFaceSnapMatch.struBlockListInfo.dwPIDLen];
+                    buffers2.get(bytes2);
+                    log.info("图片ID: {}", new String(bytes2));
+                }
+                //保存抓拍人脸图，图片数据传输方式: 0- 二进制
+                if ((strFaceSnapMatch.dwSnapPicLen > 0) && (strFaceSnapMatch.byPicTransType == 0)) {
+                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                    String newName = sf.format(new Date());
+                    FileOutputStream fout;
+                    try {
+                        String filename = ".//pic//" + newName + "_pSnapPicBuffer" + ".jpg";
+                        fout = new FileOutputStream(filename);
+                        //将字节写入文件
+                        long offset = 0;
+                        ByteBuffer buffers = strFaceSnapMatch.pSnapPicBuffer.getByteBuffer(offset, strFaceSnapMatch.dwSnapPicLen);
+                        byte[] bytes = new byte[strFaceSnapMatch.dwSnapPicLen];
+                        buffers.rewind();
+                        buffers.get(bytes);
+                        fout.write(bytes);
+                        fout.close();
+                    } catch (IOException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+                //保存抓拍人脸图URL，图片数据传输方式: 1- URL 注：超脑设备人脸比对报警图片一般按照URL上传，根据URL去下载设备中存储的图片，认证方式选择：摘要认证
+                if ((strFaceSnapMatch.dwSnapPicLen > 0) && (strFaceSnapMatch.byPicTransType == 1)) {
+                    long offset = 0;
+                    ByteBuffer buffers = strFaceSnapMatch.pSnapPicBuffer.getByteBuffer(offset, strFaceSnapMatch.dwSnapPicLen);
+                    byte[] bytes = new byte[strFaceSnapMatch.dwSnapPicLen];
+                    buffers.rewind();
+                    buffers.get(bytes);
+                    log.info("人脸抓拍图片 URL: {}", new String(bytes));
+                }
+                if ((strFaceSnapMatch.struSnapInfo.dwSnapFacePicLen > 0) && (strFaceSnapMatch.byPicTransType == 0)) {
+                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                    String newName = sf.format(new Date());
+                    FileOutputStream fout;
+                    try {
+                        String filename = ".//pic//" + newName + "_struSnapInfo_pBuffer1" + ".jpg";
+                        fout = new FileOutputStream(filename);
+                        //将字节写入文件
+                        long offset = 0;
+                        ByteBuffer buffers = strFaceSnapMatch.struSnapInfo.pBuffer1.getByteBuffer(offset, strFaceSnapMatch.struSnapInfo.dwSnapFacePicLen);
+                        byte[] bytes = new byte[strFaceSnapMatch.struSnapInfo.dwSnapFacePicLen];
+                        buffers.rewind();
+                        buffers.get(bytes);
+                        fout.write(bytes);
+                        fout.close();
+                    } catch (IOException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+                if ((strFaceSnapMatch.struSnapInfo.dwSnapFacePicLen > 0) && (strFaceSnapMatch.byPicTransType == 1)) {
+                    long offset = 0;
+                    ByteBuffer buffers = strFaceSnapMatch.struSnapInfo.pBuffer1.getByteBuffer(offset, strFaceSnapMatch.struSnapInfo.dwSnapFacePicLen);
+                    byte[] bytes = new byte[strFaceSnapMatch.struSnapInfo.dwSnapFacePicLen];
+                    buffers.rewind();
+                    buffers.get(bytes);
+                    log.info("人脸抓拍图片1 URL: {}", new String(bytes));
+                }
+                //保存人脸库图片，图片数据传输方式: 0- 二进制
+                if ((strFaceSnapMatch.struBlockListInfo.dwBlockListPicLen > 0) && (strFaceSnapMatch.byPicTransType == 0)) {
+                    SimpleDateFormat sf = new SimpleDateFormat("yyyyMMddHHmmss");
+                    String newName = sf.format(new Date());
+                    FileOutputStream fout;
+                    try {
+                        String filename = ".//pic//" + newName + "_fSimilarity_" + strFaceSnapMatch.fSimilarity + "_struBlackListInfo_pBuffer1" + ".jpg";
+                        fout = new FileOutputStream(filename);
+                        //将字节写入文件
+                        long offset = 0;
+                        ByteBuffer buffers = strFaceSnapMatch.struBlockListInfo.pBuffer1.getByteBuffer(offset, strFaceSnapMatch.struBlockListInfo.dwBlockListPicLen);
+                        byte[] bytes = new byte[strFaceSnapMatch.struBlockListInfo.dwBlockListPicLen];
+                        buffers.rewind();
+                        buffers.get(bytes);
+                        fout.write(bytes);
+                        fout.close();
+                    } catch (IOException e) {
+                        // TODO Auto-generated catch block
+                        e.printStackTrace();
+                    }
+                }
+                //保存人脸库图片，图片数据传输方式: 1-URL
+                if ((strFaceSnapMatch.struBlockListInfo.dwBlockListPicLen > 0) && (strFaceSnapMatch.byPicTransType == 1)) {
+                    long offset = 0;
+                    ByteBuffer buffers = strFaceSnapMatch.struBlockListInfo.pBuffer1.getByteBuffer(offset, strFaceSnapMatch.struBlockListInfo.dwBlockListPicLen);
+                    byte[] bytes = new byte[strFaceSnapMatch.struBlockListInfo.dwBlockListPicLen];
+                    buffers.rewind();
+                    buffers.get(bytes);
+                    log.info("人脸库图片 URL: {}", new String(bytes));
+                }
+                //抓拍库附加信息数据指针，附加信息的XML文本中包含人脸温度数据
+                if (strFaceSnapMatch.struBlockListInfo.struBlockListInfo.dwFCAdditionInfoLen > 0) {
+                    long offset = 0;
+                    ByteBuffer buffers = strFaceSnapMatch.struBlockListInfo.struBlockListInfo.pFCAdditionInfoBuffer.getByteBuffer(offset, strFaceSnapMatch.struBlockListInfo.struBlockListInfo.dwFCAdditionInfoLen);
+                    byte[] bytes = new byte[strFaceSnapMatch.struBlockListInfo.struBlockListInfo.dwFCAdditionInfoLen];
+                    buffers.rewind();
+                    buffers.get(bytes);
+                    log.info("抓拍库附加信息: {}", new String(bytes));
+                }
+//                alarmDSService.pushLCommand(lCommand);
+                break;
+            default:
+                // TODO 单报警设备 目前不需要 sAlarmType alarmNow
+                log.info("alarm type in the FMSGCallBack_V31 ->int: {}", lCommand);
+//                alarmDSService.pushLCommand(lCommand);
+                break;
+        }
+    }
+
+}

src/main/java/com/unis/face/FaceMain.java

@@ -0,0 +1,186 @@
+package com.unis.face;
+
+import com.sun.jna.Native;
+import com.unis.common.HCNetSDK;
+import com.unis.common.osSelect;
+import com.unis.config.AddressModel;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2024-07-31 9:29
+ */
+@Slf4j
+@Component
+@Order(1)
+public class FaceMain implements ApplicationRunner {
+
+    static HCNetSDK hCNetSDK = null;
+    static int lUserID = -1;//用户句柄
+    static int lAlarmHandle = -1; //布防句柄
+    static int lListenHandle = -1; //监听句柄
+
+    // 设备连接信息
+    @Resource
+    private AddressModel addressModel;
+
+    /*
+     * 获取配置
+     */
+    private void mainMethod() {
+        log.info("FaceMain mainMethod===========================================================init thread");
+        try {
+            if (hCNetSDK == null) {
+                if (!CreateSDKInstance()) {
+                    log.error("Load SDK fail");
+                    return;
+                }
+            }
+            //linux系统建议调用以下接口加载组件库
+            if (osSelect.isLinux()) {
+                HCNetSDK.BYTE_ARRAY ptrByteArray1 = new HCNetSDK.BYTE_ARRAY(256);
+                HCNetSDK.BYTE_ARRAY ptrByteArray2 = new HCNetSDK.BYTE_ARRAY(256);
+                //这里是库的绝对路径，请根据实际情况修改，注意改路径必须有访问权限
+                String strPath1 = System.getProperty("user.dir") + "/lib/libcrypto.so.1.1";
+                String strPath2 = System.getProperty("user.dir") + "/lib/libssl.so.1.1";
+
+                System.arraycopy(strPath1.getBytes(), 0, ptrByteArray1.byValue, 0, strPath1.length());
+                ptrByteArray1.write();
+                hCNetSDK.NET_DVR_SetSDKInitCfg(3, ptrByteArray1.getPointer());
+
+                System.arraycopy(strPath2.getBytes(), 0, ptrByteArray2.byValue, 0, strPath2.length());
+                ptrByteArray2.write();
+                hCNetSDK.NET_DVR_SetSDKInitCfg(4, ptrByteArray2.getPointer());
+
+                String strPathCom = System.getProperty("user.dir") + "/lib";
+                HCNetSDK.NET_DVR_LOCAL_SDK_PATH struComPath = new HCNetSDK.NET_DVR_LOCAL_SDK_PATH();
+                System.arraycopy(strPathCom.getBytes(), 0, struComPath.sPath, 0, strPathCom.length());
+                struComPath.write();
+                hCNetSDK.NET_DVR_SetSDKInitCfg(2, struComPath.getPointer());
+            }
+
+            //初始化
+            hCNetSDK.NET_DVR_Init();
+
+            //加载日志
+            hCNetSDK.NET_DVR_SetLogToFile(3, "..//sdklog", false);
+
+            //登录设备，每一台设备分别登录; 登录句柄是唯一的，可以区分设备
+            HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();//设备登录信息
+            HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();//设备信息
+
+            String m_sDeviceIP = addressModel.getDeviceIP();//设备ip地址
+            m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];
+            System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length());
+
+            String m_sUsername = addressModel.getUserName();//设备用户名
+            m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];
+            System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length());
+
+            String m_sPassword = addressModel.getPassword();//设备密码
+            m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];
+            System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length());
+
+            m_strLoginInfo.wPort = 8000;
+            m_strLoginInfo.bUseAsynLogin = false; //是否异步登录：0- 否，1- 是
+            m_strLoginInfo.byLoginMode = 0;  //登录模式：0- SDK私有协议，1- ISAPI协议
+            m_strLoginInfo.write();
+
+            lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
+            if (lUserID == -1) {
+                log.error("登录失败,错误码为: {}", hCNetSDK.NET_DVR_GetLastError());
+            } else {
+                log.info("{} 设备登录成功!设备序列号: {}", m_sDeviceIP, new String(m_strDeviceInfo.struDeviceV30.sSerialNumber).trim());
+                m_strDeviceInfo.read();
+            }
+
+            //报警布防实时接收人脸比对的结果信息，也可以单独参考“2-报警布防监听”这个Demo示例
+            Alarm.SetAlarm(lUserID);
+
+            // TODO 暂停状态 需要测试改造
+            while (true) {
+                //这里加入控制台输入控制，是为了保持连接状态，当输入Y表示布防结束
+                log.info("请选择是否撤出布防(Y/N):");
+                BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));
+                String str = bufferedReader.readLine();
+                if (str.toUpperCase().equals("Y")) {
+                    break;
+                }
+            }
+            Thread.sleep(3000);
+
+            //退出之前判断布防监听状态，并做撤防和停止监听操作
+            if (lAlarmHandle >= 0) {
+                if (!hCNetSDK.NET_DVR_CloseAlarmChan_V30(lAlarmHandle)) {
+                    log.error("撤防失败，错误码: {}", hCNetSDK.NET_DVR_GetLastError());
+                } else {
+                    log.info("撤防成功！！！");
+                }
+            }
+            if (lListenHandle >= 0) {
+                if (!hCNetSDK.NET_DVR_StopListen_V30(lListenHandle)) {
+                    log.error("取消监听失败，错误码：{}", hCNetSDK.NET_DVR_GetLastError());
+                } else {
+                    log.info("停止监听成功！！！");
+                }
+            }
+
+            //注销登录，程序退出时调用；程序同时对接多台设备时，每一台设备分别调用一次接口，传入不同的登录句柄
+            if (lUserID >= 0) {
+                hCNetSDK.NET_DVR_Logout(lUserID);
+            }
+
+            //SDK反初始化，释放资源，程序退出时调用
+            boolean b = hCNetSDK.NET_DVR_Cleanup();
+            if (b)
+                log.info("释放资源,程序退出!");
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * 根据不同操作系统选择不同的库文件和库路径
+     *
+     * @return
+     */
+    private boolean CreateSDKInstance() {
+        if (hCNetSDK == null) {
+            synchronized (HCNetSDK.class) {
+                String strDllPath = "";
+                try {
+//                    System.setProperty("jna.debug_load", "true");
+                    if (osSelect.isWindows())
+                        //win系统加载库路径
+                        strDllPath = System.getProperty("user.dir") + "\\lib\\HCNetSDK.dll";
+                    else if (osSelect.isLinux())
+                        //Linux系统加载库路径
+                        strDllPath = System.getProperty("user.dir") + "/lib/libhcnetsdk.so";
+                    hCNetSDK = (HCNetSDK) Native.loadLibrary(strDllPath, HCNetSDK.class);
+                } catch (Exception ex) {
+                    log.error("loadLibrary: {} Error: {}", strDllPath, ex.getMessage());
+                    return false;
+                }
+            }
+        }
+        return true;
+    }
+
+    @Override
+    public void run(ApplicationArguments args) throws Exception {
+        // after behind for application run,because implements ApplicationRunner
+        this.mainMethod();
+    }
+}

src/main/resources/application-dev.yml

@@ -2,11 +2,11 @@
 # 设备登录
 exceptionAlarm:
   # 设备ip地址 枪机: DS-2CD7T27DWD-IZS(16384)/球机: DS-7716NX-I4(4354)
-  deviceIP: 192.168.0.103
+  deviceIP: 10.7.11.161
   # 设备用户名
   userName: admin
   # 设备密码
-  password: q1234567
+  password: Aa870618
   # orgCode
   org-code: SJG
 # 只支持post