Netty系列(四):NioServerSocketChannel注册

前言

本文主要介绍的是服务端NioServerSocketChannel创建和注册流程以及客户端连接到服务端后的NioSocketChannel的创建和注册流程,这两步都是很关键的。在介绍的过程中,中间会穿插着进行ChannelHandler与ChannelPipeline的一些简单的介绍。


服务端代码

上面的代码段我已经添加了详细的注释,具体的注册流程得从我标红的bind这个方法开始,我们随着这条线追踪一下,会发现最终会调用到doBind方法,里面有个initAndRegister函数,从这里开始就正式进入创建注册流程了。


initAndRegister函数

在这个函数中,我们主要关注三个点:

  1. 调用NioServerSocketChannel的无参构造函数进行其实例的初始化。
  2. 进行Option以及Attr的设置,这个方法里面,大家可以关注一下我下面圈红的ServerBootstrapAcceptor这个类,它会被注册到NioServerSocketChannel的pipeline中去,后面SocketChannel的注册流程会依靠这个类做一些操作,大家先留个印象即可,重点
  3. 开启NioEventLoop的线程,并执行register操作。

我们直接从第三步开始说,涉及到前面的知识点我后面会一一解释。

server_channel_register.png

上图的第二步判断操作eventLoop.inEventLoop()这一步实际上判断的是
this.thread == Thread.currentThread(),而this.thread仅仅只是在线程开启的时候赋值过一次,所以我上面说,只要线程已经开启,这类注册任务便可以直接执行,省去了队列的push和pull的过程。(线程的开启可以参考我的Netty系列(三))。

下面开始说注册的核心函数register0。


register0 核心函数

  1. doRegister()这个方法在seletor上注册了NioServerSocketChannel实例,但是没有绑定任何兴趣事件。我们要知道,一个ServerSocketChannel要想接受客户端的连接必须要绑定一个Accept的兴趣事件的,所以这里的注册流程还是不完整的,后面肯定有方法将这个坑给填上。注册代码如下:
    selectionKey = javaChannel().register(eventLoop().unwrappedSelector(), 0, this);
  2. 第二步的主要功能是将handler在咱们的pipeline这个管道中串联起来,方便后面的业务处理流程。按咱们最开始构造的服务端的代码,目前pipeline中的handler的顺序应该如下图所示:

在经过pipeline.invokeHandlerAddedIfNeeded()这个方法的调用之后,pipeline中的管道应该如下图所示:

调用这个方法的流程一步步点进去不难发现,实际上调用的是你重写handler之后的handlerAdded方法,而ChannelInitializer这个类的handlerAdded方法又调用的本身的initChannel方法:

所以接下来就会走这个流程:


这段代码是不是很熟悉,我在上面说initAndRegister这个函数的时候也有用到这块代码的。通过上面这段简单的流程,我们可以对handler是怎样和pipeline组合到一起有了一个大概的了解。

这里给大家补充个小知识点:

数据从HeadContext进来,按pipeline从前往后找InboundHandler处理业务;但是发出去时,从TailContext开始,按pipeline从后往前找OutboundHandler处理业务,这两者刚好相反。所以咱们编解码的handler都要添加在pipeline的最前面,也就是head后面的位置,这样data进来就可以进行decode,出去就encode。

  1. 前面介绍过只是将channel注册到selector上面了,但是未绑定兴趣事件。这个第三步就是一个填坑的操作,将ServerSocketChannel所需要的兴趣事件给补充上了。fireChannelActive方法调用的是handler中的channelActive方法。咱们看一下HeadContext中的channelActive方法,注册兴趣事件时在我圈红的方法里面完成的:

咱们看下调用流程:


顺着这条链路走下去,最终调用到一个doBeginRead的方法,关注两个点,一个是selectionKey,一个是readInterestOp。前者是在上面的第一步
selectionKey = javaChannel().register(eventLoop().unwrappedSelector(), 0, this)过程中进行的赋值,后者是在调用NioServerSocketChannel的无参构造函数时进行的赋值:

在通过位运算if ((interestOps & readInterestOp) == 0)判断该兴趣事件如果尚未被注册的话便进行注册兴趣事件。所以这里会注册一个OP_ACCEPT兴趣事件。

这样,NioServerSocketChannel的注册流程就结束了。也能正常接收客户端发过来的连接请求了。


NioServerSocketChannel注册总结图

NioServerSocketChannel.png

上面是整理的是NioServerSocketChannel从initAndRegister开始的注册流程图。


NioSocketChannel创建及注册

NioSocketChannel的注册流程咱们从processSelectedKey这个方法开始看,上一篇文章有介绍这个方法里面实际上是根据不同的兴趣事件做不同的处理,这里我们关注下OP_ACCEPT兴趣事件。

咱们完整的看看这个read方法:

        public void read() {
            //判断NioEventLoop是否已经开启线程了
            assert eventLoop().inEventLoop();
            final ChannelConfig config = config();
            //取出 与NioServerSocketChannel绑定的pipeline
            final ChannelPipeline pipeline = pipeline();
            final RecvByteBufAllocator.Handle allocHandle = unsafe().recvBufAllocHandle();
            allocHandle.reset(config);

            boolean closed = false;
            Throwable exception = null;
            try {
                try {
                    do {
                        // 生成NioSocketChannel实例
                        int localRead = doReadMessages(readBuf);
                        if (localRead == 0) {
                            break;
                        }
                        if (localRead < 0) {
                            closed = true;
                            break;
                        }

                        allocHandle.incMessagesRead(localRead);
                    } while (allocHandle.continueReading());
                } catch (Throwable t) {
                    exception = t;
                }

                int size = readBuf.size();
                for (int i = 0; i < size; i ++) {
                    readPending = false;
                    //沿着pipeline从head-->tail调用channelRead方法
                    pipeline.fireChannelRead(readBuf.get(i));
                }
                // 清除处理过后的消息,供下次接收使用
                readBuf.clear();
                allocHandle.readComplete();
                pipeline.fireChannelReadComplete();

                if (exception != null) {
                    closed = closeOnReadError(exception);

                    pipeline.fireExceptionCaught(exception);
                }

                if (closed) {
                    inputShutdown = true;
                    if (isOpen()) {
                        close(voidPromise());
                    }
                }
            } finally {
                if (!readPending && !config.isAutoRead()) {
                    removeReadOp();
                }
            }
        }
  1. 看下doReadMessages这个方法:

这一块就是调用serverSocketChannel.accept()获取SocketChannel,这一块不清楚的可以了解一下JAVA NIO相关的知识点。获取SocketChannel实例后包装成为NioSocketChannel实例,然后塞到集合中供后面进行处理。

  1. 看下pipeline.fireChannelRead(readBuf.get(i))这个方法,从第一步中咱们可以知道readBuf.get(i)得到的就是一个NioSocketChannel实例,然后在pipeline中从head-->tail依次执行handler中的channelRead方法。

现在的pipeline如下(不熟悉这张图的话可以翻到前面去看一下):


实际上主要看ServerBootstrapAcceptor的channelRead方法:

这个流程大家应该不会很陌生了吧!

1.给NioSocketChannel绑定的pipeline上添加handle。
2.进行Option以及Attr的设置。
3.进行register注册操作。

后续的register操作和NioServerSocketChannel差不了多少,就在注册兴趣事件时一个是注册的OP_ACCEPT,另一个注册的是OP_READ。


NioSocketChannel的创建流程图

NioSocketChannel.png

上面是整理的是NioSocketChannel的注册流程图,只画到register处,后续具体的注册流程可以参考NioServerSocketChannel的注册流程。


End

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,496评论 6 501
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,407评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 162,632评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,180评论 1 292
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,198评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,165评论 1 299
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,052评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,910评论 0 274
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,324评论 1 310
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,542评论 2 332
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,711评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,424评论 5 343
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,017评论 3 326
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,668评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,823评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,722评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,611评论 2 353

推荐阅读更多精彩内容