From 594de76ed51fd49fb79b912212bb0052a63e7671 Mon Sep 17 00:00:00 2001
From: feiyu02 <risaku@163.com>
Date: 星期四, 09 四月 2026 16:10:45 +0800
Subject: [PATCH] 2026.4.9
---
src/main/kotlin/com/flightfeather/uav/socket/handler/UnderwayWebSocketServerHandler.kt | 31 +++++++++++++++++--------------
1 files changed, 17 insertions(+), 14 deletions(-)
diff --git a/src/main/kotlin/com/flightfeather/uav/socket/handler/UnderwayWebSocketServerHandler.kt b/src/main/kotlin/com/flightfeather/uav/socket/handler/UnderwayWebSocketServerHandler.kt
index 11f5696..6874d94 100644
--- a/src/main/kotlin/com/flightfeather/uav/socket/handler/UnderwayWebSocketServerHandler.kt
+++ b/src/main/kotlin/com/flightfeather/uav/socket/handler/UnderwayWebSocketServerHandler.kt
@@ -28,24 +28,27 @@
}
override fun channelRead(ctx: ChannelHandlerContext?, msg: Any?) {
- super.channelRead(ctx, msg)
+// super.channelRead(ctx, msg)
when (msg) {
is TextWebSocketFrame -> {
val msgTxt = msg.text()
-
- println(msgTxt)
-// ctx?.channel()?.writeAndFlush(msg)
-
- // Test
try {
- if (msgTxt == "start") {
- sourceTraceController.initTask()
- } else {
- val data = GsonUtils.parserJsonToArrayBeans(msgTxt, DataVo::class.java)
- data.forEach {
- sourceTraceController.addOneData(
- it.toBaseRealTimeData(BaseRealTimeData::class.java)
- )
+ when (msgTxt) {
+ "start" -> {
+ sourceTraceController.initTask()
+ println(msgTxt)
+ }
+ "ping" -> {
+ ctx?.channel()?.writeAndFlush(TextWebSocketFrame("ping checked"))
+ }
+ else -> {
+ println(msgTxt)
+ val data = GsonUtils.parserJsonToArrayBeans(msgTxt, DataVo::class.java)
+ data.forEach {
+ sourceTraceController.addOneData(
+ it.toBaseRealTimeData(BaseRealTimeData::class.java)
+ )
+ }
}
}
} catch (e: Exception) {
--
Gitblit v1.9.3