14-高并发-netty原理和基础-处理器详解

短命女 2023-05-29 11:54 67阅读 0赞

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZG9uZ2xpYW5nemhpY2Fp_size_16_color_FFFFFF_t_70][]

*  反应器模式中，反应器查询到IO事件后，分发到Handler业务处理器，由Handler完成IO操作和业务处理。
 *  整个IO操作包含五个环节。只有首尾两位环节由netty底层负责完成。

这里详细描述一下出站和入站的操作：

*  出站处理：触发方向为自顶向下。从channelOutboundHandler-->netty内部-->系统内核缓冲区。会处理数据(读取)解码+业务处理。关键是netty通道操作底层java IO通道。
 *  入站处理：触发方向为自底向上。从系统内核缓冲区--->netty内部-->channelInboundHandler。会处理数据编码+数据写入通道。关键是底层java IO通道操作netty通道。

## channelInboundHandler ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZG9uZ2xpYW5nemhpY2Fp_size_16_color_FFFFFF_t_70 1][]

**1．channelRegistered**  
当通道注册完成后，Netty会调用fireChannelRegistered，触发通道注册事件。通道会启动该入站操作的流水线处理，在通道注册过的入站处理器Handler的channelRegistered方法，会被调用到。  
**2．channelActive**  
当通道激活完成后，Netty会调用fireChannelActive，触发通道激活事件。通道会启动该入站操作的流水线处理，在通道注册过的入站处理器Handler的channelActive方法，会被调用到。  
**3．channelRead**  
当通道缓冲区可读，Netty会调用fireChannelRead，触发通道可读事件。通道会启动该入站操作的流水线处理，在通道注册过的入站处理器Handler的channelRead方法，会被调用到。  
**4．channelReadComplete**  
当通道缓冲区读完，Netty会调用fireChannelReadComplete，触发通道读完事件。通道会启动该入站操作的流水线处理，在通道注册过的入站处理器Handler的channelReadComplete方法，会被调用到。  
**5．channelInactive**  
当连接被断开或者不可用，Netty会调用fireChannelInactive，触发连接不可用事件。通道会启动对应的流水线处理，在通道注册过的入站处理器Handler的channelInactive方法，会被调用到。  
**6．exceptionCaught**  
当通道处理过程发生异常时，Netty会调用fireExceptionCaught，触发异常捕获事件。通道会启动异常捕获的流水线处理，在通道注册过的处理器Handler的exceptionCaught方法，会被调用到。注意，这个方法是在通道处理器中ChannelHandler定义的方法，入站处理器、出站处理器接口都继承到了该方法。

## inboundHandler生命周期【生命周期方法】【入站回调方法】 ##

*  【生命周期方法】handlerAdded()

当业务处理器被加入到流水线后，此方法被回调。就是完成ch.pipeline().addLast(handler)后。

*  【生命周期方法】channelRegistered()

当通道成功绑定一个NioEventLoop线程后，会通道流水线回调所有业务处理器的channelRegistered()方法。

*  【生命周期方法】channelActive()

当通道成功激活后，会通过流水线回调所有业务处理器的channelActive()方法。

*  【入站方法回调】channelRead()

有数据入站，通道可读。流水线会启动入站处理流程。入站处理器的channelRead()方法会被一次回调到。

*  【入站方法回调】channelReadCompleted()

流水线完成入站处理后，会从前向后，依次回调每个入站处理器的channelReadCompleted()方法，表示数据读取完毕。

*  【生命周期方法】channelInactive()

当通道底层连接已经不是ESTABLISH或者关闭时，会通过流水线回调所有业务处理器的channelInactive()方法。

*  【生命周期方法】channelUnregistered()

当通道和NioEventLoop线程解除绑定，回调所有处理器的channelUnregistered()方法。

*  【生命周期方法】handlerRemoved()

当通道移除掉所有业务处理器后，回调所有处理器的handlerRemoved()方法。

## channelOutboundHandler ##

再强调一下，出站处理的方向：是通过上层Netty通道，去操作底层Java IO通道。关键是操作底层java IO通道。主要出站（Outbound）的操作如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZG9uZ2xpYW5nemhpY2Fp_size_16_color_FFFFFF_t_70 2][]

**1．bind**  
监听地址（IP+端口）绑定：完成底层Java IO通道的IP地址绑定。如果使用TCP传输协议，这个方法用于服务器端。  
**2．connect**  
连接服务端：完成底层Java IO通道的服务器端的连接操作。如果使用TCP传输协议，这个方法用于客户端。  
**3．write**  
写数据到底层：完成Netty通道向底层Java IO通道的数据写入操作。此方法仅仅是触发一下操作而已，并不是完成实际的数据写入操作。  
**4．flush**  
腾空缓冲区中的数据，把这些数据写到对端：将底层缓存区的数据腾空，立即写出到对端。  
**5．read**  
从底层读数据：完成Netty通道从Java IO通道的数据读取。  
**6．disConnect**  
断开服务器连接：断开底层Java IO通道的服务器端连接。如果使用TCP传输协议，此方法主要用于客户端。  
**7．close**  
主动关闭通道：关闭底层的通道，例如服务器端的新连接监听通道。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZG9uZ2xpYW5nemhpY2Fp_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191106091739678.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZG9uZ2xpYW5nemhpY2Fp,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZG9uZ2xpYW5nemhpY2Fp_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20191106120242898.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZG9uZ2xpYW5nemhpY2Fp,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZG9uZ2xpYW5nemhpY2Fp_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20191106120710424.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZG9uZ2xpYW5nemhpY2Fp,size_16,color_FFFFFF,t_70