Netty客户端接入流程NioSocketChannel怎么创建
导读：本文共3234.5字符，通常情况下阅读需要11分钟。同时您也可以点击右侧朗读，来听本文内容。按键盘←（左） →（右） 方向键可以翻页。
摘要： NioSocketChannel的创建回到上一小节的read()方法publicvoidread(){//必须是NioEventLoop方法调用的,不能通过外部线程调用asserteventLoop().inEventLoop();//服务端channel的configfinalChannelConfigconfig=config();//服务端cha... ...
目录
(为您整理了一些要点),点击可以直达。
我们继续剖析int localRead = doReadMessages(readBuf)这一部分逻辑
这里只是简单的定义了一个ArrayList, doReadMessages(readBuf)方法就是将读到的链接放在这个list中, 因为这里是NioServerSocketChannel所以这走到了NioServerSocketChannel的doReadMessage()方法
跟到doReadMessage()方法中:
首先根据jdk的ServerSocketChannel拿到jdk的Channel, 熟悉Nio的小伙伴应该不会陌生
封装成一个NioSokectChannel扔到Readbuf中
这里的NioSocketChannel是对jdk底层的SocketChannel的包装, 我们看到其构造方法传入两个参数, this代表当前NioServerSocketChannel, ch代表jdk的SocketChannel
我们跟到NioSocketChannel的构造方法中:
这里看到调用了父类构造方法, 传入两个参数, parent代表创建自身channel的, NioServerSocketChannel, socket代表jdk底层的socketChannel
其中SelectionKey.OP_READ代表其监听事件是读事件
继续跟父类的构造方法:
这里初始化了自身成员变量ch, 就是jdk底层的SocketChannel, 并初始化了自身的监听事件readInterestOp, 也就是读事件
ch.configureBlocking(false)这一步熟悉nio的小伙伴也不陌生, 就是将jdk的SocketChannel设置为非阻塞
我们继续跟到父类构造方法中:
这里初始化parent, 也就是创建自身的NioServerSocketChannel, 并为自身创建了唯一id
初始化unsafe, 我们跟到newUnsafe()方法中
由于此方法是NioEventLoop调用的, 所以会走到其父类AbstractNioByteChannel的newUnsafe()
跟到newUnsafe()中:
这里创建了NioByteUnsafe对象, 所以NioSocketChannel对应的unsafe是NioByteUnsafe
继续往下跟, 我们看到其初始化了pipeline, 有关pipline的知识, 我们会在下一章节中讲到
回到NioSocketChannel中的构造方法:
同NioServerSocketChannel一样, 这里也初始化了一个Config属性, 传入两个参数, 当前NioSocketChannel自身和jdk的底层SocketChannel的socket对象
同样, 这个类是NioSocketChannel的内部类
继续跟父类构造方法:
这里保存了SocketChannel的socket对象, 并且默认的情况禁止了Nagle算法, 有关Nagle, 感兴趣的同学可以学习下相关知识
继续跟到父类构造方法中:
又跟到到了我们熟悉的部分了, 也就是说, 无论NioServerSocketChannel和NioSocketChannel, 最后都会初始化DefaultChannelConfig, 并创建可变ByteBuf分配器, 我们之前小节对此做过详细剖析这里不再赘述。
Netty客户端接入流程NioSocketChannel怎么创建的详细内容，希望对您有所帮助，信息来源于网络。