From 2eb49990386c5e6efe40ce2d3499800b98a4b384 Mon Sep 17 00:00:00 2001 From: Guoqs <123@jsowell.com> Date: Mon, 28 Oct 2024 14:45:15 +0800 Subject: [PATCH] =?UTF-8?q?=E9=98=BB=E6=AD=A2=E9=87=8D=E5=A4=8D=E5=B8=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../netty/handler/yunkuaichong/AbstractYkcHandler.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/AbstractYkcHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/AbstractYkcHandler.java index 1b8d13342..6045d4df2 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/AbstractYkcHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/AbstractYkcHandler.java @@ -22,6 +22,8 @@ public abstract class AbstractYkcHandler implements InitializingBean { @Autowired private RedisCache redisCache; + private static final String REQUEST_PREFIX = "Request_"; + /** * 执行逻辑 * 有应答 @@ -96,7 +98,7 @@ public abstract class AbstractYkcHandler implements InitializingBean { String frameTypeStr = YKCUtils.frameType2Str(ykcDataProtocol.getFrameType()); // 获取channelId String channelId = ctx.channel().id().asShortText(); - String redisKey = "Request_" + channelId + "_" + frameTypeStr; + String redisKey = REQUEST_PREFIX + channelId + "_" + frameTypeStr; Boolean result = redisCache.setnx(redisKey, ykcDataProtocol.getHEXString(), 30); // result返回false说明没有设置成功,就是说已经有相同请求了,所以返回true重复 return !result;