From 6bb08fde40a576507f4b718eb18baab79b78ddfc Mon Sep 17 00:00:00 2001 From: Guoqs <123@jsowell.com> Date: Mon, 28 Oct 2024 14:30:49 +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/LoginRequestHandler.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/LoginRequestHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/LoginRequestHandler.java index 03a9ae583..5430c75ef 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/LoginRequestHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/LoginRequestHandler.java @@ -117,6 +117,11 @@ public class LoginRequestHandler extends AbstractYkcHandler { @Override public byte[] supplyProcess(YKCDataProtocol ykcDataProtocol, ChannelHandlerContext ctx) { + if (verifyTheDuplicateRequest(ykcDataProtocol, ctx)) { + // 阻止重复帧 + return null; + } + // 获取消息体 byte[] msgBody = ykcDataProtocol.getMsgBody(); @@ -174,10 +179,6 @@ public class LoginRequestHandler extends AbstractYkcHandler { String business = BytesUtil.bcd2Str(businessTypeByteArr); // *********************** 字段解析完成,下面进行逻辑处理 *********************** // - if (verifyTheDuplicateRequest(ykcDataProtocol, ctx)) { - return null; - } - LoginRequestData loginRequestData = LoginRequestData.builder() .pileSn(pileSn) .pileType(pileType)