obd 数据解码逻辑完成

riku

2019-09-15 4d44ed185203088052b10a8d1e3526fcbbc88331

 src/main/kotlin/com/flightfeather/obd/socket/ServerHandler.kt

@@ -3,6 +3,9 @@
import io.netty.channel.ChannelHandlerContext
import io.netty.channel.ChannelInboundHandlerAdapter
import io.netty.util.AttributeKey
import java.lang.StringBuilder
import java.text.SimpleDateFormat
import java.util.*


class ServerHandler : ChannelInboundHandlerAdapter() {
@@ -11,6 +14,7 @@

    override fun channelRegistered(ctx: ChannelHandlerContext?) {
        super.channelRegistered(ctx)
//        ctx?.fireChannelActive()
    }

    override fun channelActive(ctx: ChannelHandlerContext?) {
@@ -19,16 +23,27 @@

    override fun channelRead(ctx: ChannelHandlerContext?, msg: Any?) {
        super.channelRead(ctx, msg)
        println("------收到的原始数据：[ip:${ctx?.channel()?.remoteAddress()}]\r\n$msg")
        if (msg is String) {
            MessageManager().dealMsg(msg, ctx)
        }

//        val attribute = ctx?.channel()?.attr(attributeKey)?.apply {
//            if (get() == null) {
//                set(data.obdVin)
//            }
//        }
        val sb = StringBuilder()

        if (msg is ByteArray) {
            println("------收到的原始数据：[ip:${ctx?.channel()?.remoteAddress()}] ${SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(Date())}")
            msg.forEach {
                var a = 0
                a = if (it < 0) {
                    it + 256
                } else {
                    it.toInt()
                }
                print("${a.toString(16)} ")
                sb.append(a.toString(16)).append(" ")
            }
            sb.deleteCharAt(sb.length - 1)
        }
        val str = sb.toString()
        if (str.isNotEmpty()) {
            MessageManager().dealStringMsg(str, ctx)
        }

    }