更新代码

Pu Zhibing

3 天以前 98d63d51c8488dadd819d540350f578e025e02c1

 ZuulZYTravel/src/main/java/com/sinata/zuul/util/applets/NettyWebSocketController.java

@@ -78,21 +78,21 @@
                    NettyChannelMap.update_(token.substring(0, 23), ctx);//存储单点登录的通道
                    String token_ = redisUtil.getValue("USER_" + userId1);//获取缓存中最新的数据
                    if(StringUtil.isNotEmpty(token_) && !token.equals(token_)){//不在同一设备上登录，向其他设备发送数据
                        JSONObject msg_ = new JSONObject();
                        msg_.put("code", 200);
                        msg_.put("msg", "SUCCESS");
                        msg_.put("method", "OFFLINE");
                        msg_.put("data", new Object());
                        this.sendMsgToClient(ctx, msg_.toJSONString());
                        TimerTask timerTask = new TimerTask() {
                            @Override
                            public void run() {
                                NettyChannelMap.remove_(ctx);
                            }
                        };
                        Timer timer = new Timer();
                        timer.schedule(timerTask, 3000);
                        timer.cancel();
//                        JSONObject msg_ = new JSONObject();
//                        msg_.put("code", 200);
//                        msg_.put("msg", "SUCCESS");
//                        msg_.put("method", "OFFLINE");
//                        msg_.put("data", new Object());
//                        this.sendMsgToClient(ctx, msg_.toJSONString());
//                        TimerTask timerTask = new TimerTask() {
//                            @Override
//                            public void run() {
//                                NettyChannelMap.remove_(ctx);
//                            }
//                        };
//                        Timer timer = new Timer();
//                        timer.schedule(timerTask, 3000);
//                        timer.cancel();
                    }
                    if(StringUtil.isEmpty(token_)){//确保登录的时候存储token失败的情况
                        redisUtil.setStrValue("USER_" + userId1, token);