修改位置 重置 参数

src/main/java/com/tidecloud/dataacceptance/service/DelimiterJingWeiFrameDecoder.java

@@ -62,7 +62,7 @@ public class DelimiterJingWeiFrameDecoder extends ByteToMessageDecoder {
                         return;
                     } else {
                         cutLength = commaLength;
-                        in.markReaderIndex();
+                        in.readerIndex(cutLength + 1);
                     }
                 }
                 in.resetReaderIndex();
@@ -84,7 +84,6 @@ public class DelimiterJingWeiFrameDecoder extends ByteToMessageDecoder {
                     int readLength = cutLength + 1 + length + 1;
                     Object decoded = decode(readLength, ctx, in);
                     out.add(decoded);
-
                 }
 
             }