zoukankan      html  css  js  c++  java
  • Netty源码分析--初始化Options,添加处理器(四)

    接上篇,我们继续进入AbstractBootstrap类的 initAndRegister() 方法

    进入init()方法

    设置父级Channel的options,

    进入到上节提到的NioServerSocketChannelConfig

    其实就是为我们的channel.config()设置全局属性,当然我们也可以设置attr。

    继续看,从channel中获取新创建的pipeline,获取我们初始化的childOptions和childAttrs,我们这里都是null,因为我们并未通过引导器ServerBootStrap来设置。

    然后调用了pipeline的addLast方法,传入了一个抽象方法的实现类,这个类就是当前的此类,ServerBootstrap, 这里要注意

    继续代码跟进去,我们debug看一下

    继续跟

    进入 newCtx = newContext(group, name, handler);

     

    我们看,这里childExecutor由于传入的事件循环组是null,所以childExecutor(group)的返回时null, 并且 new 了一个 DefaultChannelHandlerContext 。

    进入构造方法

    将ServerBootstrap 赋给成员变量 handler , isInboud(handler) 和 isOutbound(handler) 是用来判断是入站处理器还是出站处理器

    确认一下,看到ServerBootstrap 继承的这类 ChannelInitializer 继承了 入站处理器的适配器, 也就是  isInboud(handler) = true  , isOutbound(handler)  = false

    继续进去父类的构造方法 ,赋值成员变量, 这个时候executor 是 null, 也就是说这里还没有指定当前的这个channel 以后由那个线程来处理

    总结一下就是创建了一个上下文包裹了这个ServerBootstrap

    我们继续往下看:

    把刚刚创建的这个上下文 添加到 pipeline的列表中

    现在就变成了这样的层级关系 HeadContext -> ServerBootstrap -> TailContext

    看到这里大家或许会有一些疑问,为什么把ServerBootstrap添加到链表中?而不是我们最开始的那个LoggingHandler呢?

    其实

    这里只是添加一个抽象方法的实现类进去,并没有真正调用initChannel的方法,这个要注意,这个在后面channel注册完后会来调用,并且会把我们当前添加的这个ServerBootstrap从链表中移除掉,这个我们后面再说。

    同时值得注意的是,这里还初始化了一个ServerBootstrapAcceptor类,没错这个就是acceptor, 用来接收客户端连接并且将新的客户端注册到多路复用器上,便于处理后面的读写操作。

  • 相关阅读:
    action里设置session
    用Eclipse导出能直接运行的jar包
    linux下命令行运行jar文件出错
    扫描对方主机端口
    调用Axis Webservice异常: java.net.ConnectException: Connection timed out: connect
    PL/SQL 安装出现的一些问题
    调用Axis WebService异常:org.xml.sax.SAXException: Bad envelope tag: definitions
    开通博客第一天
    正则表达式
    匿名函数
  • 原文地址:https://www.cnblogs.com/huxipeng/p/10994453.html
Copyright © 2011-2022 走看看