From aa241a47c90ed776062adf0b8daccf288a21836f Mon Sep 17 00:00:00 2001
From: liujie <liujie>
Date: 星期四, 10 八月 2023 09:55:54 +0800
Subject: [PATCH] 合并代码
---
zuul/src/main/java/com/sinata/zuul/util/applets/NettyWebSocketController.java | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/zuul/src/main/java/com/sinata/zuul/util/applets/NettyWebSocketController.java b/zuul/src/main/java/com/sinata/zuul/util/applets/NettyWebSocketController.java
index b7867cd..f214c7a 100644
--- a/zuul/src/main/java/com/sinata/zuul/util/applets/NettyWebSocketController.java
+++ b/zuul/src/main/java/com/sinata/zuul/util/applets/NettyWebSocketController.java
@@ -45,7 +45,7 @@
* @param msg
* @author TaoNingBo
*/
- public void JudgeOperation(ChannelHandlerContext ctx, String msg) {
+ public synchronized void JudgeOperation(ChannelHandlerContext ctx, String msg) {
try {
// 验证即时通讯命令是否正确有效
if (SinataUtil.isEmpty(msg)) {
@@ -85,7 +85,7 @@
if (StringUtil.isNotEmpty(token)) {
String token_ = redisUtil.getValue("USER_Applets_" + userId1);//获取缓存中最新的数据
if (StringUtil.isNotEmpty(token_) && !token.equals(token_)) {//不在同一设备上登录，向其他设备发送数据
- ChannelHandlerContext data_ = NettyChannelMap.getData_(token_.substring(0, 23));
+ ChannelHandlerContext data_ = NettyChannelMap.getData_(token_.substring(token_.length() - 16));
JSONObject msg_ = new JSONObject();
msg_.put("code", 200);
msg_.put("msg", "SUCCESS");
@@ -99,7 +99,7 @@
}
}, 5000);
}
- NettyChannelMap.update_(token.substring(0, 23), ctx);//存储单点登录的通道
+ NettyChannelMap.update_(token.substring(token.length() - 16), ctx);//存储单点登录的通道
NettyChannelMap.update("Applets" + userId1, ctx);
redisUtil.setStrValue("USER_Applets_" + userId1, token);
}
--
Gitblit v1.7.1