package com.netsdk.demo.customize.transmitInfoDemo;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.netsdk.demo.customize.transmitInfoDemo.entity.DeviceInfo;
|
import com.netsdk.demo.customize.transmitInfoDemo.module.LoginModule;
|
import com.netsdk.demo.customize.transmitInfoDemo.module.SdkUtilModule;
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.Utils;
|
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.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;
|
|
import java.nio.charset.Charset;
|
|
|
/**
|
* @author 251823
|
* @description 透传接口演示样例
|
* @date 2022/3/23
|
*/
|
public class TransmitInfoForWebDemo {
|
|
static NetSDKLib netsdk = NetSDKLib.NETSDK_INSTANCE;
|
// 登录句柄
|
private final NetSDKLib.LLong m_hLoginHandle;
|
// 设备信息
|
private final NetSDKLib.NET_DEVICEINFO_Ex m_hDeviceInfo;
|
// 订阅句柄
|
private LLong attachHandle = new NetSDKLib.LLong(0);
|
// SID
|
private String sid = "";
|
// 跨平台编码
|
private final Charset encode = Charset.forName(Utils.getPlatformEncode());
|
|
public TransmitInfoForWebDemo(DeviceInfo deviceInfo) {
|
this.m_hLoginHandle = deviceInfo.m_hLoginHandle;
|
this.m_hDeviceInfo = deviceInfo.m_stDeviceInfo;
|
}
|
|
public TransmitInfoForWebDemo(NetSDKLib.LLong loginHandle, NetSDKLib.NET_DEVICEINFO_Ex deviceinfo) {
|
this.m_hLoginHandle = loginHandle;
|
this.m_hDeviceInfo = deviceinfo;
|
}
|
|
/////////////////////////////////////// 业务接口 ///////////////////////////////////////
|
/////////////////////////////////////////////////////////////////////////////////////////
|
|
/**
|
* 配置透传接口
|
*/
|
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);
|
}
|
|
|
|
|
|
/////////////////////////////////////// 简易控制台 ///////////////////////////////////////
|
/////////////////////////////////////////////////////////////////////////////////////////
|
|
/**
|
* 初始化测试
|
*/
|
public void InitTest() {
|
SdkUtilModule.Init(); // 初始化SDK库
|
NetSDKLib.LLong loginHandle = LoginModule.TcpLoginWithHighSecurity(m_ipAddr, m_nPort, m_username, m_password, m_hDeviceInfo); // 高安全登录
|
if (loginHandle.intValue() == 0) {
|
SdkUtilModule.cleanup();
|
}
|
m_hLoginHandle.setValue(loginHandle.longValue());
|
}
|
|
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();
|
System.out.println("子测试已退出");
|
}
|
|
/**
|
* 结束测试
|
*/
|
public void EndTest() {
|
System.out.println("End Test");
|
LoginModule.logout(m_hLoginHandle); // 登出
|
System.out.println("See You...");
|
SdkUtilModule.cleanup(); // 清理资源
|
System.exit(0);
|
}
|
|
/////////////// 配置登陆地址，端口，用户名，密码 ////////////////////////
|
private String m_ipAddr = "172.13.3.206";
|
private int m_nPort = 37777;
|
private String m_username = "admin";
|
private String m_password = "admin123";
|
//////////////////////////////////////////////////////////////////////3
|
|
|
public static void main(String[] args) {
|
|
NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
NetSDKLib.LLong loginHandle = new NetSDKLib.LLong(0);
|
TransmitInfoForWebDemo demo = new TransmitInfoForWebDemo(loginHandle, deviceInfo);
|
if (args.length == 4) {
|
demo.m_ipAddr = args[0];
|
demo.m_nPort = Integer.parseInt(args[1]);
|
demo.m_username = args[2];
|
demo.m_password = args[3];
|
}
|
demo.InitTest();
|
demo.RunTest();
|
demo.EndTest();
|
}
|
}
|
