netty tcp 字节有序->对象有序-白红宇

io.netty.handler.codec.serialization.ObjectDecoder

将ByteBuf[]反序列化为java对象。

A decoder which deserializes the received ByteBufs into Java objects.

io.netty.handler.codec.serialization.ObjectEncoder

编码器，将java对象序列化为一个netty的ByteBuf对象。

An encoder which serializes a Java object into a ByteBuf.

要求传送的类实现java.io.serializable接口。用法见下。

Bootstrap b = new Bootstrap();   b.handler(new ChannelInitializer
    
     () {                @Override                public void initChannel(SocketChannel ch) throws Exception {                    ch.pipeline().addLast(new ObjectEncoder(),                   		 new ObjectDecoder(ClassResolvers.cacheDisabled(null)),						 new TcpClientHandler());                }   });

完整的项目示例见github。

https://github.com/chuchu9293/NettyTcpObjOrdering

其他Decoder

ByteToMessageDecoder是ChannelHandler的一个实现类，他可以在处理数据拆分的问题上变得很简单。

每当有新数据接收的时候，ByteToMessageDecoder都会调用decode()方法来处理内部的那个累积缓冲。

Decode()方法可以决定当累积缓冲里没有足够数据时可以往out对象里放任意数据。当有更多的数据被接收了ByteToMessageDecoder会再一次调用decode()方法。

如果在decode()方法里增加了一个对象到out对象里，这意味着解码器解码消息成功。ByteToMessageDecoder将会丢弃在累积缓冲里已经被读过的数据。请记得你不需要对多条消息调用decode()，ByteToMessageDecoder会持续调用decode()直到不放任何数据到out里。