MessagePack反序列化使用示例

上一篇 <<<序列化与反序列化知识点汇总
下一篇 >>>Marshalling在Netty中的使用

1.MessagePack简单示例

1.1 引入jar包

1.2 传输对象必须要引入注解@Message，且要有默认构造函数

@Message
public class MsgEntity {

    private String id;
    private String name;

    public MsgEntity() {

    }
……
}

1.3 demo演示

// 创建MessagePack
        MessagePack messagePack = new MessagePack();
        MsgEntity meite = new MsgEntity(UUID.randomUUID().toString(), "我是jarye");
        // 序列化
        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);

1.4 结果打印

2.MessagePack在netty中的使用

2.1 netty中编码器和解码器定义

public class MsgpackDecoder extends MessageToMessageDecoder<ByteBuf> {
    @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));
    }
}
public class MsgpackEncoder extends MessageToByteEncoder {

    @Override
    protected void encode(ChannelHandlerContext channelHandlerContext, Object msg, ByteBuf byteBuf) throws Exception {
        MessagePack msgpack = new MessagePack();
        byteBuf.writeBytes(msgpack.write(msg));
    }
}

2.2 注册到netty中

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

2.3 数据传输和接收可以直接使用对象形式了

public class ClientHandler extends SimpleChannelInboundHandler<Object> {

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        MsgEntity msgEntity = new MsgEntity(UUID.randomUUID().toString(), "我是jarye");
        ctx.writeAndFlush(msgEntity);
    }

    @Override
    protected void channelRead0(ChannelHandlerContext channelHandlerContext, Object o) throws Exception {
        System.out.println("resp:"+o);
    }
}
public class ServerHandler extends SimpleChannelInboundHandler<Object> {
    @Override
    protected void channelRead0(ChannelHandlerContext channelHandlerContext, Object o) throws Exception {
        System.out.println("o:" + o);
    }
}

2.4 结果打印

推荐阅读：
<<<OSI七层模型与层上协议
<<<TCP的三次握手建立链接和四次挥手释放链接
<<<TCP、UDP及Socket代码示例
<<<Https的1.0、2.0协议及长短链接区别
<<<Linux系统的五种IO模型
<<<BIO和NIO区别
<<<BIO模型的缺陷
<<<NIO模式的IO多路复用底层原理
<<<select、poll、epoll的区别
<<<Redis为什么单线程能够支持高并发
<<<Netty初识
<<<Netty的粘包和拆包问题分析
<<<粘包和拆包问题解决方案汇总
<<<序列化与反序列化知识点汇总
<<<Marshalling在Netty中的使用