Netty源码笔记I - 关于『注册SelectionKey#OP_ACCEPT』

嗯，Mina的社区不够活跃，我转投Netty了。

翻看Netty的源码有一些时间了，但卡在了一个点上，它是在哪个逻辑里面注册
SelectionKey#OP_ACCEPT的呢？经过我断断续续的努力，各种debug断点调试，
终于取得了突破。

最终调用的代码在io.netty.channel.nio.AbstractNioChannel#doBeginRead()
里面，其中有句selectionKey.interestOps(interestOps | readInterestOp)，就
是通过这个interestOps来完成注册SelectionKey#OP_ACCEPT的。

以前翻看代码时没在意readInterestOp这个变量，完全按字面意思去理解它，以
为它最多只是注册SelectionKey#OP_READ，多次忽略了这里的逻辑。后来翻看
io.netty.channel.socket.nio.NioServerSocketChannel.NioServerSocketChannel
的构造方法可以看到它传了SelectionKey.OP_ACCEPT进去的(见下面的代码)，
传进去后被赋值到readInterestOp变量里面。这个变量如果叫做acceptOrReadInterestOp
就更好了，我可以少走一些弯路。。。

public NioServerSocketChannel(ServerSocketChannel channel) {
    super(null, channel, SelectionKey.OP_ACCEPT);
    config = new NioServerSocketChannelConfig(this, javaChannel().socket());
}

好了，知道在哪里注册SelectionKey.OP_ACCEPT之后，又是由哪里触发这个注册呢？
我debug追踪io.netty.example.echo.EchoServer这个经典的例子来看了一把，得到的流程：
-> io.netty.bootstrap.ServerBootstrap#bind(xxx)
      -> io.netty.bootstrap.AbstractBootstrap#doBind0(xxx)
           -> io.netty.channel.AbstractChannel#bind(xxx)
                -> io.netty.channel.DefaultChannelPipeline#bind(xxx)
                     -> io.netty.channel.DefaultChannelPipeline#invokeBind(xxx)
                          -> io.netty.channel.DefaultChannelPipeline.HeadHandler#bind(xxx)
                               -> io.netty.channel.AbstractChannel.AbstractUnsafe#bind(xxx)
                                    在上面这个AbstractUnsafe#bind里面有段关键代码(见下面的代码)，之前也是一直被我忽略，最终需要执行里面的pipeline.fireChannelActive()：

if (!wasActive && isActive()) {
    invokeLater(new OneTimeTask() {
        @Override
        public void run() {
            pipeline.fireChannelActive();
        }
    });
}

通过继续追踪fireChannelActive()就可以看到io.netty.channel.nio.AbstractNioChannel#doBeginRead()的执行了，然后就是selectionKey.interestOps(interestOps | readInterestOp)来完成注册SelectionKey#OP_ACCEPT。

发布在 http://auzll.iteye.com

评论

1 楼 sankby 2017-07-25  

终于找到这个说明了，netty权威指南上关于readInterestOp 这个变量的说明好像不太对，只提到是OP_READ。netty的流程太复杂了，channel注册OP_ACCEPT|OP_READ事件竟然是在doBeginRead方法中完成。