Netty序列化深入理解与使用
作者:kaico2018 时间:2023-05-24 20:13:07
序列化与反序列化
序列化:把对象转换成字节的过程,称为对象序列化
反序列化:把字节恢复成对象的过程,称为反序列化
对象的持久化概念:把字节保存的硬盘上永久的存放
网络传输对象概念:客户端将对象序列化为字节(序列化),变成二进制的形式发送到服务器端端,服务器端接受到字节对象后,反序列化成对象
注意序列化的类必须要实现 Serializable 接口, transient 修饰变量使得该变量不被序列化。
网络传输过程中不能直接传输对象,TCP协议的底层是二进制。
序列化模式
1.对象持久化概念:将对象转换成字节,存放到硬盘或者是数据库中
2. 网络传输对象概念:客户端将对象转成字节的形式(序列化)、变成二进制的形式发送给服务器端,服务器端接受到字节之后,反序列化成对象(rpc 远程通讯)。
其他对象序列化方式
1、将对象转换成json类型,实现跨语言
客户端将对象转换程json类型,传递给服务器端序列化。
服务器端获取到json, 在将json转换成对象反序列化。
2、Xml类型
一般比较重量级,一般只有银行、保险公司使用这种方式。
3、ProtoBuf(谷歌第三方协议,谷歌自定义协议)
4、MessagePack
也属于json里面的
使用json协议实现对象的传输
就是将对象转换成json字符串进行传输。
MessagePack编码器
它像JSON, 但是更快更小。
MessagePack是一种高效的二进制序列化格式。它允许您在JSON等多种语之间交换数据,但它更快速更小巧。小整数被编码为单个字节,典型的短字符串除了字符串本身之外只需要一个额外的字节。
支持Python、Ruby、 Java、 C/C++ 等众多语言。宣称比Google Protocol Buffers还要快4倍。。
使用案例:
引入mave依赖:
<dependency>
<groupId>org.msgpack</groupId>
<artifactId>msgpack</artifactId>
<version>0.6.12</version>
</dependency>
基本api使用:
// 创建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);
在Netty框架中使用
编码器
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());
来源:https://blog.csdn.net/weixin_44044929/article/details/123948587
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
C#将Word转换成PDF方法汇总(基于Office和WPS)
MyBatis一二级缓存
C#延迟执行方法函数实例讲解
winform基于异步委托实现多线程摇奖器
![](https://img.aspxhome.com/file/2023/1/111261_0s.png)
Android控件设置宽高比的方法
Feign Client 超时时间配置不生效的解决
![](https://img.aspxhome.com/file/2023/8/81298_0s.jpg)
Java sha1散列算法原理及代码实例
Java并发编程之volatile与JMM多线程内存模型
![](https://img.aspxhome.com/file/2023/3/62203_0s.png)
C#读取txt文件数据的方法实例
![](https://img.aspxhome.com/file/2023/1/106501_0s.png)
Android实现随机圆形云标签效果
![](https://img.aspxhome.com/file/2023/1/137651_0s.png)
详解Android中PopupWindow在7.0后适配的解决
![](https://img.aspxhome.com/file/2023/2/90142_0s.png)
c#中DataTable转List的2种方法示例
基于@PathVariable注解的用法说明
![](https://img.aspxhome.com/file/2023/4/76514_0s.jpg)
基于SpringBoot中activeMq的JmsTemplate的实例
springboot整合mybatis-plus基于注解实现一对一(一对多)查询功能
C# XML序列化方法及常用特性总结分析
java构造方法的作用总结
Android开发之SQLite的使用方法
![](https://img.aspxhome.com/file/2023/4/138074_0s.png)
spring profile 多环境配置管理详解
android使用PullToRefresh实现下拉刷新和上拉加载
![](https://img.aspxhome.com/file/2023/5/85455_0s.png)