Netty 数据在管道中的流通

netty框架提供了多种编解码工具类对接收/发送的数据类型进行转化后再放到管道中流通。当然，也可以自己继承抽象类定制自己的编解码工具。今天，以管道中的数据格式转化角度来分析一下管道的工作流程。

一、Read数据

   // 分包，把数据读到buf中
   arg0.pipeline().addLast(new LineBasedFrameDecoder(1024));
   // 把buf中的数据转成string，在管道中流通
   arg0.pipeline().addLast(new StringDecoder());
   // 接收string类型的msg（需要强制转化）
   arg0.pipeline().addLast(new TimeServerHandler());

LineBasedFrameDecoder(ByteToMessageDecoder--读取管道中的Tcp byteBuf缓冲区的分包结果，向管道中放入拆包后的buf对象  
->   StringDecoder(MessageToMessageDecoder)--读取管道中的buf对象，(可以拆分成多个message(也可以不拆分))然后向管道中放入List<Object>对象(这里是List<string>)  
-> TimeServerHandler(ChannelHandlerAdapter)--读取管道中的Object对象，进行业务操作（而不是List<Object>,list中的每个元素都是一个独立的消息,被拆成多个Object）

二、Write

   ch.pipeline()
				    .addLast(
				    // ByteToMessageDecoder  从tcp buf中分包，然后把包中的字节反序列化成对象，放到管道中
					    new ObjectDecoder(
						    1024 * 1024,
						    ClassResolvers
							    .weakCachingConcurrentResolver(this
								    .getClass()
								    .getClassLoader())));
				// MessageToByteEncoder，拿到管道中的object对象，将object对象序列化后写到tcp buf缓冲区
			    ch.pipeline().addLast(new ObjectEncoder());
				// ChannelHandlerAdapter，拿到管道中的object对象，进行业务操作
			    ch.pipeline().addLast(new SubReqServerHandler());

SubReqServerHandler （ChannelHandlerAdapter）(使用ctx.writeAndFlush方法向管道中写入object、string对象)

-> ObjectEncoder（MessageToByteEncoder）（读取管道中的可序列化的对象，转成字节流，写入到tcp buf中）

标签：Netty,pipeline,addLast,对象,管道,new,流通,buf
来源： https://blog.csdn.net/qq_29012499/article/details/120306349