内容简介:的类图:与一个特定的线程进行了绑定,并且在其生命周期内,绑定的线程都不会再改变。
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 , 有兴趣的童鞋可以关注一下。
本篇到此结束,如果读完觉得有收获的话,欢迎点赞、关注、加公众号【贰级天災】,查阅更多精彩历史!!!
以上所述就是小编给大家介绍的《Netty源码分析(七):初识ChannelPipeline》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!
猜你喜欢:- ReactNative源码解析-初识源码
- OkHttp源码分析 初识结构篇
- DPDK 源码的不完全笔记(一) 初识DPDK
- Spring Security源码分析十:初识Spring Security OAuth2
- 初识Redis
- Netty:初识Netty
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。