From f480b48e591f5d52252267e6ffa740ee259cab7d Mon Sep 17 00:00:00 2001
From: riku <risaku@163.com>
Date: 星期日, 29 九月 2019 09:40:53 +0800
Subject: [PATCH] 删除原obd_data表的数据存储
---
src/main/kotlin/com/flightfeather/obd/socket/SocketServerClient.kt | 9 ++++++---
1 files changed, 6 insertions(+), 3 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..5ee34b1 100644
--- a/src/main/kotlin/com/flightfeather/obd/socket/SocketServerClient.kt
+++ b/src/main/kotlin/com/flightfeather/obd/socket/SocketServerClient.kt
@@ -1,15 +1,19 @@
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
import io.netty.handler.codec.string.StringEncoder
+import java.nio.charset.Charset
/**
* socket闀胯繛鎺ユ湇鍔＄
@@ -43,9 +47,8 @@
override fun initChannel(p0: NioSocketChannel?) {
p0?.pipeline()
// ?.addLast("decoder", StringDecoder())
-// ?.addLast("encoder", StringEncoder())
- ?.addLast(ByteArrayDecoder())
- ?.addLast(ByteArrayEncoder())
+ ?.addLast(ObdByteDataDecoder())
+ ?.addLast("encoder", StringEncoder(Charset.forName("UTF-8")))
?.addLast(ServerHandler())
}
})
--
Gitblit v1.9.3