Easy Netty 系列（三）：ChannelHandler详解

2021-12-01

Handler 是处理器，那它处理什么呢？网络中有什么它就做那些处理。常见的有连接的建立、响应读写事件、网络中数据的处理如编码、解码等，这些都是处理器做的。Netty 中的处理器是 ChannelHandler 接口，所有的处理器都是这个接口的实现。

首先说下 Netty 处理器的定位：它是 Netty 架构中网络处理与业务逻辑的解耦，处理器代表了与用户相关的业务逻辑，如数据读取、后端计算和发送，而网络连接管理、线程控制、网络事件监听处理都由 Netty 接管，使我们可以更加专注业务逻辑。站在开发的角度，使用 Netty 开发接触最多的就是 ChannelHandler。

处理器有许多种类，通过以下分类你可以先在脑海中建立一个简单的概念。

处理器分类

入站处理器：处理 read 事件的数据，通常是解码操作
出站处理器：处理 write 事件的数据，通常是编码操作
编解码器：一种专用的数据转换器，例如字节转换为字符串，称之为“解码器”，反之把字符串转换为“字节”称之为“编码器”
转换器：复合处理器，把一种数据转换为另一种数据，例如 HTTP1 转换为 HTTP2

ChannelHandler 层次结构

Handler结构.png

常用类使用

最常使用的是 ChannelInboundHandlerAdapter、ChannelDuplexHandler、ChannelOutboundHandlerAdapter 的实现类，这些类定义了不同类型的方法，例如 InboundHandler 与 OutboundHandler 定义的方法就有很大的差别。

以入站为代表的类有 ByteToMessageDecoder、SimpleChannelInboundHandler。

例如ByteToMessageDecoder使用时重写decode方法即可，编码器重写 encode。

1      public class SquareDecoder extends {@link ByteToMessageDecoder} {
2          @Override
3          public void decode(ChannelHandlerContext ctx,  ByteBuf in, List<Object> out)
4                  throws  Exception {
5              out.add(in.readBytes(in.readableBytes()));
6          }
7      }

SimpleChannelInboundHandler<T> 使用时重写 channelRead0 方法即可，Adapter 里已经帮我们做好了类型转换。

1       public class StringHandler extends SimpleChannelInboundHandler<String> {
2            @Override
3           protected void channelRead0(ChannelHandlerContext ctx, String message)
4                   throws Exception {
5               System.out.println(message);
6           }
7       }

ChannelDuplexHandler 的子类实现多是进行数据转换，例如：ByteToMessageCodec 将入站的 byte 数据转化为对象，出站时将对象转换为 byte，类似的还有 MessageToMessageCodec，实现两个对象间的转化。

ChannelHandler 的几个注意点

1、执行顺序。按照被添加的顺序执行。

2、共享 Handler 与非共享 Handler。共享的 Handler 会绑定到多个 Channel，当 Channel 并行执行时可能存在线程安全问题；非共享 Handler 绑定时就会创建一个，Channel 独享，不存在线程安全问题。

3、Handler 的 read 会执行多次。当 Channel 中的数据未处理完，上一个 Handler 会多次触发下个 Handler 的 read 事件。

(end)

<< Previous Post

Next Post >>

#Netty