From 98d63d51c8488dadd819d540350f578e025e02c1 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期二, 23 九月 2025 14:49:28 +0800
Subject: [PATCH] 更新代码

---
 MessagePushTravel/src/main/java/com/sinata/push/util/applets/NettyWebSocketController.java |   32 ++++++++++++++++----------------
 1 files changed, 16 insertions(+), 16 deletions(-)

diff --git a/MessagePushTravel/src/main/java/com/sinata/push/util/applets/NettyWebSocketController.java b/MessagePushTravel/src/main/java/com/sinata/push/util/applets/NettyWebSocketController.java
index 1b7ee60..dd1c3e9 100644
--- a/MessagePushTravel/src/main/java/com/sinata/push/util/applets/NettyWebSocketController.java
+++ b/MessagePushTravel/src/main/java/com/sinata/push/util/applets/NettyWebSocketController.java
@@ -77,22 +77,22 @@
                 if(StringUtil.isNotEmpty(token)){
                     String token_ = redisUtil.getValue("USER_" + userId1);//获取缓存中最新的数据
                     if(StringUtil.isNotEmpty(token_) && !token.equals(token_)){//不在同一设备上登录,向其他设备发送数据
-                        ChannelHandlerContext context = NettyChannelMap.getData("Applets" + userId1);
-                        JSONObject msg_ = new JSONObject();
-                        msg_.put("code", 200);
-                        msg_.put("msg", "SUCCESS");
-                        msg_.put("method", "OFFLINE");
-                        msg_.put("data", new Object());
-                        this.sendMsgToClient(context, msg_.toJSONString());
-                        TimerTask timerTask = new TimerTask() {
-                            @Override
-                            public void run() {
-                                NettyChannelMap.remove(context);
-                            }
-                        };
-                        Timer timer = new Timer();
-                        timer.schedule(timerTask, 3000);
-                        timer.cancel();
+//                        ChannelHandlerContext context = NettyChannelMap.getData("Applets" + userId1);
+//                        JSONObject msg_ = new JSONObject();
+//                        msg_.put("code", 200);
+//                        msg_.put("msg", "SUCCESS");
+//                        msg_.put("method", "OFFLINE");
+//                        msg_.put("data", new Object());
+//                        this.sendMsgToClient(context, msg_.toJSONString());
+//                        TimerTask timerTask = new TimerTask() {
+//                            @Override
+//                            public void run() {
+//                                NettyChannelMap.remove(context);
+//                            }
+//                        };
+//                        Timer timer = new Timer();
+//                        timer.schedule(timerTask, 3000);
+//                        timer.cancel();
                     }
                     if(StringUtil.isEmpty(token_)){//确保登录的时候存储token失败的情况
                         redisUtil.setStrValue("USER_" + userId1, token);

--
Gitblit v1.7.1