登录 注册
开源 企业版 高校版 私有云 Gitee AI NEW
扫描微信二维码支付
取消
支付完成
Watch
不关注 关注所有动态 仅关注版本发行动态 关注但不提醒动态
3 Star 0 Fork 0

Gitee 极速下载 / jcstruct

代码 Wiki 统计 流水线
服务
加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目，私有仓库也完全免费 ：）
免费加入
此仓库是为了提升国内下载速度的镜像仓库，每日同步一次。 原始仓库： https://github.com/yanghao0518/mypro_2017/tree/master/jcstruct.git
克隆/下载
分支 1
标签 0
贡献代码
同步代码
创建 Pull Request
了解更多
对比差异 通过 Pull Request 同步
同步更新到分支
通过 Pull Request 同步
将会在向当前分支创建一个 Pull
Request，合入后将完成同步
取消
提示: 由于 Git 不支持空文件夾，创建文件夹后会生成空的 .keep 文件
jcstruct
LICENSE
README.md
Loading...
README
Apache-2.0

介绍

   描述：为了解决java与C结构通信过程中结构体解析问题。
   主要功能：能友好的用java处理任何发送的C结构体对象，并且能发送java对象转换成C结构体接收的二进制。

功能说明

1、基于spring框架开发
2、对于结构体定义采用可视化XML配置，便于维护与调试，防止协议多次修改带来的麻烦。
3、所有关健解析操作都基于接口开发，有默认实现，也可以用于自定义实现，能满足所有特殊业务解析需求。
4、配置简单，使用方便、易上手。

使用实例

1、全局配置
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
  xmlns:cjava="http://www.haoyu.com/schema/cjava"
	xmlns:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-4.0.xsd
        http://www.haoyu.com/schema/cjava
        http://www.haoyu.com/schema/cjava/cjava-1.0.xsd
		"
	default-lazy-init="false">

 <!-- 对于ByteArray类型的特殊处理，该类需要继承com.haoyu.module.jcstruct.opt.AbstractJFieldOpt-->	
	<bean id="byteArrayJFieldOpt" class="com.haoyu.module.jcstruct.opt.ByteArrayJFieldOpt"></bean>
  
	<!-- 加入模板容器处理，默认实现类com.haoyu.module.jcstruct.template.DefaultTemplateContainer -->
	<cjava:templateContainer/>
  
  <!-- 解析管理类，默认com.haoyu.module.jcstruct.opt.DefaultOptManager，继承com.haoyu.module.jcstruct.opt.AbstractOptManager-->
	<cjava:optManager class="com.haoyu.module.jcstruct.opt.OptManagerForDebug">
   <!-- 对于ByteArray类型的解析的特殊处理->	
  <cjava:optManagerOne key="bytearray" value-ref="byteArrayJFieldOpt"/>
  </cjava:optManager>
  
  <!-- 调度中心配置，该类主要用于处理不同协议的业务处理，并返回处理结果。默认实现类:com.haoyu.module.jcstruct.dispatch.DefaultDispatchCenterServiceImpl，自定义实现需要继承AbstractDispatchCenterService-->	
	<cjava:dispatchCenterService/>
  
  <!-- 启动加载完成后的自定义刷新管理类，用于加载完成后从spring集合里取出指定类型或者指定KEY的对象，具体刷新类需要实现RefreshService接口，默认实现类:com.haoyu.module.jcstruct.refresh.RefreshServiceManager-->
	<cjava:refreshManager/>
	
  <!-- 测试类的包路径加入到spring-->
	<context:component-scan base-package="com.haoyu.module.jcstruct.test.handle" />
	
  <!-- 解析的辅助类加入到spring-->
	<context:component-scan base-package="com.haoyu.module.jcstruct.resolve" />

  <!-- 启动检查字段-->
	<cjava:check/> 

  <!-- 接收C结构体定义XML-->
  <import resource="spring-cjava-fc.xml"/>
    
  <!-- 返回C结构体的协议定义XML->
  <import resource="spring-cjava-tc.xml"/>
	
</beans>

说明：
spring头文件需要加入
xmlns:cjava="http://www.haoyu.com/schema/cjava"
xsi:schemaLocation中需要加入
http://www.haoyu.com/schema/cjava
http://www.haoyu.com/schema/cjava/cjava-1.0.xsd
对自定义cjava标签支持。
2、结构体协议配置(举例)
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:cjava="http://www.haoyu.com/schema/cjava"
	xmlns:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-4.0.xsd
        http://www.haoyu.com/schema/cjava
        http://www.haoyu.com/schema/cjava/cjava-1.0.xsd
		"
	default-lazy-init="false">
	
    <!-- 协议头-->
	<cjava:fch key="Package_Type"><!-- key用来定位协议ID的标识 -->
		<cjava:field name="Constant_Up" type="ushort" desc="2字节，前导字符，固定为0XAAAA，表示为上行数据包-" />
		<cjava:field name="Gateway_Id" type="unsigendint" desc="4字节，网关id号" />
		<cjava:field name="Package_Type" type="char" desc="具体根据每个协议ID决定" />
	</cjava:fch>
	
	
	<cjava:fct name="ACK" id="1" desc="通讯确认协议号0x01">
		<cjava:field name="Version" type="char" desc="1字节,网关软件版本  " />
		<cjava:field name="Package_length" type="ushort" desc="2字节数据包长度，单位字节，从Package_length（包含）至BCC（包含） " />
		<cjava:field name="Package_Number" type="ushort" desc="字节，包序号，copy接收到的上行数据包包序号 " />
		<cjava:field name="command_properties" type="char" desc="
		 =0x01,表示传感节点测试通信 
		=0x02，数据接收正确
		=0x03，数据接收错误，要求重发
        =0x04，数据接收错误，不要求重发
        =0X05，终止传输（多包传输时使用）。
        =0X06，接收正确，命令无法执行。"/>
		<cjava:field name="BCC" type="char" desc="1个字节，前面所有数据含前导，异或运算 " />
		<cjava:field name="Constant_Up_Stop" type="ushort" desc="2字节，固定为0XAA55，表示为上行数据包结束 " />
	</cjava:fct>
	
	<cjava:fct name="HeartBeat" id="5" desc="心跳 协议号0x05">
	    <cjava:field name="Package_Number" type="ushort" desc="字节，包序号，copy接收到的上行数据包包序号 " />
	    <cjava:field name="BCC" type="char" desc="1个字节，前面所有数据含前导，异或运算 " />
		<cjava:field name="Constant_Up_Stop" type="ushort" desc="2字节，固定为0XAA55，表示为上行数据包结束 " />
	</cjava:fct>
	
	<cjava:fct name="Character" id="2" desc="特征值  0x02">
	
	  <cjava:field name="Sensor_Id" type="unsigendint" desc="4字节，传感器ID  " />
		<cjava:field name="Version" type="char" desc="1字节,网关软件版本  " />
		<cjava:field name="Package_length" type="ushort" desc="2字节数据包长度，单位字节，从Package_length（包含）至BCC（包含） " />
		<cjava:field name="Package_Number" type="ushort" desc="字节，包序号，copy接收到的上行数据包包序号 " />
		<cjava:field name="command_properties" type="char" desc="
		 1字节，=0x01,表示传感器霍尔触发上传数据=0x02，表示传感器定时上传数据"/>
		 
		 
		 <cjava:field name="Recver_Riss" type="char" desc="接收到这包数据的场强 " />
		 <cjava:field name="Battery" type="char" desc="电池电量,百分数  " />
		 <cjava:field name="Temperature" type="short" realValueRule="{*}{0.01}" desc="2字节，温度值,真实值等于该值*0.01" />
		 <cjava:field name="Character_Attribute" type="char" desc="1字节，数据类型，即后面一组数据的类型。1加速度 2速度  " />
		 <cjava:field name="Data_coefficient" type="ushort" desc="系数, 计算方法见5.11中Data_ coefficient字段  " />
		 
 		 <cjava:field name="Data_x_Rms" type="ushort" desc="2字节，x方向RMS值 " />
 		 <cjava:field name="Data_x_PP" type="ushort" desc="2字节，x方向峰峰值" />
 		 <cjava:field name="Data_x_P" type="ushort" desc="2字节，x方向峰值 " />
 		 
 		 <cjava:field name="Data_y_Rms" type="ushort" desc="2字节，y方向RMS值 " />
 		 <cjava:field name="Data_y_PP" type="ushort" desc="2字节，y方向峰峰值" />
 		 <cjava:field name="Data_y_P" type="ushort" desc="2字节，y方向峰值 " />
 
 		 <cjava:field name="Data_z_Rms" type="ushort" desc="2字节，z方向RMS值 " />
 		 <cjava:field name="Data_z_PP" type="ushort" desc="2字节，z方向峰峰值" />
 		 <cjava:field name="Data_z_P" type="ushort" desc="2字节，z方向峰值 " />
		 
		<cjava:field name="BCC" type="char" desc="1个字节，前面所有数据含前导，异或运算 " />
		<cjava:field name="Constant_Up_Stop" type="ushort" desc="2字节，固定为0XAA55，表示为上行数据包结束 " />
		
	</cjava:fct>
	
	<cjava:fct name="Sensor" id="3" desc="传感器组网信息上传（0X03">
	  <cjava:field name="Sensor_Id" type="unsigendint" desc="4字节，传感器ID  " />
		<cjava:field name="Version" type="char" desc="1字节,网关软件版本  " />
		<cjava:field name="Package_length" type="ushort" desc="2字节数据包长度，单位字节，从Package_length（包含）至BCC（包含） " />
		<cjava:field name="Package_Number" type="ushort" desc="2字节，包序号，copy接收到的上行数据包包序号 " />
		<cjava:field name="command_properties" type="char" desc="
		1字节，=0x01,表示传感器霍尔触发上传数据=0x02，表示传感器定时上传数据"/>
		<cjava:field name="Recver_Riss" type="char" desc="接收到这包数据的场强 " />
		<cjava:field name="BCC" type="char" desc="1个字节，前面所有数据含前导，异或运算 " />
		<cjava:field name="Constant_Up_Stop" type="ushort" desc="2字节，固定为0XAA55，表示为上行数据包结束 " />
	</cjava:fct>
	
	<cjava:fct name="Wave" id="4" desc="波形数据 ">
	  <cjava:field name="Sensor_Id" type="unsigendint" desc="4字节，传感器ID  " />
		<cjava:field name="Version" type="char" desc="1字节,网关软件版本  " />
		<cjava:field name="Package_length" type="ushort" desc="2字节数据包长度，单位字节，从Package_length（包含）至BCC（包含） " />
		<cjava:field name="Package_Number" type="ushort" desc="2字节，包序号，copy接收到的上行数据包包序号 " />
		<cjava:field name="command_properties" type="char" desc="
		1字节，命令属性为0X04，表示传感节点申请波形上传
		1字节，命令属性为0X05，表示中间包
		1字节，命令属性为0X06，表示结束包
		"/>
		
		
		<cjava:branchs key="command_properties"><!-- 特殊情况，对于二级KEY定位的标识 -->
		
			<cjava:branch keyValue="4" desc="表示传感节点申请波形上传"> <!-- 二级KEY的分支协议-->
				<cjava:field name="Wave_attribute" type="char" desc="当前数据属性" />
				<cjava:field name="Wave_long" type="char" desc="波形长度=0  512点  =1  1024点 =2 	2048点	=3	4096点 =4	8192点" />
				<cjava:field name="Temperature" type="short" realValueRule="{*}{0.01}" desc="真实值等于该值*0.01" />
				<cjava:field name="Sample_Frequency" type="ushort"  desc="采样频率 " />
				<cjava:field name="Wave_coefficient" type="ushort"  desc="后续发送值*系数/100得到真实值 " />
			</cjava:branch>
			
			<cjava:branch keyValue="5" desc="波形结束包数据 "> <!-- 二级KEY的分支协议-->
				<cjava:field name="Wave_data" type="bytearray" realLengthRule="{Package_length}{-}{6}" desc="1024个数据，每包1024个数据，最后一包按实际剩余数据量 " />
			</cjava:branch>
			
			<cjava:branch keyValue="6" desc="波形结束包数据 "> <!-- 二级KEY的分支协议-->
			</cjava:branch>
			
		</cjava:branchs><!-- 二级KEY的分支结束-->

		<cjava:field name="BCC" type="char" desc="1个字节，前面所有数据含前导，异或运算 " />
		<cjava:field name="Constant_Up_Stop" type="ushort" desc="2字节，固定为0XAA55，表示为上行数据包结束 " />
	</cjava:fct>
	
</beans>
注：返回给C结构的协议类同参考包下面的spring-cjava-tc.xml
3、自定义业务实现（举例，对特征值解析以后的处理）
package com.haoyu.module.jcstruct.test.handle;

import java.util.Date;
import org.apache.log4j.Logger;
import org.springframework.stereotype.Service;
import com.alibaba.fastjson.JSONObject;
import com.haoyu.module.jcstruct.annotation.HandleMessageProtocol;
import com.haoyu.module.jcstruct.handle.HandleMessageService;
import com.haoyu.module.jcstruct.model.DefaultResponseResult;

/**
 * 处理特征值显示
 * 
 * @author haoyu
 *
 */
//spring注解
@Service("handleCharacterMessage")
//待处理的协议注解，解析出数据后的主键KEY(协议号标识)与根据此注解id匹配，如果匹配成功，在此做协议的处理并返回处理结果
@HandleMessageProtocol(id = GatewayServerCodeType.Gateway_Server_Character)
//处理类必须要实现HandleMessageService接口
public class HandleCharacterMessage extends AbstractHandleMessageService implements HandleMessageService
{
	Logger LOG = Logger.getLogger(this.getClass());

	// @Autowired
	// private ReceiveDataService receiveDataService;

	@Override
	public void handle(JSONObject message, DefaultResponseResult responseResult)
	{
		//LOG.info("接收特征值信息:" + message);
		System.out.println("接收特征值信息:" + message);
		// 往趋势图加入数据
		try {
			String Sensor_Id = message.getLong("Sensor_Id").toString();

			// 获取温度
			float Temperature = message.getFloatValue("Temperature");

			// 获取电量
			int Battery = message.getIntValue("Battery");

			// 接收端数据= 数据/Data_coefficient
			float Data_coefficient = message.getIntValue("Data_coefficient");

			float Data_x_Rms = message.getIntValue("Data_x_Rms") / Data_coefficient;
			float Data_x_PP = message.getIntValue("Data_x_PP") / Data_coefficient;
			float Data_x_P = message.getIntValue("Data_x_P") / Data_coefficient;

			float Data_y_Rms = message.getIntValue("Data_y_Rms") / Data_coefficient;
			float Data_y_PP = message.getIntValue("Data_y_PP") / Data_coefficient;
			float Data_y_P = message.getIntValue("Data_y_P") / Data_coefficient;

			float Data_z_Rms = message.getIntValue("Data_z_Rms") / Data_coefficient;
			float Data_z_PP = message.getIntValue("Data_z_PP") / Data_coefficient;
			float Data_z_P = message.getIntValue("Data_z_P") / Data_coefficient;

			JSONObject receiveData = new JSONObject();

			receiveData.put("temperature", Temperature);

			receiveData.put("battery", Battery);

			receiveData.put("datatime", System.currentTimeMillis());

			LOG.info("特征值上传时间:mills:" + receiveData.get("datatime") + "->times:" + new Date());

			// 用于判断是否为速度、加速度
			int type = message.getIntValue("Character_Attribute");

			receiveData.put("dataType", type);

			if (type == 1) {
				// 加速度
				receiveData.put("xValue", Data_x_P);
				receiveData.put("yValue", Data_y_P);
				receiveData.put("zValue", Data_z_P);

			} else {
				// 速度

				receiveData.put("xValue", Data_x_Rms);
				receiveData.put("yValue", Data_y_Rms);
				receiveData.put("zValue", Data_z_Rms);
			}

			// 调用接口
			//receiveDataService.receiveFromSimulative(ReceiveDataService.HIS_DATA, Sensor_Id, receiveData);
			System.out.println("处理解析特征值上传信息成功，待上传的数据信息为" + receiveData);

			buildDefaultSuccess(message, responseResult);
		} catch (Exception e) {
			LOG.error("处理接收后的特征值信息接口异常:" + e.getMessage(), e);
			buildDefaultFail(message, responseResult);
		}

	}

}


4、测试代码
package com.haoyu.module.jcstruct;

import java.io.IOException;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import com.alibaba.fastjson.JSONObject;
import com.haoyu.module.jcstruct.common.BaseDataType;
import com.haoyu.module.jcstruct.dispatch.DispatchCenterService;
import com.haoyu.module.jcstruct.exception.DtuMessageException;
import com.haoyu.module.jcstruct.model.ResolveResult;
import com.haoyu.module.jcstruct.model.ResponseResult;
import com.haoyu.module.jcstruct.opt.JFieldOpt;
import com.haoyu.module.jcstruct.opt.OptManager;
import com.haoyu.module.jcstruct.resolve.DefaultResolve;
import com.haoyu.module.jcstruct.template.TemplateContainer;
import com.haoyu.module.jcstruct.test.handle.GatewayServerCodeType;
import com.haoyu.module.jcstruct.utils.HexUtils;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:spring-cjava.xml")
public class AppTest
{

	@Autowired
	private TemplateContainer templateContainer;

	@Autowired
	private OptManager optManager;

	@Autowired
	private DispatchCenterService dispatchCenterService;

	@Autowired
	private DefaultResolve defaultResolve;

	// 测试解析特征值，协议号0x02
	private void testCharacterResolve() throws DtuMessageException, IOException
	{
		byte[] data = new byte[] { -86, -86, -3, 79, -6, -119, 2, 18, -85, -51, -17, 1, 0, 31, 101, -61, 3, 83, 0, 10, -26, 2, 0, 10, 1, 87, 6, 69, 3, -80, 0, -18, 3, 98, 1, -59, 1, -114, 7, 66, 4, 104, 31, -86, 85 };
		ResolveResult<JSONObject> json = defaultResolve.resolve(data, null);
		// 处理特征值
		ResponseResult responseResult = dispatchCenterService.handle(json.getId(), json.getResult());
		byte[] rtnData = defaultResolve.unresolve(responseResult.getId(), responseResult.getData());
		System.out.println("处理特征值以后返回给C结构数据为:" + HexUtils.bytesToHexString(rtnData));

	}

	// 测试解析波形，协议号0x04
	private void testWaveResolve() throws DtuMessageException, IOException
	{
		// 申请上传波形
		byte[] data = new byte[] { -86, -86, -3, 79, -6, -119, 4, 18, -85, -51, -17, 1, 0, 14, 102, 72, 4, 2, 1, 10, -26, 0, 0, 0, 100, -16, -86, 85 };

		ResolveResult<JSONObject> json = defaultResolve.resolve(data, null);

		System.out.println(json.getId() + "->" + json.getResult());

		// 中间波形
		data = new byte[] { -86, -86, -3, 79, -6, -119, 4, 18, -85, -51, -17, 1, 4, 6, 102, 73, 5, -17, -61, -18, -5, -10, -71, 4, -94, 16, 30, 22, 14, 22, 110, 19, 119, 15, 67, 6, 111, -1, 85, -4, 72, -4, 89, 5, 64, 13, -15, 17, -89, 13, -29, 6, 66, -2, -55, -10, 59, -17, -103, -30, 108, -38, -22, -33, 29, -19, -62, -3, 42, 8, 94, 6, -13, 5, -79, 4, -78, 2, -50, -6, -127, -14, -21, -16, 114, -6, 46, 7, 56, 16, 62, 18, 93, 13, -3, 8, -15, 1, 66, -6, -76, 0, 46, -3, -57, -5,
				-17, 2, 40, 13, -116, 21, -63, 23, -82, 18, 19, 12, 49, 6, 57, -4, 30, -6, 13, -10, 35, -8, -37, 3, 97, 11, 118, 14, -83, 9, 54, 2, 122, -6, -83, -13, 64, -20, -8, -27, -7, -28, 14, -22, -64, -7, 83, 5, 114, 13, 75, 13, -11, 12, -39, 10, 1, 3, 121, -7, 74, -11, -37, -11, -20, -1, -35, 10, -96, 16, 123, 14, -8, 8, -117, 2, 3, -7, -24, -13, -54, -25, -37, -34, 73, -32, 72, -19, 69, -3, 88, 8, -16, 8, -75, 5, 110, 4, 56, 2, -83, -5, 1, -15, 89, -19, 56, -11, 117,
				3, -96, 13, -25, 18, 114, 14, -39, 10, -91, 3, -121, -4, -78, -6, -22, -8, -118, -10, 101, -3, 39, 9, -96, 19, -75, 24, 35, 21, -46, 17, 15, 11, -84, 2, 47, 0, -125, -3, 91, -3, -90, 6, 58, 14, 76, 17, 68, 12, -102, 4, -78, -4, -53, -12, -87, -19, -30, -29, -50, -33, 50, -28, 91, -14, -34, 0, 88, 9, -51, 8, 63, 7, 49, 5, 103, 2, 20, -8, -4, -13, 40, -14, 21, -5, -57, 7, -9, 15, -5, 17, 6, 12, 15, 6, -125, -2, -88, -8, 91, -3, -97, -7, 12, -9, -79, -2, -40, 10,
				-84, 18, -29, 19, -19, 13, -79, 7, -12, 2, -94, -8, -28, -11, 70, -15, 11, -11, 31, 0, -20, 9, -49, 13, -32, 8, -61, 2, -15, -5, 98, -12, 78, -18, 80, -22, -105, -23, -123, -16, -128, -2, -113, 10, 21, 17, 11, 17, -112, 15, -65, 12, 78, 4, -104, -7, -12, -10, 53, -10, 110, 0, 43, 10, 109, 15, -39, 13, -26, 7, 55, 0, -108, -8, 125, -14, 70, -27, -47, -36, -95, -33, 52, -20, -29, -3, 3, 8, -106, 8, 19, 4, -2, 3, -82, 2, 35, -6, 103, -15, 22, -19, 34, -11, -71,
				3, -63, 13, -12, 18, 102, 14, -54, 10, -107, 3, -94, -3, 0, -1, -93, -3, -121, -5, 1, 0, -59, 12, 78, 21, -91, 25, 24, 21, -77, 16, 55, 10, 121, 0, -97, -2, -69, -5, -127, -4, 49, 4, -21, 12, -2, 15, -10, 11, 75, 3, 114, -5, -18, -13, -13, -19, 80, -29, 31, -34, -58, -28, 32, -14, -37, 0, 123, 9, -22, 8, 51, 6, -56, 4, -65, 1, 104, -8, -113, -14, -44, -15, -57, -5, -86, 8, 2, 16, 47, 17, 38, 11, -15, 6, 44, -2, 125, -8, 31, -4, 55, -9, 10, -11, -62, -3, 100,
				9, -85, 18, 85, 19, -100, 13, 94, 7, -8, 2, -63, -7, 84, -14, -65, -19, 127, -15, -62, -2, 102, 8, 98, 13, 66, 8, -13, 3, -122, -4, 87, -11, -92, -17, -46, -20, 105, -21, 69, -14, 67, 0, 21, 11, -112, 18, 97, 18, -89, 16, -90, 13, 9, 5, -124, -6, -50, -10, -23, -10, -27, 0, 121, 10, -35, 16, 116, 14, -70, 8, 8, 1, 102, -7, 50, -14, -41, -25, 116, -34, 59, -32, 50, -19, 59, -3, 62, 8, -81, 8, -82, 5, 1, 3, 53, 1, -111, -7, -16, -16, -12, -20, 106, -12, 106, 2,
				-115, 12, -27, 17, -81, 14, 41, 9, -9, 3, 28, -4, -77, -5, 118, -8, -9, -10, -38, -3, 54, 9, -84, 19, -22, 24, -128, 22, -39, 18, 109, 13, 37, 3, -93, -3, 2, -6, 12, -6, -65, 3, -64, 12, 97, 15, -40, 11, -118, 4, 12, -4, -8, -11, 55, -18, -42, -30, 13, -37, -115, -32, 86, -17, 98, -2, 59, 8, -46, 7, 10, 5, 90, 4, 57, 2, 8, -7, -20, -14, 49, -16, 7, -7, -13, 7, 20, 15, -7, 18, 33, 13, -107, 8, 79, 0, -26, -6, -110, 0, 69, -4, 50, -6, 124, 1, 39, 12, -46, 21,
				111, 23, 81, 17, 106, 11, -116, 5, -93, -5, -104, -6, 25, -10, -109, -7, 56, 3, -66, 12, 41, 15, 108, 9, -6, 3, 1, -5, 53, -13, -76, -19, 89, -25, -81, -26, 20, -20, 120, -6, -71, 6, -104, 14, 55, 13, -10, 12, -121, 9, 109, 3, 30, -8, -14, -12, 111, -12, 83, -2, 74, 9, 97, 15, -7, 15, 24, 8, -43, 2, 118, -6, 69, -12, 19, -23, 24, -33, -99, -31, 53, -19, -20, -3, -26, 9, 103, 10, 3, 6, 29, 3, -5, 1, -40, -6, 57, -15, 1, -20, 8, -13, -122, 1, -64, 12, -121, 17,
				-67, 13, -24, 9, -110, 2, -74, -4, 27, -6, -27, -8, -128, -10, 43, -4, 86, 8, -104, 19, 45, 24, 65, 23, 45, 19, 26, 14, 12, 4, -102, -3, 98, -6, 4, -6, 108, 3, 102, 12, 75, 15, -17, 12, 46, 4, -85, -3, -120, -11, -81, -17, 99, -31, -16, -38, -85, -33, 60, -18, 43, -3, 117, 8, -121, 6, -28, 5, 49, 4, 58, 2, 95, -6, 124, -14, 36, -17, -115, -7, 55, 6, -112, 15, -57, 18, 76, 14, 54, 9, 83, 1, -53, -5, 89, 1, 71, -3, 120, -5, 109, 1, -57, 13, 97, 21, -17, 23, -46,
				18, 56, 12, 95, 6, 126, -4, 29, -5, 5, -8, 9, -6, -111, 4, -59, 12, -112, 15, 125, 9, -50, 2, -56, -6, -21, -13, 58, -20, -33, -27, -117, -29, 103, -23, -42, -8, 82, 4, -77, 12, -50, 12, -52, 11, -88, 9, 4, 2, -23, -8, -41, -12, 1, -12, 4, -2, 49, 9, 124, 16, 8, 15, 21, 8, -26, 2, -87, -6, 76, -37, -86, 85 };

		json = defaultResolve.resolve(data, null);

		System.out.println(json.getId() + "->" + json.getResult());

		// 最后一组上传波形
		data = new byte[] { -86, -86, -3, 79, -6, -119, 4, 18, -85, -51, -17, 1, 0, 6, 102, 83, 6, 106, -86, 85 };

		json = defaultResolve.resolve(data, null);

		System.out.println(json.getId() + "->" + json.getResult());

	}

	// 测试解析确认信息协议，协议号0x01
	private void testACKResolve() throws DtuMessageException, IOException
	{
		byte[] data = new byte[] { -86, -86, -3, 79, -6, -119, 2, 18, -85, -51, -17, 1, 0, 31, 101, -61, 3, 83, 0, 10, -26, 2, 0, 10, 1, 87, 6, 69, 3, -80, 0, -18, 3, 98, 1, -59, 1, -114, 7, 66, 4, 104, 31, -86, 85 };

		ResolveResult<JSONObject> json = defaultResolve.resolve(data, null);

		System.out.println(json.getId() + "->" + json.getResult());

	}

	// 测试解析心跳信息协议，协议号0x05
	private void testHeartBeatResolve() throws DtuMessageException, IOException
	{
		byte[] data = new byte[] { -86, -86, -3, 79, -6, -119, 2, 18, -85, -51, -17, 1, 0, 31, 101, -61, 3, 83, 0, 10, -26, 2, 0, 10, 1, 87, 6, 69, 3, -80, 0, -18, 3, 98, 1, -59, 1, -114, 7, 66, 4, 104, 31, -86, 85 };

		ResolveResult<JSONObject> json = defaultResolve.resolve(data, null);

		System.out.println(json.getId() + "->" + json.getResult());

	}

	// 测试解析组网上传协议，协议号0x03
	private void testSensorResolve() throws DtuMessageException, IOException
	{
		byte[] data = new byte[] { -86, -86, -3, 79, -6, -119, 2, 18, -85, -51, -17, 1, 0, 31, 101, -61, 3, 83, 0, 10, -26, 2, 0, 10, 1, 87, 6, 69, 3, -80, 0, -18, 3, 98, 1, -59, 1, -114, 7, 66, 4, 104, 31, -86, 85 };

		ResolveResult<JSONObject> json = defaultResolve.resolve(data, null);

		System.out.println(json.getId() + "->" + json.getResult());

	}

	// 测试反解析
	private void testUnResolve() throws DtuMessageException, IOException
	{
		// 反解析
		JSONObject ack = new JSONObject();
		ack.put("Package_Type", 1);
		ack.put("Gateway_Id", 4249877129L);
		ack.put("Package_Number", 0);
		ack.put("command_properties", 2);
		ack.put("BCC", 1);

		byte[] data = defaultResolve.unresolve("1", ack);

		// [85, 85, -3, 79, -6, -119, 1, 0, 6, 0, 0, 2, 1, 85, -86]
		// 打印16进制
		System.out.println(HexUtils.bytesToHexString(data));

	}

	// 测试反解析下发配置
	private void testUnResolveSensorConfig() throws DtuMessageException, IOException
	{

		String s = "{\"Gateway_Id\":\"4249877129\",\"Upload_Sensor_Type\":\"9\",\"Sensor_Id\":\"313249263\"," + "\"HP_Filter\":\"2\",\"X_Angle\":\"0\",\"Sample_Character_Time\":\"1\",\"Upload_Wave_Type\":\"113\"," + "\"Upload_Character_Time\":\"1\",\"Upload_Wave_Time\":\"2\",\"Wave_long\":\"1\",\"Sample_Frequency\":\"800\"," + "\"Temperature_alarm_diff\":\"35\",\"Temperature_alarm_HH\":\"80\",\"Temperature_alarm_Change\":\"5\","
				+ "\"Acc_X_alarm_HH\":\"1\",\"Acc_X_alarm_H\":\"0.8\",\"Acc_Y_alarm_HH\":\"1\",\"Acc_Y_alarm_H\":\"0.8\"," + "\"Acc_Z_alarm_HH\":\"1\",\"Acc_Z_alarm_H\":\"0.8\",\"Speed_X_alarm_HH\":\"1\",\"Speed_X_alarm_H\":\"0.8\"," + "\"Speed_Y_alarm_HH\":\"1\",\"Speed_Y_alarm_H\":\"0.8\",\"Speed_Z_alarm_HH\":\"1\",\"Speed_Z_alarm_H\":\"0.8\"}";

		JSONObject sensorConfig = JSONObject.parseObject(s);

		sensorConfig.put("Package_Type", 6);

		sensorConfig.put("Package_Number", 0);

		sensorConfig.put("BCC", 1);

		byte[] data = defaultResolve.unresolve("6", sensorConfig);

		System.out.println(HexUtils.bytesToHexString(data));

	}

	@Test
	public void test()
	{
		try {
			testCharacterResolve();

			testWaveResolve();

			testUnResolve();

			testUnResolveSensorConfig();

			JSONObject content = new JSONObject();
			content.put("Constant_Up", 43690);
			content.put("Gateway_Id", 35526545);
			content.put("Package_Type", 5);
			content.put("Package_Number", 13);
			content.put("BCC", 1);
			content.put("Constant_Up_Stop", 43605);
			// 处理心跳业务
			ResponseResult result = dispatchCenterService.handle(GatewayServerCodeType.Gateway_Server_HeartBeat, content);
			// 返回下发C结构体二进制
			byte[] resultData = this.defaultResolve.unresolve(result.getId(), result.getData());
			System.out.println(HexUtils.bytesToHexString(resultData));

		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	private void testother()
	{
		// 获取读取BYTEARRAY类的操作类
		JFieldOpt jReadArray = optManager.getJFieldOpt(BaseDataType.BYTEARRAY);
		try {
			// 调用read方法
			jReadArray.read(null, null, 512);

		} catch (IOException e) {
			e.printStackTrace();
		}

		// 获取读取SHORTARRAY类的操作类
		JFieldOpt jReadShortArray = optManager.getJFieldOpt(BaseDataType.SHORTARRAY);
		try {
			jReadShortArray.read(null, null, 520);

		} catch (IOException e) {
			e.printStackTrace();
		}

		// 根据返回C协议号ID获取模板类
		Template tm = templateContainer.getFCTemplate("1");

		System.out.println(tm.toString());

		// 测试处理业务类
		JSONObject content = new JSONObject();
		dispatchCenterService.handle("5", content);
	}

}
Apache License Version 2.0, January 2004 http://www.apache.org/licenses/ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION 1. Definitions. "License" shall mean the terms and conditions for use, reproduction, and distribution as defined by Sections 1 through 9 of this document. "Licensor" shall mean the copyright owner or entity authorized by the copyright owner that is granting the License. "Legal Entity" shall mean the union of the acting entity and all other entities that control, are controlled by, or are under common control with that entity. For the purposes of this definition, "control" means (i) the power, direct or indirect, to cause the direction or management of such entity, whether by contract or otherwise, or (ii) ownership of fifty percent (50%) or more of the outstanding shares, or (iii) beneficial ownership of such entity. "You" (or "Your") shall mean an individual or Legal Entity exercising permissions granted by this License. "Source" form shall mean the preferred form for making modifications, including but not limited to software source code, documentation source, and configuration files. "Object" form shall mean any form resulting from mechanical transformation or translation of a Source form, including but not limited to compiled object code, generated documentation, and conversions to other media types. "Work" shall mean the work of authorship, whether in Source or Object form, made available under the License, as indicated by a copyright notice that is included in or attached to the work (an example is provided in the Appendix below). "Derivative Works" shall mean any work, whether in Source or Object form, that is based on (or derived from) the Work and for which the editorial revisions, annotations, elaborations, or other modifications represent, as a whole, an original work of authorship. For the purposes of this License, Derivative Works shall not include works that remain separable from, or merely link (or bind by name) to the interfaces of, the Work and Derivative Works thereof. "Contribution" shall mean any work of authorship, including the original version of the Work and any modifications or additions to that Work or Derivative Works thereof, that is intentionally submitted to Licensor for inclusion in the Work by the copyright owner or by an individual or Legal Entity authorized to submit on behalf of the copyright owner. For the purposes of this definition, "submitted" means any form of electronic, verbal, or written communication sent to the Licensor or its representatives, including but not limited to communication on electronic mailing lists, source code control systems, and issue tracking systems that are managed by, or on behalf of, the Licensor for the purpose of discussing and improving the Work, but excluding communication that is conspicuously marked or otherwise designated in writing by the copyright owner as "Not a Contribution." "Contributor" shall mean Licensor and any individual or Legal Entity on behalf of whom a Contribution has been received by Licensor and subsequently incorporated within the Work. 2. Grant of Copyright License. Subject to the terms and conditions of this License, each Contributor hereby grants to You a perpetual, worldwide, non-exclusive, no-charge, royalty-free, irrevocable copyright license to reproduce, prepare Derivative Works of, publicly display, publicly perform, sublicense, and distribute the Work and such Derivative Works in Source or Object form. 3. Grant of Patent License. Subject to the terms and conditions of this License, each Contributor hereby grants to You a perpetual, worldwide, non-exclusive, no-charge, royalty-free, irrevocable (except as stated in this section) patent license to make, have made, use, offer to sell, sell, import, and otherwise transfer the Work, where such license applies only to those patent claims licensable by such Contributor that are necessarily infringed by their Contribution(s) alone or by combination of their Contribution(s) with the Work to which such Contribution(s) was submitted. If You institute patent litigation against any entity (including a cross-claim or counterclaim in a lawsuit) alleging that the Work or a Contribution incorporated within the Work constitutes direct or contributory patent infringement, then any patent licenses granted to You under this License for that Work shall terminate as of the date such litigation is filed. 4. Redistribution. You may reproduce and distribute copies of the Work or Derivative Works thereof in any medium, with or without modifications, and in Source or Object form, provided that You meet the following conditions: (a) You must give any other recipients of the Work or Derivative Works a copy of this License; and (b) You must cause any modified files to carry prominent notices stating that You changed the files; and (c) You must retain, in the Source form of any Derivative Works that You distribute, all copyright, patent, trademark, and attribution notices from the Source form of the Work, excluding those notices that do not pertain to any part of the Derivative Works; and (d) If the Work includes a "NOTICE" text file as part of its distribution, then any Derivative Works that You distribute must include a readable copy of the attribution notices contained within such NOTICE file, excluding those notices that do not pertain to any part of the Derivative Works, in at least one of the following places: within a NOTICE text file distributed as part of the Derivative Works; within the Source form or documentation, if provided along with the Derivative Works; or, within a display generated by the Derivative Works, if and wherever such third-party notices normally appear. The contents of the NOTICE file are for informational purposes only and do not modify the License. You may add Your own attribution notices within Derivative Works that You distribute, alongside or as an addendum to the NOTICE text from the Work, provided that such additional attribution notices cannot be construed as modifying the License. You may add Your own copyright statement to Your modifications and may provide additional or different license terms and conditions for use, reproduction, or distribution of Your modifications, or for any such Derivative Works as a whole, provided Your use, reproduction, and distribution of the Work otherwise complies with the conditions stated in this License. 5. Submission of Contributions. Unless You explicitly state otherwise, any Contribution intentionally submitted for inclusion in the Work by You to the Licensor shall be under the terms and conditions of this License, without any additional terms or conditions. Notwithstanding the above, nothing herein shall supersede or modify the terms of any separate license agreement you may have executed with Licensor regarding such Contributions. 6. Trademarks. This License does not grant permission to use the trade names, trademarks, service marks, or product names of the Licensor, except as required for reasonable and customary use in describing the origin of the Work and reproducing the content of the NOTICE file. 7. Disclaimer of Warranty. Unless required by applicable law or agreed to in writing, Licensor provides the Work (and each Contributor provides its Contributions) on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied, including, without limitation, any warranties or conditions of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A PARTICULAR PURPOSE. You are solely responsible for determining the appropriateness of using or redistributing the Work and assume any risks associated with Your exercise of permissions under this License. 8. Limitation of Liability. In no event and under no legal theory, whether in tort (including negligence), contract, or otherwise, unless required by applicable law (such as deliberate and grossly negligent acts) or agreed to in writing, shall any Contributor be liable to You for damages, including any direct, indirect, special, incidental, or consequential damages of any character arising as a result of this License or out of the use or inability to use the Work (including but not limited to damages for loss of goodwill, work stoppage, computer failure or malfunction, or any and all other commercial damages or losses), even if such Contributor has been advised of the possibility of such damages. 9. Accepting Warranty or Additional Liability. While redistributing the Work or Derivative Works thereof, You may choose to offer, and charge a fee for, acceptance of support, warranty, indemnity, or other liability obligations and/or rights consistent with this License. However, in accepting such obligations, You may act only on Your own behalf and on Your sole responsibility, not on behalf of any other Contributor, and only if You agree to indemnify, defend, and hold each Contributor harmless for any liability incurred by, or claims asserted against, such Contributor by reason of your accepting any such warranty or additional liability. END OF TERMS AND CONDITIONS APPENDIX: How to apply the Apache License to your work. To apply the Apache License to your work, attach the following boilerplate notice, with the fields enclosed by brackets "{}" replaced with your own identifying information. (Don't include the brackets!) The text should be enclosed in the appropriate comment syntax for the file format. We also recommend that a file or class name and description of purpose be included on the same "printed page" as the copyright notice for easier identification within third-party archives. Copyright {yyyy} {name of copyright owner} Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Starred
0
Star
0
Fork
0

简介

暂无描述 展开 收起
暂无标签
https://www.oschina.net/p/jcstruct
Java
Apache-2.0
使用 Apache-2.0 开源许可协议
取消

发行版

暂无发行版

贡献者

全部

近期动态

加载更多
不能加载更多了
Java
1
https://gitee.com/mirrors/jcstruct.git
git@gitee.com:mirrors/jcstruct.git
mirrors
jcstruct
jcstruct
master
点此查找更多帮助

搜索帮助

Git 命令在线学习 如何在 Gitee 导入 GitHub 仓库
Git 仓库基础操作
企业版和社区版功能对比
SSH 公钥设置
如何处理代码冲突
仓库体积过大，如何减小？
如何找回被删除的仓库数据
Gitee 产品配额说明
GitHub仓库快速导入Gitee及同步更新
什么是 Release（发行版）
将 PHP 项目自动发布到 packagist.org
评论
仓库举报
回到顶部