您现在的位置是：首页 > 文章详情

交通标准 808 解析软件二次开发包 v1.2.2 发布

日期：2020-05-15点击：407收藏

介绍

这个二次开发包是基于作者之前做过项目的源码改造的，那个时候使用不是很标准，仅仅是解析车辆定位数据，并没有实现所有的内容。现在有时间终于可以重构一下原来的项目源码。

版本特性

20200512 v1.2.2

💥 兼容交通标准808协议的2011、2013、2019版本
💥 基于 Spring 系列框架，充分利用 Spring 的优势，改写扩展都很简单（自定义消息包处理器）
💢 修复报警和状态解析的异常

20200503 v1.0.1

💥 处理分包粘包
💥 兼容交通标准808协议的2011、2013版本
💥 超长指令分包下发（一般是超过1K）
💥 分包处理（上传信息分包会合并解析）

如何开发

完整开发视频请访问重构录屏
基于开发包进行二次开发请访问直播录屏
详细说明请访问我的博客
最小化启动项目已经开源，欢迎访问
作者 JDK 使用的是 openJDK 12 版本，还没有在其他 JDK 版本进行测试。

下面是基于maven简短的开发使用步骤，详细还请访问直播录屏

创建新的 spring boot 项目的 pom 文件，并添加以下依赖：

 <dependency> <groupId>com.zhoyq</groupId> <artifactId>spring-boot-starter-jt808</artifactId> <version>1.2.2</version> </dependency>

新建启动类，并且配置不使用Web容器（当然有需要也可以使用）。添加 @EnableJt808Server 注解。

 @SpringBootApplication @EnableJt808Server public class Application { public static void main (String[] args) { var app = new SpringApplication(Application.class); // 不使用web容器 仅启动jt808服务 app.setWebApplicationType(WebApplicationType.NONE); app.run(args); } }

实现持久化接口，项目中已经有了基于 HashMap 的会话层的接口，仍需用户提供持久化的Bean。

 import com.zhoyq.server.jt808.starter.service.DataService; @Component public class SimpleDataService implements DataService

然还有在 application.yml 中添加配置：

 jt808: enabled: true use: mina protocol: tcp port: 10001 processCount: 2 corePoolSize: 1 maximumPoolSize: 10 # 单位毫秒 keepAliveTime: 1000 # 单位秒 idleTime: 10 idleCount: 6 readBufferSize: 2048 packageLength: 1024 threadCorePoolSize: 1 threadMaximumPoolSize: 10 # 单位毫秒 threadKeepAliveTime: 1000 masterSize: 1 slaveSize: 10 tcpNoDelay: true keepAlive: true

建议使用 mina 配置，因为作者之前写的工程就是基于 mina 写的，当然我也写了 netty 的版本。

至此，启动程序，祝生活愉快。

如何扩展

因为很多时候处理逻辑并不是那么严谨，还是有需要自定义一些常规逻辑所以开放了对于单条命令的扩展方式，本节目标是使用自定义心跳包扩展，放弃原有心跳包逻辑定义。只需要定义一个类即可，如下：

 import com.zhoyq.server.jt808.starter.core.Jt808Pack; import com.zhoyq.server.jt808.starter.core.PackHandler; import com.zhoyq.server.jt808.starter.helper.ResHelper; import lombok.extern.slf4j.Slf4j; /**  * 0x0002 终端心跳  */ @Slf4j @Jt808Pack(msgId = 0x0002) public class HeartbeatPackHandler implements PackHandler { @Override public byte[] handle(byte[] phoneNum, byte[] streamNum, byte[] msgId, byte[] msgBody) { log.info("new heartbeat."); return ResHelper.getPlatAnswer(phoneNum, streamNum, msgId, (byte) 0x00); } }