From 57b3b0851b2144073522a43640c2acc9452e1719 Mon Sep 17 00:00:00 2001
From: riku <risaku@163.com>
Date: 星期三, 30 十月 2019 14:52:34 +0800
Subject: [PATCH] 新增接口： 1. 获取车辆轨迹
---
src/main/kotlin/com/flightfeather/obd/socket/ServerHandler.kt | 39 +++++++++++++++++++++++++++++++++++----
1 files changed, 35 insertions(+), 4 deletions(-)
diff --git a/src/main/kotlin/com/flightfeather/obd/socket/ServerHandler.kt b/src/main/kotlin/com/flightfeather/obd/socket/ServerHandler.kt
index e1480ee..4c01a5b 100644
--- a/src/main/kotlin/com/flightfeather/obd/socket/ServerHandler.kt
+++ b/src/main/kotlin/com/flightfeather/obd/socket/ServerHandler.kt
@@ -3,6 +3,10 @@
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() {
@@ -10,19 +14,44 @@
override fun channelRegistered(ctx: ChannelHandlerContext?) {
super.channelRegistered(ctx)
+ println("------绔彛鏈塈P杩炴帴锛歔ip:${ctx?.channel()?.remoteAddress()}] ${SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(Date())}")
+// ctx?.fireChannelActive()
}
override fun channelActive(ctx: ChannelHandlerContext?) {
+ println("------绔彛鏈塈P婵�娲伙細[ip:${ctx?.channel()?.remoteAddress()}] ${SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(Date())}")
super.channelActive(ctx)
}
override fun channelRead(ctx: ChannelHandlerContext?, msg: Any?) {
super.channelRead(ctx, msg)
- val attribute = ctx?.channel()?.attr(attributeKey)?.apply {
- if (get() == null) {
-// set()
+
+ 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()
+ }
+ val s = if (a < 16) {
+ "0${a.toString(16)}"
+ } else {
+ a.toString(16)
+ }
+ print("$s ")
+ sb.append(s).append(" ")
}
+ sb.deleteCharAt(sb.length - 1)
}
+ val str = sb.toString()
+ if (str.isNotEmpty()) {
+ MessageManager().dealStringMsg(str, ctx)
+ }
+
}
override fun channelReadComplete(ctx: ChannelHandlerContext?) {
@@ -30,10 +59,12 @@
}
override fun channelInactive(ctx: ChannelHandlerContext?) {
+ println("------绔彛鏈塈P涓嶆椿鍔細[ip:${ctx?.channel()?.remoteAddress()}] ${SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(Date())}")
super.channelInactive(ctx)
}
override fun exceptionCaught(ctx: ChannelHandlerContext?, cause: Throwable?) {
- super.exceptionCaught(ctx, cause)
+ cause?.printStackTrace()
+ ctx?.close()
}
}
\ No newline at end of file
--
Gitblit v1.9.3