gitee
/
roses
mirror of https://gitee.com/stylefeng/roses
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

修改list为线程安全的list

pull/22/head
rays 2021-06-22 16:57:03 +08:00
parent 4921a9ecc6
commit ea8e423e16
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kernel-d-socket/socket-business-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/business/websocket/session/SessionCenter.java
View File

@ -19,7 +19,7 @@ import java.util.concurrent.ConcurrentMap;
public class SessionCenter { public class SessionCenter {
/** /**
* 所有会话维护 * 所有用户会话维护
*/ */
private static ConcurrentMap<String, List<SocketSession<GunsSocketOperator>>> socketSessionMap = new ConcurrentHashMap<>(); private static ConcurrentMap<String, List<SocketSession<GunsSocketOperator>>> socketSessionMap = new ConcurrentHashMap<>();
@ -87,7 +87,7 @@ public class SessionCenter {
public static void addSocketSession(SocketSession<GunsSocketOperator> socketSession) { public static void addSocketSession(SocketSession<GunsSocketOperator> socketSession) {
List<SocketSession<GunsSocketOperator>> socketSessions = socketSessionMap.get(socketSession.getUserId()); List<SocketSession<GunsSocketOperator>> socketSessions = socketSessionMap.get(socketSession.getUserId());
if (ObjectUtil.isEmpty(socketSessions)) { if (ObjectUtil.isEmpty(socketSessions)) {
socketSessions = new ArrayList<>(); socketSessions = Collections.synchronizedList(new ArrayList<>());
socketSessionMap.put(socketSession.getUserId(), socketSessions); socketSessionMap.put(socketSession.getUserId(), socketSessions);
} }
socketSessions.add(socketSession); socketSessions.add(socketSession);