Netty源码分析（七）：初识ChannelPipeline
ChannelPipeline 单看名称就可以知道 Channel 的管道。本篇将结合它的默认实现类 DefaultChannelPipeline 来对它做一个简单的介绍。
示例图
ChannelPipeline 的事例图。IO请求经由
ChannelOutboundHandler 中
ChannelOutboundHandler 处理之后写出到服务端，服务接收到读入后，由
ChannelInboundHandler 依次处理。 下面来看下
DefaultChannelPipeline
的类图：
DefaultChannelPipeline 实现了
ChannelPipeline 接口，而
ChannelPipeline 又继承了
ChannelInboundInvoker 、
ChannelOutboundInvoker 和
Iterable 。
ChannelInboundInvoker :发起对
ChannelPipeline 中下一个
ChannelInboundHandler 的方法的调用。
ChannelOutboundInvoker :发起对
ChannelPipeline 中下一个
ChannelOutboundHandler 的方法的调用。
Iterable ：可遍历
ChannelPipeline 中的
ChannelHandler 。
NioEventLoop 继承自
SingleThreadEventLoop ,而
SingleThreadEventLoop 又继承自
SingleThreadEventExecutor 。
SingleThreadEventExecutor 内部持有一个Thread对象，是
Netty 多线程的基础。 可以认为, 一个
NioEventLoop
与一个特定的线程进行了绑定,并且在其生命周期内,绑定的线程都不会再改变。
DefaultChannelPipeline
DefaultChannelPipeline 的主要工作就是对 ChannelHandler 的管理，包括 ChannelHandler 的增减，事件的触发等。
ChannelHandler 的增减
以 addFirst 方法为例:
public final ChannelPipeline addFirst(EventExecutorGroup group, String name, ChannelHandler handler) {
final AbstractChannelHandlerContext newCtx;
synchronized (this) {
// 检查handler是否可以共享
checkMultiplicity(handler);
// 给AbstractChannelHandlerContext起个独立的名字
name = filterName(name, handler);
// 创建DefaultChannelHandlerContext
newCtx = newContext(group, name, handler);
// 执行实际的添加操作
addFirst0(newCtx);
// channel尚未注册到eventloop
if (!registered) {
// 设置newCtx的状态为ADD_PENDING
newCtx.setAddPending();
// 设置过一会回调ChannelHandler的handlerAdded方法
callHandlerCallbackLater(newCtx, true);
return this;
}
EventExecutor executor = newCtx.executor();
if (!executor.inEventLoop()) {
newCtx.setAddPending();
executor.execute(new Runnable() {
@Override
public void run() {
callHandlerAdded0(newCtx);
}
});
return this;
}
}
callHandlerAdded0(newCtx);
return this;
}
复制代码
addFirst 方法先检查添加的 ChannelHandler 是否可以共享（判断共享的方法是对于每个channel当前ChannelHandler是否需要不同的状态），再创建 ChannelHandler 的上下文关系，使 ChannelHandler 以链表方式存在于 ChannelPipeline 中。当 ChannelHandler 添加成功后，再调用 ChannelHandler 的 handlerAdded 方法。其它的添加方式和 addFirst 类似。
事件触发
以 fireChannelActive 方法为例：
public final ChannelPipeline fireChannelActive() {
AbstractChannelHandlerContext.invokeChannelActive(head);
return this;
}
复制代码
从 HeadContext 的head开始，依次触发下一个 ChannelHandler 的 channelActive 方法。
本篇简单介绍了 ChannelPipeline 的相关概念，当 ChannelHandler 介绍完后，再具体介绍 ChannelPipeline 中的 HeadContext 和 TailContext 。
文中帖的代码注释全在： KAMIJYOUDOUMA ， 有兴趣的童鞋可以关注一下。
本篇到此结束，如果读完觉得有收获的话，欢迎点赞、关注、加公众号【贰级天災】，查阅更多精彩历史！！！
正文到此结束
热门推荐
相关文章
近期评论
-
文章和留言都翻到11页了 没有OOM
-
-
朋友，翻页到11页，及以后，会出现OOM，无法访问
-
-
搞个gitee的项目
-
-
版本号是多少，你可以下载哪个代码仓库，jdk选1.8 直接跑就行
-
-
-
Loading...
![[HBLOG]公众号](https://www.liuhaihua.cn/img/qrcode_gzh.jpg)
