diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/impl/YKCBusinessServiceImpl.java b/jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/impl/YKCBusinessServiceImpl.java index 5b9d25d04..641edecae 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/impl/YKCBusinessServiceImpl.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/impl/YKCBusinessServiceImpl.java @@ -37,10 +37,10 @@ public class YKCBusinessServiceImpl implements YKCBusinessService { @Override public byte[] process(byte[] msg, ChannelHandlerContext ctx) { - // if (!YKCUtils.checkMsg(msg)) { - // // 校验不通过,丢弃消息 - // return null; - // } + if (!YKCUtils.checkMsg(msg)) { + // 校验不通过,丢弃消息 + return null; + } YKCDataProtocol ykcDataProtocol = new YKCDataProtocol(msg); // 获取帧类型 String frameType = YKCUtils.frameType2Str(ykcDataProtocol.getFrameType());