feat: websocket 连接信息优化记录 token 方便找到用户信息

basic-websocket/src/main/java/com/yiring/websocket/domain/StompPrincipal.java

@@ -32,6 +32,7 @@ public class StompPrincipal implements Principal, Serializable {
 
     Type type;
     String user;
+    String token;
     String session;
     JSONObject options;
 

basic-websocket/src/main/java/com/yiring/websocket/interceptor/ClientInboundChannelInterceptor.java

@@ -55,6 +55,7 @@ public class ClientInboundChannelInterceptor implements ChannelInterceptor {
                 if (tokens instanceof Collection<?>) {
                     String token = Convert.toList(String.class, tokens).get(0);
                     User user = auths.getUserByToken(token);
+                    principal.setToken(token);
                     principal.setUser(user.getRealName());
                     principal.setType(StompPrincipal.Type.LOGIN_USER);
                 } else {
@@ -66,10 +67,11 @@ public class ClientInboundChannelInterceptor implements ChannelInterceptor {
                 synchronized (lock) {
                     redis.hset(RedisKey.STOMP_ONLINE_USERS, principal.getSession(), principal);
                     log.info(
-                        "STOMP Online Users: {} (incr: +1, session: {}, user: `{}`)",
+                        "STOMP Online Users: {} (incr: +1, user: {}, session: {}, token: {})",
                         redis.hsize(RedisKey.STOMP_ONLINE_USERS),
+                        principal.getUser(),
                         principal.getSession(),
-                        principal.getUser()
+                        principal.getToken()
                     );
                 }
             }
@@ -79,10 +81,11 @@ public class ClientInboundChannelInterceptor implements ChannelInterceptor {
                 synchronized (lock) {
                     redis.hdel(RedisKey.STOMP_ONLINE_USERS, principal.getSession());
                     log.info(
-                        "STOMP Online Users: {} (incr: -1, session: {}, user: `{}`)",
+                        "STOMP Online Users: {} (incr: -1, user: {}, session: {}, token: {})",
                         redis.hsize(RedisKey.STOMP_ONLINE_USERS),
+                        principal.getUser(),
                         principal.getSession(),
-                        principal.getUser()
+                        principal.getToken()
                     );
                 }
             }