Netty4事件处理传播机制，java高级开发工程师要求（csdn）————程序.pdf
版权申诉
176 浏览量
2021-12-03
10:32:21
上传
评论
收藏 497KB PDF 举报
final AbstractChannelHandlerContext head
final AbstractChannelHandlerContext tail
private final Channel channel
protected DefaultChannelPipeline(Channel channel) {
this.channel = ObjectUtil.checkNotNull(channel, “channel”);
tail = new TailContext(this);
head = new HeadContext(this);
head.next = tail;
tail.prev = head;
}
从这里看一个 Channel 对应一个 ChannelPipeline。
2.1 事件链构建
本节将以 addFirst 方法为例展示 ChannelPipeline 事件链的维护实现。
DefaultChannelPipeline#addFirst
public final ChannelPipeline addFirst(String name, ChannelHandler
handler) {
return addFirst(null, name, handler);
}
内部调用其重载方法。接下来重点分析该方法
public final ChannelPipeline addFirst(EventExecutorGroup group,
String name, ChannelHandler handler) { // @1
final AbstractChannelHandlerContext newCtx;
synchronized (this) {
checkMultiplicity(handler); // @2
剩余15页未读，继续阅读
资源评论
