ThinkerQAQ

4.新连接的接入

Java · 4 篇笔记

  1. 2.59 1.检测新连接historical

    1. 打断点 有新连接过来的时候，会调用NioEventLoop中run方法的processSelectedKeys中OP ACCEPT逻辑 1.1. 启动客户端连接 我们在unsafe.read打个断点，启动服务器，并用telnet或者nc链接 2. 新连接进入 - 进入AbstractNioMe

  2. 2.65 2.创建NioSocketChannelhistorical

    1. 要分析的代码 this是netty服务端的channel，ch是jdk nio客户端的channel，NioSocketChannel是netty客户端的channel 2. NioSocketChannel构造函数 2.1. 设置对OP READ感兴趣 - 父类AbstractNioByte

  3. 2.71 3.分配线程及注册selectorhistorical

    1. 要分析的代码 - io.netty.channel.nio.AbstractNioMessageChannel.NioMessageUnsafe#read中有一段逻辑 2. 通过pipeline传播 pipeline.fireChannelRead(readBuf.get(i)) 会从pipe

  4. 2.74 4.向selector注册读事件historical

    1. 要分析的代码 - io.netty.channel.AbstractChannel.AbstractUnsafe#register中的register操作 2. 打断点使用nc连接 其实跟服务器启动的时候向selector注册accept一样，我们看io.netty.channel.Abstr