2025.12.29 1. websocket添加心跳回复机制

feiyu02

2025-12-30 6ddad5e82280f74961d907c8930c6b0fefbebdf0

 src/main/kotlin/com/flightfeather/uav/socket/handler/UnderwayWebSocketServerHandler.kt

@@ -28,19 +28,21 @@
    }

    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") {
                    when (msgTxt) {
                        "start" -> {
                        sourceTraceController.initTask()
                    } else {
                            println(msgTxt)
                        }
                        "ping" -> {
                            ctx?.channel()?.writeAndFlush(TextWebSocketFrame("ping checked"))
                        }
                        else -> {
                            println(msgTxt)
                        val data = GsonUtils.parserJsonToArrayBeans(msgTxt, DataVo::class.java)
                        data.forEach {
                            sourceTraceController.addOneData(
@@ -48,6 +50,7 @@
                            )
                        }
                    }
                    }
                } catch (e: Exception) {
//                    ctx?.channel()?.writeAndFlush(TextWebSocketFrame("当前为测试状态，传输的数据不是走航数据格式"))
                    println("当前为测试状态，传输的数据不是走航数据格式")