diff --git a/protocol/src/main/java/com/zfoo/protocol/buffer/CustomByteBuf.java b/protocol/src/main/java/com/zfoo/protocol/buffer/CustomByteBuf.java index f67f0399..92506074 100644 --- a/protocol/src/main/java/com/zfoo/protocol/buffer/CustomByteBuf.java +++ b/protocol/src/main/java/com/zfoo/protocol/buffer/CustomByteBuf.java @@ -74,7 +74,11 @@ public abstract class CustomByteBuf { var length = ByteBufUtils.readInt(byteBuf); var byteBuffer = ByteBuffer.allocate(length * 4); byteBuf.readBytes(byteBuffer); + byteBuffer.rewind(); var intBuffer = byteBuffer.asIntBuffer(); - return intBuffer.array(); + int[] ints = new int[length]; + intBuffer.get(ints); + return ints; } + }