From f5aee3341b1d87116b06d33b742eaa287de8bc8f Mon Sep 17 00:00:00 2001 From: rays <1615175118@qq.com> Date: Tue, 29 Jun 2021 09:20:08 +0800 Subject: [PATCH] =?UTF-8?q?WebSocket=E4=BC=9A=E8=AF=9D=E7=BB=B4=E6=8A=A4To?= =?UTF-8?q?ken=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../kernel/socket/api/session/pojo/SocketSession.java | 8 +++++--- .../socket/business/websocket/server/WebSocketServer.java | 1 + 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/kernel-d-socket/socket-api/src/main/java/cn/stylefeng/roses/kernel/socket/api/session/pojo/SocketSession.java b/kernel-d-socket/socket-api/src/main/java/cn/stylefeng/roses/kernel/socket/api/session/pojo/SocketSession.java index 0d9910139..e84bb98d4 100644 --- a/kernel-d-socket/socket-api/src/main/java/cn/stylefeng/roses/kernel/socket/api/session/pojo/SocketSession.java +++ b/kernel-d-socket/socket-api/src/main/java/cn/stylefeng/roses/kernel/socket/api/session/pojo/SocketSession.java @@ -3,9 +3,6 @@ package cn.stylefeng.roses.kernel.socket.api.session.pojo; import cn.stylefeng.roses.kernel.socket.api.session.SocketSessionOperatorApi; import lombok.Data; -import java.util.HashSet; -import java.util.Set; - /** * Socket会话 * @@ -30,6 +27,11 @@ public class SocketSession { */ private String messageType; + /** + * token信息 + */ + private String token; + /** * 连接时间 */ diff --git a/kernel-d-socket/socket-business-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/business/websocket/server/WebSocketServer.java b/kernel-d-socket/socket-business-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/business/websocket/server/WebSocketServer.java index fa3d627ae..1f431c56d 100644 --- a/kernel-d-socket/socket-business-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/business/websocket/server/WebSocketServer.java +++ b/kernel-d-socket/socket-business-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/business/websocket/server/WebSocketServer.java @@ -72,6 +72,7 @@ public class WebSocketServer { socketSession.setSessionId(session.getId()); socketSession.setUserId(userId); socketSession.setSocketOperatorApi(GunsSocketOperator); + socketSession.setToken(token); socketSession.setConnectionTime(System.currentTimeMillis()); // 维护会话