package com.netsdk.demo.customize;
|
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.structure.*;
|
import com.netsdk.lib.utils.Initialization;
|
import com.sun.jna.Memory;
|
import com.sun.jna.Pointer;
|
import java.io.File;
|
import java.io.UnsupportedEncodingException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* @author 291189
|
* @version 1.0
|
* @description GIP220929012
|
* @date 2022/10/26 16:13
|
*/
|
public class AttachGyroDemo extends Initialization {
|
|
NetSDKLib.LLong lAttachHandle=new NetSDKLib.LLong();
|
|
static List<Pointer> pointers=new ArrayList<>();
|
/**
|
* 订阅陀螺仪数据接口
|
*/
|
public void attachGyro(){
|
|
String dwUser="{"+"ip:"+ipAddr+",port:"+port+"}";
|
|
// CLIENT_AttachGyro接口入参
|
NET_IN_ATTACH_GYRO input=new NET_IN_ATTACH_GYRO();
|
Pointer dwUserData
|
= GetStringToPointer(dwUser, encode);
|
input.cbNotifyGyroData=NotifyGyroData.getInstance();
|
input.dwUser=dwUserData;
|
Pointer inputPointer =new Memory(input.size());
|
|
inputPointer.clear(input.size());
|
|
ToolKits.SetStructDataToPointer(input,inputPointer,0);
|
|
//CLIENT_AttachGyro接口出参
|
NET_OUT_ATTACH_GYRO outPut=new NET_OUT_ATTACH_GYRO();
|
|
Pointer outPutPointer =new Memory(outPut.size());
|
|
outPutPointer.clear(outPut.size());
|
|
ToolKits.SetStructDataToPointer(outPut,outPutPointer,0);
|
|
lAttachHandle = netSdk.CLIENT_AttachGyro(loginHandle,inputPointer,outPutPointer,3000 );
|
|
if(lAttachHandle.longValue()!=0){
|
System.out.println(" CLIENT_AttachGyro Success");
|
pointers.add(dwUserData);
|
}else {
|
System.out.println("CLIENT_AttachGyro Failed!LastError "+
|
ToolKits.getErrorCode());
|
}
|
}
|
|
/**
|
* 取消陀螺仪数据订阅接口
|
*/
|
public void detachGyro(){
|
|
if(lAttachHandle.longValue()!=0){
|
|
boolean b
|
= netSdk.CLIENT_DetachGyro(lAttachHandle);
|
|
if(b){
|
System.out.println(" CLIENT_DetachGyro Success");
|
|
}else {
|
System.out.println("CLIENT_DetachGyro Failed!LastError "+
|
ToolKits.getErrorCode());
|
}
|
|
}
|
|
|
}
|
|
/**
|
* 订阅陀螺仪数据接口回调函数原型, lAttachGyroHandle为CLIENT_AttachGyro接口的返回值
|
*/
|
private static class NotifyGyroData implements NetSDKLib.fNotifyGyroData {
|
private final File picturePath;
|
private static NotifyGyroData instance;
|
|
private NotifyGyroData() {
|
picturePath = new File("./AnalyzerPicture/");
|
if (!picturePath.exists()) {
|
picturePath.mkdirs();
|
}
|
}
|
|
public static NotifyGyroData getInstance() {
|
if (instance == null) {
|
synchronized (NotifyGyroData.class) {
|
if (instance == null) {
|
instance = new NotifyGyroData();
|
}
|
}
|
}
|
return instance;
|
}
|
|
|
@Override
|
public void invoke(NetSDKLib.LLong lAttachGyroHandle, Pointer pstuGyroDataInfo, Pointer dwUser) {
|
|
String s = GetPointerDataToString(dwUser,encode);
|
System.out.println("dwUser:"+s);
|
NET_NOTIFY_GYRO_DATA_INFO msg=new NET_NOTIFY_GYRO_DATA_INFO();
|
|
ToolKits.GetPointerData(pstuGyroDataInfo,msg);
|
|
System.out.println("msg:"+msg.toString());
|
|
|
}
|
}
|
|
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 void RunTest()
|
{
|
System.out.println("Run Test");
|
CaseMenu menu = new CaseMenu();
|
menu.addItem(new CaseMenu.Item(this , "订阅陀螺仪数据接口" , "attachGyro"));
|
menu.addItem(new CaseMenu.Item(this , "取消陀螺仪数据订阅接口" , "detachGyro"));
|
menu.run();
|
}
|
|
private static String ipAddr = "10.55.157.161";
|
private static int port = 37777;
|
private static String user = "admin";
|
private static String password = "admin123";
|
|
public static void main(String[] args){
|
InitTest(ipAddr, port, user, password);
|
AttachGyroDemo attachGyroDemo=new AttachGyroDemo();
|
attachGyroDemo.RunTest();
|
LoginOut();
|
}
|
}
|
