package com.pz.chat.util; import com.pz.chat.controller.ChatController; import com.pz.common.core.domain.entity.SysUser; import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; /** * 统一管理session、websocket、curUser */ public class CurPool { // public static CopyOnWriteArraySet<WebSocket> webSockets =new CopyOnWriteArraySet<>(); public static Map<Integer, ChatController> webSockets = new ConcurrentHashMap<>(); // list 里面第一个存sessionId,第二个存session public static Map<Integer, List<Object>> sessionPool = new ConcurrentHashMap<>(); // 当前登录用户x public static Map<String, SysUser> curUserPool = new ConcurrentHashMap<>(); }