From c9a3c06b37b5b2eb9b02d4e6348e5c53145284d9 Mon Sep 17 00:00:00 2001 From: riku <risaku@163.com> Date: 星期一, 16 九月 2019 17:40:20 +0800 Subject: [PATCH] 1. 添加注释 2. 添加粘包分包解码器 3. 修改数据单元信息体获取逻辑 4. 修改接收数据转换后的string列表,展示为16进制数时,小于16的应该在前面补0,否则之后计算会出错 --- src/main/kotlin/com/flightfeather/obd/socket/SocketServerClient.kt | 6 ++++-- 1 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/main/kotlin/com/flightfeather/obd/socket/SocketServerClient.kt b/src/main/kotlin/com/flightfeather/obd/socket/SocketServerClient.kt index 991a4e7..80904b7 100644 --- a/src/main/kotlin/com/flightfeather/obd/socket/SocketServerClient.kt +++ b/src/main/kotlin/com/flightfeather/obd/socket/SocketServerClient.kt @@ -1,11 +1,14 @@ package com.flightfeather.obd.socket import io.netty.bootstrap.ServerBootstrap +import io.netty.buffer.ByteBuf +import io.netty.buffer.Unpooled import io.netty.channel.ChannelInitializer import io.netty.channel.ChannelOption import io.netty.channel.nio.NioEventLoopGroup import io.netty.channel.socket.nio.NioServerSocketChannel import io.netty.channel.socket.nio.NioSocketChannel +import io.netty.handler.codec.DelimiterBasedFrameDecoder import io.netty.handler.codec.bytes.ByteArrayDecoder import io.netty.handler.codec.bytes.ByteArrayEncoder import io.netty.handler.codec.string.StringDecoder @@ -44,8 +47,7 @@ p0?.pipeline() // ?.addLast("decoder", StringDecoder()) // ?.addLast("encoder", StringEncoder()) - ?.addLast(ByteArrayDecoder()) - ?.addLast(ByteArrayEncoder()) + ?.addLast(ObdByteDataDecoder()) ?.addLast(ServerHandler()) } }) -- Gitblit v1.9.3