Netty序列化深入理解与使用

<dependency>
    <groupId>org.msgpack</groupId>
    <artifactId>msgpack</artifactId>
    <version>0.6.12</version>
</dependency>

 // 创建MessagePack
MessagePack messagePack = new MessagePack();
MsgEntity meite = new MsgEntity(UUID.randomUUID().toString(), "kaico学习");
// 序列化
byte[] bs = messagePack.write(meite);
Value read1 = messagePack.read(bs);
System.out.println(read1);
// 反序列化
MsgEntity read = messagePack.read(bs, MsgEntity.class);
System.out.println(read);

public class MsgpackEncoder extends MessageToByteEncoder {
    /**
     * 对我们数据实现编码
     *
     * @param channelHandlerContext
     * @param msg
     * @param byteBuf
     * @throws Exception
     */
    @Override
    protected void encode(ChannelHandlerContext channelHandlerContext, Object msg, ByteBuf byteBuf) throws Exception {
        MessagePack msgpack = new MessagePack();
        byteBuf.writeBytes(msgpack.write(msg));
    }
}

public class MsgpackDecoder extends MessageToMessageDecoder<ByteBuf> {
    /**
     * 服务器解码数据
     *
     * @param channelHandlerContext
     * @param byteBuf
     * @param list
     * @throws Exception
     */
    @Override
    protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception {
        final int length = byteBuf.readableBytes();
        byte[] b = new byte[length];
        byteBuf.getBytes(byteBuf.readerIndex(), b, 0, length);
        MessagePack msgpack = new MessagePack();
        list.add(msgpack.read(b));
    }
}

socketChannel.pipeline().addLast(new MsgpackDecoder());
socketChannel.pipeline().addLast(new ServerHandler());

ch.pipeline().addLast(new MsgpackEncoder());
ch.pipeline().addLast(new ClientHandler());