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)