我们看如下代码：

@Override
public final ChannelPipeline fireChannelRead(Object msg) {
    AbstractChannelHandlerContext.invokeChannelRead(head, msg);
    returnthis;
}

他是从头节点开始传播的，channelRead的传播是自上而下的，所以就势必会传播到 ServerBootstrapAcceptor的逻辑中，所以我们进入到ServerBootstrapAcceptor#channelRead方法：

public void channelRead(ChannelHandlerContext ctx, Object msg) {
    //能进入都这一段逻辑的就必定是通道对象，因为只有服务端管道会存在该处理器
    final Channel child = (Channel) msg;
//向服务端管道追加childHandler   在构建ServerBootStrap的时候传入的
    child.pipeline().addLast(childHandler);
//在构建ServerBootStrap的时候传入的
    setChannelOptions(child, childOptions, logger);
//在构建ServerBootStrap的时候传入的
    setAttributes(child, childAttrs);
    try {
        //开始进行注册，注册逻辑同NioServerSocketChannel相同
        childGroup.register(child).addListener(new ChannelFutureListener() {
            @Override
            public void operationComplete(ChannelFuture future) throws Exception {
                if (!future.isSuccess()) {
                    forceClose(child, future.cause());
                }
            }
        });
    } catch (Throwable t) {
        forceClose(child, t);
    }
}

我们可以看到这个，先是向通道内注册一些客户端的参数，然后开始进行注册Channel, 注册的时候同NioServerSocketChannel的注册逻辑一样，只不过NioSocketChannel的关注事件是OP_READ事件，这里留一个作业，同学们可以自己分析一下NioSocketChannel的创建，分析一下它的注册逻辑与反应堆逻辑！

三、客户端数据读取源码解析

我们还是直接回到

io.netty.channel.nio.NioEventLoop#processSelectedKey(java.nio.channels.SelectionKey, io.netty.channel.nio.AbstractNioChannel)

private void processSelectedKey(SelectionKey k, AbstractNioChannel ch) {
    final AbstractNioChannel.NioUnsafe unsafe = ch.unsafe();
    .........忽略有效性验证................

    try {
        int readyOps = k.readyOps();
        ...................忽略其他 事件的处理逻辑...............
        if ((readyOps & (SelectionKey.OP_READ | SelectionKey.OP_ACCEPT)) != 0 || readyOps == 0) {
            unsafe.read();
        }
    } catch (CancelledKeyException ignored) {
        unsafe.close(unsafe.voidPromise());
    }
}

上面分析过，负责客户端新连接的通道是NioSocketChannel，大家自行分析一下内部逻辑，与NioServerSocketChannel的相似度90%！

1. 读取通道数据

NioSocketChannel的Unsafe是 NioByteUnsafe, 所以我们直接进入到：

io.netty.channel.nio.AbstractNioByteChannel.NioByteUnsafe#read

查看他是如何进行数据读取的：

@Override
public final void read() {
    ........................忽略........................
    //获取客户端通道管道
    final ChannelPipeline pipeline = pipeline();
    //获取一个内存分配器
    final ByteBufAllocator allocator = config.getAllocator();
    final RecvByteBufAllocator.Handle allocHandle = recvBufAllocHandle();
    allocHandle.reset(config);

    ByteBuf byteBuf = null;
    boolean close = false;
    try {
        do {
            //分配一个ByteBuf缓冲区
            byteBuf = allocHandle.allocate(allocator);
            //开始向缓冲区内写入通道的数据
            allocHandle.lastBytesRead(doReadBytes(byteBuf));
            if (allocHandle.lastBytesRead() <= 0) {
                // 如果没有读取到缓冲区，就释放缓冲区.
                byteBuf.release();
                byteBuf = null;
                //设置关闭标志
                close = allocHandle.lastBytesRead() < 0;
                if (close) {
                    // There is nothing left to read as we received an EOF.
                    readPending = false;
                }
                break;
            }

            allocHandle.incMessagesRead(1);
            readPending = false;
            //传播一次readChnnel事件
            pipeline.fireChannelRead(byteBuf);
            byteBuf = null;
        } while (allocHandle.continueReading());

        allocHandle.readComplete();
        //传播一次readChnnelComplete事件 
        pipeline.fireChannelReadComplete();
//关闭通道
        if (close) {
            closeOnRead(pipeline);
        }
    } catch (Throwable t) {
        ....................忽略不必要代码.....................
    }
}

我们整体将逻辑分为以下几个步骤：

1. 获取一个内存分配器，Netty中存在一个专门用于分配ByteBuf的内存分配器。这里是将它获取出来！
2. 使用上一步获取的内存分配器分配一块缓冲区，用域后续的使用！
3. 开始读取通道内的数据写入预先分配好的缓冲区！
4. 读取数据完毕后，将带有数据的缓冲区调用pieline的传播方法进行数据的传播 readChannel方法！
5. 当通道内的数据被处理完后，传播一次 channelReadComplete方法

四、总结

1. 在Netty中NioServerSocketChannel与NioSocketChannel的处理中，对于数据的读取拥有不同的处理方法，NioServerSockerChannel主要用于处理新连接的，在初始化的时候就会在通道内加入一个新连接接入器ServerBootstrapAcceptor！

   NioServerSocketChannel对象在读取到数据后将之包装为NioSocketChannel对象，然后使用ServerBootstrapAcceptor进行NioSocketChannel的注册与启动反应堆线程！

2. 当通道内存在数据的时候，被NioSockerChannel探测到后，就会先分配一块缓冲区，将数据读取进预先分配好的缓冲区，然后进行数据的向下通道流转（事件触发）！