From 27921d0aadbe9e3754ccd8498e893eb8d73c1269 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Thu, 27 May 2021 17:37:32 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java | 21 +++++++-------------- 1 files changed, 7 insertions(+), 14 deletions(-) diff --git a/src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java b/src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java index 8511435..9cbe9cf 100644 --- a/src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java +++ b/src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java @@ -42,13 +42,6 @@ responseBean.setType(requestBean.getType()); responseBean.setStatus(1); -// String bearerToken = requestBean.getData().toString(); -// String rsaToken = bearerToken.replace(AppContants.TOKEN_START_WITH, ""); -// RSA rsa = new RSA(securityProperties.getPrivateKey(), null); -// String[] tokens = StrUtil.split(rsa.decryptStr(rsaToken, KeyType.PrivateKey), "_"); -// -// Long memberId = Long.parseLong(tokens[0]); - String token = requestBean.getData().toString(); String redisKey = AppContants.APP_LOGIN_PREFIX + token; String loginStr = redisUtils.getString(redisKey); @@ -94,13 +87,13 @@ targetChannel.writeAndFlush(NettyTools.webSocketJson(toRes)); } else { // 在redis中保存用户未在线时,给该用户发送的消息条数 - String key = AppContants.MSG_NOTICE + chat.getTargetId(); - String value = redisUtils.getString(key); - if (StrUtil.isEmpty(value)) { - redisUtils.set(key , 1); - } else { - redisUtils.set(key, Integer.parseInt(value) + 1); - } +// String key = AppContants.MSG_NOTICE + chat.getTargetId(); +// String value = redisUtils.getString(key); +// if (StrUtil.isEmpty(value)) { +// redisUtils.set(key , 1); +// } else { +// redisUtils.set(key, Integer.parseInt(value) + 1); +// } } chatProducer.sendMsgHistory(chat); } -- Gitblit v1.9.1