转载

netty-3-channelhandler

ChannelHandler是Netty中负责处理Channel上的IO事件、其他事件的组件，例如处理连接建立、收到特定消息特定事件等。ChannelHandler通过处理事件类型的不同又可以分为ChannelInboundHandler和ChannelOutboundHandler。一般当我们实现的是一个服务器时，我们将服务器server想象为靠近自己的一端，Client为远离自己的一端。这样Inbound就是进来的事件，一般为Channel已注册、Channel读到消息、Channel特定用户事件触发。而Outbound事件则为从Server发向Client的事件，例如write、flush等。当实现的是Client端时也是类似的道理，站在自己的角度看进来和出去的数据事件即可。

常见的ChannelHandler分为编解码器Codec、业务事件处理等。

Codec分为Encoder和Decoder 编码和解码器，因为网络传输的都是二进制数据而应用程序需要使用特定的结构对象，所以需要进行互相的转换。转换成业务对象后由应用自定义的业务时间处理器来处理。

ChannelHandler代码分析

每个Channel在创建后都会有一个ChannelPipeline, ChannelPipeline上是绑定到当前Channel的ChannelHandle的列表，这个是可以在运行过程中随时增加和减少ChannelHandler的。

ChannelHandler定义了channelAdd, channelRemove表示当前ChannelHandler增加和移除时候的回调。

/**
    * Gets called after the {@link ChannelHandler} was added to the actual context and it's ready to handle events.
    */
   void handlerAdded(ChannelHandlerContext ctx) throws Exception;

   /**
    * Gets called after the {@link ChannelHandler} was removed from the actual context and it doesn't handle events
    * anymore.
    */
   void handlerRemoved(ChannelHandlerContext ctx) throws Exception;

@Sharable

添加ChannelHandler可以通过ChannelPipeline的addFirst、AddLast等方法来添加，这里涉及到一个共享并发相关的问题，当ChannelHandler保存了一个实例变量，这个实例变量是和单独Channel相关的时，如果这个ChannelHandler被多个ChannelPipeline共享了就可能出现并发问题，例如一个是否已经登录的状态，这种情况有几种解决方式

每个ChannelPipeline使用单独的ChannelHandler，而前面章节介绍的一个Channel只会有一个线程来处理它的IO相关事件所以是线程安全的。
ChannelHandler不保存实例变量或者保存的是线程安全的变量并且通过合理的同步控制并发。如果不保存实例变量，可以通过一个ChannelHandlerContext来保存，ChannelHandlerContext可以理解为ChannelPipeline和ChannelHandler结合的对象，ChannelHandlerContext可以通过AttributeMap来保存当前Channel相关的信息，用于前后传递。
在后面的文章中会继续介绍更多的Channel、ChannelPipelie、ChannelHandler等信息，并且会总结Netty的线程模型等。

原文 https://liuzhengyang.github.io/2018/07/12/netty-3-channelhandler/

正文到此结束