package com.netsdk.demo.customize;
|
|
import static com.netsdk.lib.Utils.getOsPrefix;
|
|
import java.io.File;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.netsdk.demo.customize.analyseTaskDemo.AnalyseTaskUtils;
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.NetSDKLib.LLong;
|
import com.netsdk.lib.NetSDKLib.NET_IN_TRANSMIT_INFO;
|
import com.netsdk.lib.NetSDKLib.NET_OUT_TRANSMIT_INFO;
|
import com.netsdk.lib.callback.impl.DefaultDisconnectCallback;
|
import com.netsdk.lib.callback.impl.DefaultHaveReconnectCallBack;
|
import com.netsdk.lib.structure.NET_CB_TRANSMIT_INFO;
|
import com.netsdk.lib.structure.NET_IN_ATTACH_TRANSMIT_INFO;
|
import com.netsdk.lib.structure.NET_IN_DETACH_TRANSMIT_INFO;
|
import com.netsdk.lib.structure.NET_OUT_ATTACH_TRANSMIT_INFO;
|
import com.netsdk.lib.structure.NET_OUT_DETACH_TRANSMIT_INFO;
|
import com.sun.jna.Memory;
|
import com.sun.jna.Pointer;
|
|
/**
|
* @author 251823
|
* @version 1.0
|
* @description 透传接口使用样例
|
* @date 2022/2/16
|
*/
|
public class TransmitInfoDemo {
|
// SDk对象初始化
|
public static final NetSDKLib netsdk = NetSDKLib.NETSDK_INSTANCE;
|
public static final NetSDKLib configsdk = NetSDKLib.CONFIG_INSTANCE;
|
|
// 判断是否初始化
|
private static boolean bInit = false;
|
// 判断log是否打开
|
private static boolean bLogOpen = false;
|
// 设备信息
|
private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
// 登录句柄
|
private NetSDKLib.LLong m_hLoginHandle = new NetSDKLib.LLong(0);
|
|
// 订阅句柄
|
private LLong attachHandle = new NetSDKLib.LLong(0);
|
|
// 回调函数需要是静态的，防止被系统回收
|
// 断线回调
|
private static NetSDKLib.fDisConnect disConnectCB = DefaultDisconnectCallback.getINSTANCE();
|
// 重连回调
|
private static NetSDKLib.fHaveReConnect haveReConnectCB = DefaultHaveReconnectCallBack.getINSTANCE();
|
|
// 编码格式
|
public static String encode;
|
|
// SID
|
private String sid = "";
|
|
static {
|
String osPrefix = getOsPrefix();
|
if (osPrefix.toLowerCase().startsWith("win32-amd64")) {
|
encode = "GBK";
|
} else if (osPrefix.toLowerCase().startsWith("linux-amd64")) {
|
encode = "UTF-8";
|
}
|
}
|
|
/**
|
* 初始化SDK库
|
*/
|
public static boolean Init() {
|
bInit = netsdk.CLIENT_Init(disConnectCB, null);
|
if (!bInit) {
|
System.out.println("Initialize SDK failed");
|
return false;
|
}
|
// 配置日志
|
TransmitInfoDemo.enableLog();
|
|
// 设置断线重连回调接口, 此操作为可选操作，但建议用户进行设置
|
netsdk.CLIENT_SetAutoReconnect(haveReConnectCB, null);
|
|
// 设置登录超时时间和尝试次数，可选
|
// 登录请求响应超时时间设置为3S
|
int waitTime = 3000;
|
// 登录时尝试建立链接 1 次
|
int tryTimes = 1;
|
netsdk.CLIENT_SetConnectTime(waitTime, tryTimes);
|
// 设置更多网络参数， NET_PARAM 的nWaittime ， nConnectTryNum 成员与 CLIENT_SetConnectTime
|
// 接口设置的登录设备超时时间和尝试次数意义相同,可选
|
NetSDKLib.NET_PARAM netParam = new NetSDKLib.NET_PARAM();
|
// 登录时尝试建立链接的超时时间
|
netParam.nConnectTime = 10000;
|
// 设置子连接的超时时间
|
netParam.nGetConnInfoTime = 3000;
|
netsdk.CLIENT_SetNetworkParam(netParam);
|
return true;
|
}
|
|
/**
|
* 打开 sdk log
|
*/
|
private static void enableLog() {
|
NetSDKLib.LOG_SET_PRINT_INFO setLog = new NetSDKLib.LOG_SET_PRINT_INFO();
|
File path = new File("sdklog/");
|
if (!path.exists())
|
path.mkdir();
|
|
// 这里的log保存地址依据实际情况自己调整
|
String logPath = path.getAbsoluteFile().getParent() + "\\sdklog\\" + "sdklog" + AnalyseTaskUtils.getDate()
|
+ ".log";
|
setLog.nPrintStrategy = 0;
|
setLog.bSetFilePath = 1;
|
System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
|
System.out.println(logPath);
|
setLog.bSetPrintStrategy = 1;
|
bLogOpen = netsdk.CLIENT_LogOpen(setLog);
|
if (!bLogOpen)
|
System.err.println("Failed to open NetSDK log");
|
}
|
|
/**
|
* 高安全登录
|
*/
|
public void loginWithHighLevel() {
|
// 输入结构体参数
|
NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY pstlnParam = new NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY() {
|
{
|
szIP = m_strIpAddr.getBytes();
|
nPort = m_nPort;
|
szUserName = m_strUser.getBytes();
|
szPassword = m_strPassword.getBytes();
|
}
|
};
|
// 输出结构体参数
|
NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY pstOutParam = new NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY();
|
|
// 写入sdk
|
m_hLoginHandle = netsdk.CLIENT_LoginWithHighLevelSecurity(pstlnParam, pstOutParam);
|
if (m_hLoginHandle.longValue() == 0) {
|
System.err.printf("Login Device[%s] Port[%d]Failed. %s\n", m_strIpAddr, m_nPort,
|
netsdk.CLIENT_GetLastError());
|
} else {
|
deviceInfo = pstOutParam.stuDeviceInfo; // 获取设备信息
|
System.out.println("Login Success");
|
System.out.println("Device Address：" + m_strIpAddr);
|
System.out.println("设备包含：" + deviceInfo.byChanNum + "个通道");
|
}
|
}
|
|
/**
|
* 退出
|
*/
|
public void logOut() {
|
if (m_hLoginHandle.longValue() != 0) {
|
netsdk.CLIENT_Logout(m_hLoginHandle);
|
System.out.println("LogOut Success");
|
}
|
}
|
|
/**
|
* 清除 sdk环境
|
*/
|
public static void cleanup() {
|
if (bLogOpen) {
|
netsdk.CLIENT_LogClose();
|
}
|
if (bInit) {
|
netsdk.CLIENT_Cleanup();
|
}
|
}
|
|
/**
|
* 清理并退出
|
*/
|
public static void cleanAndExit() {
|
netsdk.CLIENT_Cleanup();
|
System.exit(0);
|
}
|
|
/**
|
* 配置透传接口
|
*/
|
public String transmitInfoForWeb(String jsonParams) {
|
String request = jsonParams;
|
int dwInBufferSize = request.length();
|
Pointer szInBuffer = new Memory(dwInBufferSize);
|
szInBuffer.write(0, request.getBytes(), 0, request.getBytes().length);
|
int dwOutBufferSize = 10 * 1024;
|
Pointer szOutBuffer = new Memory(dwOutBufferSize);
|
boolean ret = netsdk.CLIENT_TransmitInfoForWeb(m_hLoginHandle, szInBuffer, dwInBufferSize, szOutBuffer,
|
dwOutBufferSize, null, 3000);
|
if (ret) {
|
System.out.println("TransmitInfoForWeb success");
|
byte[] str = szOutBuffer.getByteArray(0, dwOutBufferSize);
|
String strJson = new String(str);
|
System.out.println("配置透传接口返回数据:" + strJson);
|
return strJson;
|
} else {
|
// public static final int NET_UNSUPPORTED = (0x80000000 | 79); // 设备不支持该操作
|
System.err.printf("TransmitInfoForWeb false Last Error[0x%x]\n", netsdk.CLIENT_GetLastError());
|
return "";
|
}
|
}
|
|
/**
|
* 配置透传接口扩展实现
|
*/
|
public void transmitInfoForWebEx() {
|
JSONObject params = new JSONObject();
|
params.put("DeviceID", "1");
|
|
JSONObject JSONObject = new JSONObject();
|
JSONObject.put("method", "Things.getDevCaps");
|
JSONObject.put("params", params);
|
String request = JSONObject.toString();
|
System.out.println("request:" + request);
|
NET_IN_TRANSMIT_INFO pIn = new NET_IN_TRANSMIT_INFO();
|
pIn.emType = 0;
|
pIn.emEncryptType = 0;
|
String json = request;
|
|
pIn.dwInJsonBufferSize = json.getBytes().length;
|
pIn.szInJsonBuffer = json;
|
|
Pointer pInParam = new Memory(pIn.size());
|
ToolKits.SetStructDataToPointer(pIn, pInParam, 0);
|
|
NET_OUT_TRANSMIT_INFO pOut = new NET_OUT_TRANSMIT_INFO();
|
pOut.szOutBuffer = new Memory(1024 * 10);
|
pOut.dwOutBufferSize = 1024 * 10;
|
Pointer poutParam = new Memory(pOut.size());
|
ToolKits.SetStructDataToPointer(pOut, poutParam, 0);
|
|
boolean ret = netsdk.CLIENT_TransmitInfoForWebEx(m_hLoginHandle, pInParam, poutParam, 3000);
|
|
if (!ret) {
|
System.err.printf("transmitInfoForWebEX Failed!Last Error[0x%x]\n", ToolKits.getErrorCode());
|
} else {
|
System.out.println("transmitInfoForWebEX Succeed!");
|
|
ToolKits.GetPointerDataToStruct(poutParam, 0, pOut);
|
|
System.out.println("dwOutBinLen:" + pOut.dwOutBinLen);
|
System.out.println("dwOutJsonLen:" + pOut.dwOutJsonLen);
|
System.out.println("dwOutBufferSize:" + pOut.dwOutBufferSize);
|
|
byte[] str = pOut.szOutBuffer.getByteArray(0, pOut.dwOutJsonLen);// 解析字节长度根据实际返回字符串结果定义
|
System.out.println("配置透传扩展接口返回数据:" + new String(str));
|
}
|
}
|
|
|
/**
|
* 订阅设备上报数据
|
*/
|
public void thingsAttach() {
|
// 协议接口入参json字符串
|
String paramsJson = "{\"method\": \"Things.attach\",\"Params\": {\"DeviceID\": \"2\",\"ProductID\": \"001\",\"Topics\": [\"*\"]}}";
|
|
// 入参
|
NET_IN_ATTACH_TRANSMIT_INFO pIn = new NET_IN_ATTACH_TRANSMIT_INFO();
|
pIn.cbTransmitInfo = AsyncTransmitInfoDataCB.getInstance();//回调函数
|
pIn.dwUser = null;//用户数据
|
int dwInJsonBufferSize = paramsJson.length();
|
Pointer szInJsonBuffer = new Memory(dwInJsonBufferSize);
|
szInJsonBuffer.write(0, paramsJson.getBytes(), 0, paramsJson.getBytes().length);
|
pIn.dwInJsonBufferSize = dwInJsonBufferSize;//Json请求数据长度
|
pIn.szInJsonBuffer = szInJsonBuffer; //Json请求数据,用户申请空间
|
pIn.bSubConnFirst = true; //TRUE-当设备支持时，使用子连接方式接收订阅数据 FALSE-只在主连接接收订阅数据
|
Pointer pInParam = new Memory(pIn.size());
|
ToolKits.SetStructDataToPointer(pIn, pInParam, 0);
|
|
// 出参
|
NET_OUT_ATTACH_TRANSMIT_INFO pOut = new NET_OUT_ATTACH_TRANSMIT_INFO();
|
int initSize = 1024 * 10;
|
pOut.dwOutBufferSize = initSize;
|
pOut.szOutBuffer= new Memory(initSize);;
|
Pointer pOutParam = new Memory(pOut.size());
|
ToolKits.SetStructDataToPointer(pOut, pOutParam, 0);
|
|
attachHandle = netsdk.CLIENT_AttachTransmitInfo(m_hLoginHandle, pInParam, pOutParam, 3000);
|
if (attachHandle.longValue() == 0){
|
System.err.println("CLIENT_AttachTransmitInfo failed\n");
|
}else {
|
ToolKits.GetPointerDataToStruct(pOutParam, 0, pOut);
|
System.out.println("订阅句柄:" + attachHandle);
|
String str = new String(pOut.szOutBuffer.getByteArray(0, pOut.dwOutJsonLen));
|
System.out.println("事件订阅成功返回数据:" + str);
|
// 当请阅某一主题时会返回一个SID，这个ID用于用户取消订阅或者管理上报的数据。
|
// 返回示例 {session': '36jk8pWoa07dea792692606585', 'params': {'SID': 11}, 'result': True, 'id': 13}
|
JSONObject json = JSONObject.parseObject(str);
|
JSONObject params = json.getJSONObject("params");
|
sid = params.getString("SID");
|
System.out.println("SID:"+sid);
|
}
|
|
}
|
|
/**
|
* 订阅回调
|
*/
|
private static class AsyncTransmitInfoDataCB implements NetSDKLib.AsyncTransmitInfoCallBack {
|
|
private static AsyncTransmitInfoDataCB instance;
|
//private AsyncTransmitInfoDataCB() {}
|
public static AsyncTransmitInfoDataCB getInstance() {
|
if (instance == null) {
|
synchronized (AsyncTransmitInfoDataCB.class) {
|
if (instance == null) {
|
instance = new AsyncTransmitInfoDataCB();
|
}
|
}
|
}
|
return instance;
|
}
|
|
@Override
|
public void invoke(LLong lAttachHandle, NET_CB_TRANSMIT_INFO pTransmitInfo, Pointer dwUser) {
|
System.out.println("lAttachHandle:"+lAttachHandle);
|
// 订阅设备上报回来数据,解析参考具体返回Json字符串结构
|
byte[] str = pTransmitInfo.pBuffer.getByteArray(0, pTransmitInfo.dwJsonLen);
|
System.out.println("订阅回调数据:"+new String(str));
|
|
JSONObject json = JSONObject.parseObject(new String(str));
|
JSONObject params = json.getJSONObject("params");
|
String topics = params.getString("Topics");
|
System.out.println("Topics:"+topics);// “Props”: 表示订阅设备属性上报 “Events”: 标识订阅设备事件上报
|
}
|
}
|
|
/**
|
* 取消订阅
|
*/
|
public void thingsDetach() {
|
// 协议接口入参json字符串,SID的值取订阅成功的返回结果
|
String paramsJson = "{\"params\": {\"SID\": "+ sid +"}, \"method\": \"Things.detach\"}";
|
|
// 入参
|
NET_IN_DETACH_TRANSMIT_INFO pIn = new NET_IN_DETACH_TRANSMIT_INFO();
|
int dwInJsonBufferSize = paramsJson.length();
|
Pointer szInJsonBuffer = new Memory(dwInJsonBufferSize);
|
szInJsonBuffer.write(0, paramsJson.getBytes(), 0, paramsJson.getBytes().length);
|
pIn.dwInJsonBufferSize = dwInJsonBufferSize;//Json请求数据长度
|
pIn.szInJsonBuffer = szInJsonBuffer; //Json请求数据,用户申请空间
|
Pointer pInParam = new Memory(pIn.size());
|
ToolKits.SetStructDataToPointer(pIn, pInParam, 0);
|
|
// 出参
|
NET_OUT_DETACH_TRANSMIT_INFO pOut = new NET_OUT_DETACH_TRANSMIT_INFO();
|
int initSize = 1024 * 10;
|
pOut.dwOutBufferSize = initSize; //应答数据缓冲空间长度
|
pOut.szOutBuffer= new Memory(initSize);//应答数据缓冲空间, 用户申请空间
|
Pointer pOutParam = new Memory(pOut.size());
|
ToolKits.SetStructDataToPointer(pOut, pOutParam, 0);
|
boolean flg = netsdk.CLIENT_DetachTransmitInfo(attachHandle, pInParam, pOutParam, 3000);
|
if(flg) {
|
System.out.println("CLIENT_DetachTransmitInfo success\n");
|
attachHandle = new NetSDKLib.LLong(0);//订阅句柄清零
|
ToolKits.GetPointerDataToStruct(pOutParam, 0, pOut);
|
String str = new String(pOut.szOutBuffer.getByteArray(0, pOut.dwOutJsonLen));
|
System.out.println("取消事件订阅接口返回数据:" + str);
|
}
|
|
}
|
|
/**
|
* Things.getDevlist接口样例
|
*/
|
public void getDevlist() {
|
String jsonParams = "{\"params\": {}, \"method\": \"Things.getDevlist\"}";
|
this.transmitInfoForWeb(jsonParams);
|
}
|
|
/**
|
* Things.getDevCaps接口样例
|
*/
|
public void getDevCaps() {
|
String jsonParams = "{\"params\": {\"DeviceID\": \"1\"}, \"method\": \"Things.getDevCaps\"}";
|
this.transmitInfoForWeb(jsonParams);
|
}
|
|
/**
|
* Things.get接口样例
|
*/
|
public void get() {
|
String jsonParams = "{\"params\": {\"Properties\": [\"CJXX_CJWDZ_LX\", \"SBJCXX_SBBM\", \"SBJCXX_SBXH\", \"SBJCXX_XLH\", \"SBJCXX_RJBBH\", \"SBJCXX_CPLX\", \"SBJCXX_SBMS\", \"SBJCXX_EDDL\", \"SBJCXX_SBLX\", \"SBJCXX_KKPS\", \"SBJCXX_LJLBNL\", \"CJXX_CJDLBWD\", \"BJPZ_LDBJSN\", \"BJPZ_DHBJSN\"], \"DeviceID\": \"2\", \"ProductID\": \"001\"}, \"method\": \"Things.get\"}";
|
this.transmitInfoForWeb(jsonParams);
|
}
|
|
/**
|
* Things.set接口样例
|
*/
|
public void set() {
|
String jsonParams = "{\"params\": {\"Properties\": [{\"BJPZ_DHBJLDMS\": 1}, {\"BJPZ_LDBJLDMS\": 0}], \"DeviceID\": \"2\", \"ProductID\": \"001\"}, \"method\": \"Things.set\"}";
|
this.transmitInfoForWeb(jsonParams);
|
}
|
|
/**
|
* Things.getNetState接口样例
|
*/
|
public void getNetState() {
|
String jsonParams = "{\"params\": {}, \"method\": \"Things.getNetState\"}";
|
this.transmitInfoForWeb(jsonParams);
|
}
|
|
/**
|
* Things.service接口样例
|
*/
|
public void service() {
|
String jsonParams = "{\"params\": {\"ParamIn\": [], \"ServiceID\": \"leakCurtPost\", \"DeviceID\": \"2\", \"ProductID\": \"001\"}, \"method\": \"Things.service\"}";
|
this.transmitInfoForWeb(jsonParams);
|
}
|
|
// 分页查询用的token和总数
|
private String count = "";
|
private String token = "";
|
|
/**
|
* Things.startHistoryData接口样例
|
*/
|
public void startHistoryData() {
|
String jsonParams = "{\"params\": {\"Topics\": [\"\"]}, \"method\": \"Things.startHistoryData\"}";
|
String strJson = this.transmitInfoForWeb(jsonParams);
|
if(strJson.equals("")) {
|
return;
|
}
|
// strJson的字符串样例{"session": "awQMtQSb91fe54f62449364214", "params": {"Count": 0, "Token": 4}, "result": true, "id": 13}
|
JSONObject json = JSONObject.parseObject(strJson);
|
JSONObject params = json.getJSONObject("params");
|
count = params.getString("Count");
|
token = params.getString("Token");
|
}
|
|
/**
|
* Things.doHistoryData接口样例
|
*/
|
public void doHistoryData() {
|
String jsonParams = "{\"params\": {\"Count\": "+count+", \"Token\": "+token+", \"Offset\": 0}, \"method\": \"Things.doHistoryData\"}";
|
this.transmitInfoForWeb(jsonParams);
|
}
|
|
/**
|
* Things.stopHistoryData接口样例
|
*/
|
public void stopHistoryData() {
|
String jsonParams = "{\"params\": {\"Token\": "+ token +"}, \"method\": \"Things.stopHistoryData\"}";
|
this.transmitInfoForWeb(jsonParams);
|
}
|
|
|
|
/******************************** 测试控制台 ***************************************/
|
|
// 配置登陆地址，端口，用户名，密码
|
private String m_strIpAddr = "172.13.3.46";
|
private int m_nPort = 37777;
|
private String m_strUser = "admin";
|
private String m_strPassword = "admin123";
|
|
public static void main(String[] args) {
|
TransmitInfoDemo demo = new TransmitInfoDemo();
|
demo.InitTest();
|
demo.RunTest();
|
demo.EndTest();
|
}
|
|
/**
|
* 初始化测试
|
*/
|
public void InitTest() {
|
TransmitInfoDemo.Init();
|
this.loginWithHighLevel();
|
}
|
|
/**
|
* 加载测试内容
|
*/
|
public void RunTest() {
|
CaseMenu menu = new CaseMenu();
|
// 事件订阅功能
|
// 第一步：执行thingsAttach接口,订阅属性和事件上报，订阅成功返回订阅句柄attachHandle和SID
|
// 第二步：查看回调函数数据，为实时上报或者定时上报属性和事件数据，并解析数据（请不要再回调进行大量业务操作，导致卡回调）、
|
// 第三步：执行thingsDetach接口，取消订阅，并销毁订阅句柄
|
menu.addItem(new CaseMenu.Item(this, "Things.attach", "thingsAttach")); // 订阅设备上报数据
|
menu.addItem(new CaseMenu.Item(this, "Things.detach", "thingsDetach")); // 取消订阅
|
|
// 配置协议
|
// 配置协议接口入参json字符串，调用CLIENT_TransmitInfoForWeb透传接口，解析出参szInBuffer的返回数据
|
menu.addItem(new CaseMenu.Item(this, "Things.getDevlist", "getDevlist"));
|
menu.addItem(new CaseMenu.Item(this, "Things.getDevCaps", "getDevCaps"));
|
menu.addItem(new CaseMenu.Item(this, "Things.get", "get"));
|
menu.addItem(new CaseMenu.Item(this, "Things.set", "set"));
|
menu.addItem(new CaseMenu.Item(this, "Things.getNetState", "getNetState"));
|
menu.addItem(new CaseMenu.Item(this, "Things.service", "service"));
|
|
menu.addItem(new CaseMenu.Item(this, "Things.startHistoryData", "startHistoryData"));//开始查询历史数据，获取分页查询用的token和总数。
|
menu.addItem(new CaseMenu.Item(this, "Things.doHistoryData", "doHistoryData"));//分页查询
|
menu.addItem(new CaseMenu.Item(this, "Things.stopHistoryData", "stopHistoryData"));//停止查询历史数据
|
|
//menu.addItem(new CaseMenu.Item(this, "transmitInfoForWebEx", "transmitInfoForWebEx"));
|
menu.run();
|
}
|
|
/**
|
* 结束测试
|
*/
|
public void EndTest() {
|
System.out.println("End Test");
|
this.logOut(); // 退出
|
System.out.println("See You...");
|
TransmitInfoDemo.cleanAndExit(); // 清理资源并退出
|
}
|
/******************************** 结束 ***************************************/
|
}
|
