package com.project.util;
|
|
import com.project.common.core.domain.entity.SysUser;
|
import com.project.scoket.WebSocket;
|
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
public class CurPoolUtil
|
{
|
// public static CopyOnWriteArraySet<WebSocket> webSockets =new CopyOnWriteArraySet<>();
|
public static Map<Long, WebSocket> webSockets = new ConcurrentHashMap<>();
|
// list 里面第一个存sessionId，第二个存session
|
public static Map<Long, Object> sessionPool = new ConcurrentHashMap<>();
|
// 当前登录用户x
|
public static Map<String, SysUser> curUserPool = new ConcurrentHashMap<>();
|
|
}
|
