package cn.flightfeather.supervision.socket.processor
|
|
import cn.flightfeather.supervision.socket.WsSessionManager
|
import org.springframework.stereotype.Component
|
import org.springframework.web.socket.TextMessage
|
|
/**
|
* webSocket消息发送管理
|
* @date 2024/7/19
|
* @author feiyu02
|
*/
|
@Component
|
class WebSocketSender {
|
|
/**
|
* 单独发送消息
|
*/
|
fun sendMsg(msg: String, sessionId: String) {
|
WsSessionManager[sessionId]?.sendMessage(TextMessage(msg))
|
}
|
|
/**
|
* 广播给所有人
|
*/
|
fun broadcast(msg: String) {
|
WsSessionManager.eachSession {
|
it.sendMessage(TextMessage(msg))
|
}
|
}
|
}
|
