diff --git a/net/src/main/java/com/zfoo/net/handler/codec/jprotobuf/JProtobufTcpCodecHandler.java b/net/src/main/java/com/zfoo/net/handler/codec/jprotobuf/JProtobufTcpCodecHandler.java index b43d3203..55a4bbcf 100644 --- a/net/src/main/java/com/zfoo/net/handler/codec/jprotobuf/JProtobufTcpCodecHandler.java +++ b/net/src/main/java/com/zfoo/net/handler/codec/jprotobuf/JProtobufTcpCodecHandler.java @@ -34,8 +34,6 @@ import org.slf4j.LoggerFactory; import java.io.IOException; import java.util.List; -import static com.zfoo.protocol.ProtocolManager.protocols; - /** * header(4byte) + protocolId(2byte) + packet * header = body(bytes.length) + protocolId.length(2byte) @@ -47,24 +45,6 @@ public class JProtobufTcpCodecHandler extends ByteToMessageCodec out) { @@ -112,6 +92,19 @@ public class JProtobufTcpCodecHandler extends ByteToMessageCodec) ProtobufProxy.create(packet.getClass()); byte[] bytes = protobufCodec.encode(packet); buffer.writeBytes(bytes); int length = buffer.readableBytes(); - int packetLength = length - PacketService.PACKET_HEAD_LENGTH; buffer.writerIndex(0); - buffer.writeInt(packetLength); - buffer.writerIndex(length); } }