本文主要是介绍JT809协议交通809协议简单实现(Java版),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
简介
最近公司有个项目需要接收公交公司的实时推送的公交车位置数据。于是就用Netty简单实现了JT809协议的部分功能。
-
服务端(上级平台)主链路
-
主链路登录请求报文解析
-
主链路登录应答消息
-
车辆实时车辆定位信息消息报文解析
主要代码和使用
- 项目结构
解码适配器
package cn.xiuminglee.jt809.protocol;import cn.xiuminglee.jt809.common.util.CommonUtils;
import cn.xiuminglee.jt809.common.util.CrcUtil;
import cn.xiuminglee.jt809.common.util.PacketDecoderUtils;
import cn.xiuminglee.jt809.packet.JT809BasePacket;
import cn.xiuminglee.jt809.protocol.decoder.DecoderFactory;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import java.util.List;import static cn.xiuminglee.jt809.common.util.CommonUtils.PACKET_CACHE;/*** @Author: Xiuming Lee* @Describe: 解码适配器*/
public class JT809DecoderAdapter extends ByteToMessageDecoder {private static Logger log = LoggerFactory.getLogger(JT809DecoderAdapter.class);@Overrideprotected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {//判断是否有可读的字节if (in.readableBytes() <= 0) {return;}// 1、进行转义byte[] bytes = PacketDecoderUtils.decoderEscape(in);// 2、校验crcif (!CrcUtil.checkCRC(bytes)){return;}// 3、判断是那种类型的数据,交给具体的解码器类完成。ByteBuf byteBuf = CommonUtils.getByteBuf(bytes);byteBuf.skipBytes(9);// 获取业务标志short msgId = byteBuf.readShort();// 交给具体的解码器JT809BasePacket packet = null;try {packet = DecoderFactory.getDecoder(msgId).decoder(bytes);} catch (Exception e) {if (e instanceof NullPointerException) {// log.info("没有可用的解析器,忽略这条信息!此信息不在业务范围内。");// 没有可用的解析器,忽略这条信息!此信息不在业务范围内。} else {log.error("报文解析出错!错误信息:{};报文信息:{};",e.getMessage(),PACKET_CACHE.get(Thread.currentThread().getName()));}return;}out.add(packet);}
}
这个解码适配器会根据报文的业务标志从
DecoderFactory
获取具体的解码器去解析报文。所以如果需要扩展,只需要编写相关业务的解码器并添加到
DecoderFactory
即可。
package cn.xiuminglee.jt809.protocol.decoder;import cn.xiuminglee.jt809.common.Const;import java.util.HashMap;
import java.util.Map;/*** @Author: Xiuming Lee* @Describe: 解码工厂类*/
public class DecoderFactory {private static Map<Short,Decoder> DECODER_FACTORY = new HashMap<>();static {DECODER_FACTORY.put(Const.BusinessDataType.UP_CONNECT_REQ,new LoginDecoder());DECODER_FACTORY.put(Const.BusinessDataType.UP_LINKTEST_REQ,new HeartbeatDecoder());DECODER_FACTORY.put(Const.BusinessDataType.UP_EXG_MSG,new JT809Packet0x1202Decoder());}/*** @param businessDataType 业务数据类型标志* @return 具体的解码器*/public static Decoder getDecoder(short businessDataType){return DECODER_FACTORY.get(businessDataType);}
}
GitHub地址
这篇关于JT809协议交通809协议简单实现(Java版)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!