2025.7.16 1. 修改动态溯源异常判断逻辑

feiyu02

2025-07-16 8fc27dba6719041402e3e3c099e2f3e01d9d52c7

 src/main/kotlin/com/flightfeather/uav/socket/sender/UnderwayWebSocketSender.kt

@@ -1,5 +1,6 @@
package com.flightfeather.uav.socket.sender

import com.flightfeather.uav.socket.decoder.UnderwayWebSocketParser
import io.netty.channel.ChannelHandlerContext
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame

@@ -28,6 +29,11 @@

    }

    fun broadcast(type:Int, content:Any) {
        val msg = UnderwayWebSocketParser.encodeMessage(WebSocketMessage(type,content))
        broadcast(msg)
    }

    fun broadcast(msg: String) {
        sessionPool.forEach { (t, u) ->
            u?.channel()?.writeAndFlush(TextWebSocketFrame(msg))