设备上报 gengdidi

src/main/java/com/zehong/gassdevicereport/netty/ServerHandler.java

@@ -75,14 +75,15 @@ public class ServerHandler extends ChannelInboundHandlerAdapter {
         ByteBuf readMessage= (ByteBuf) msg;
         String msgStr = readMessage.toString(CharsetUtil.UTF_8);
         logger.info("receiveMsgstr======="+msgStr);
-        if(msgStr.length() != 124){
+        /*if(msgStr.length() != 124){
             return;
-        }
+        }*/
         byte[] bytes = HexUtils.hexToByteArray( msgStr.substring(0,msgStr.length()-4));
         String checkVule = CrcUtil.getCrcToHex(bytes,true);
         String checkCode = msgStr.substring(msgStr.length()-4,msgStr.length());
         if(!checkVule.equals(checkCode)){
-            return;
+            logger.error("接收数据校验失败");
+            throw new Exception("接收数据校验失败");
         }
 
         SocketChannel channel=(SocketChannel)ctx.channel();