阻止重复帧

This commit is contained in:
Guoqs
2024-10-28 14:30:49 +08:00
parent f72feba8cc
commit 6bb08fde40

View File

@@ -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)