package com.ruoyi.system.util.websocket;
|
|
import org.springframework.web.socket.WebSocketSession;
|
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
/**
|
* @author zhibing.pu
|
* @Date 2025/4/8 20:04
|
*/
|
public class SessionMap{
|
|
|
private static final Map<Integer, WebSocketSession> sessions = new ConcurrentHashMap<>();
|
|
public static void add(Integer key, WebSocketSession value){
|
sessions.put(key, value);
|
}
|
|
|
public static void del(Integer key){
|
sessions.remove(key);
|
}
|
|
|
public static Map<Integer, WebSocketSession> getAll(){
|
return sessions;
|
}
|
|
|
public static WebSocketSession get(Integer key){
|
return sessions.get(key);
|
}
|
}
|
