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, 有兴趣的童鞋可以关注一下。
本篇到此结束,如果读完觉得有收获的话,欢迎点赞、关注、加公众号【贰级天災】,查阅更多精彩历史!!!

文章转载自贰级天災,如果涉嫌侵权,请发送邮件至:contact@modb.pro进行举报,并提供相关证据,一经查实,墨天轮将立刻删除相关内容。
评论
相关阅读
2025年4月中国数据库流行度排行榜:OB高分复登顶,崖山稳驭撼十强
墨天轮编辑部
2271次阅读
2025-04-09 15:33:27
数据库国产化替代深化:DBA的机遇与挑战
代晓磊
1046次阅读
2025-04-27 16:53:22
2025年3月国产数据库大事记
墨天轮编辑部
958次阅读
2025-04-03 15:21:16
2025年3月国产数据库中标情况一览:TDSQL大单622万、GaussDB大单581万……
通讯员
657次阅读
2025-04-10 15:35:48
数据库,没有关税却有壁垒
多明戈教你玩狼人杀
526次阅读
2025-04-11 09:38:42
国产数据库需要扩大场景覆盖面才能在竞争中更有优势
白鳝的洞穴
508次阅读
2025-04-14 09:40:20
最近我为什么不写评论国产数据库的文章了
白鳝的洞穴
466次阅读
2025-04-07 09:44:54
【活动】分享你的压箱底干货文档,三篇解锁进阶奖励!
墨天轮编辑部
419次阅读
2025-04-17 17:02:24
2025年4月国产数据库中标情况一览:4个千万元级项目,GaussDB与OceanBase大放异彩!
通讯员
398次阅读
2025-04-30 15:24:06
天津市政府数据库框采结果公布,7家数据库产品入选!
通讯员
396次阅读
2025-04-10 12:32:35