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
|
|
/**
|
*
|
* @date 2025/5/14
|
* @author feiyu02
|
*/
|
object UnderwayWebSocketSender {
|
|
private val sessionPool = mutableMapOf<String?, ChannelHandlerContext?>()
|
|
fun saveSession(ctx: ChannelHandlerContext?) {
|
if (!sessionPool.containsKey(ctx?.name())) {
|
sessionPool[ctx?.name()] = ctx
|
}
|
}
|
|
fun removeSession(ctx: ChannelHandlerContext?) {
|
if (sessionPool.containsKey(ctx?.name())) {
|
sessionPool.remove(ctx?.name())
|
}
|
}
|
|
fun send() {
|
|
}
|
|
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))
|
}
|
}
|
}
|
