Unverified Commit 3604dad8 authored by 张亮's avatar 张亮 Committed by GitHub
Browse files

Merge pull request #617 from ma-xiao-guang-64/dev 

解决粘包问题
parents 943f994b b3ae2236

sharding-jdbc-server/src/main/java/io/shardingjdbc/server/codec/MySQLPacketCodec.java

+5 −0
Original line number Diff line number Diff line
@@ -33,6 +33,11 @@ public final class MySQLPacketCodec extends ByteToMessageCodec<AbstractMySQLSent 
            in.resetReaderIndex();

            return;

        }

        if (readableBytes > payloadLength) {

            ByteBuf frame = in.readRetainedSlice(payloadLength);

            out.add(frame);

            return;

        }

        out.add(in);

    }