Netty学习笔记(4) Netty源码 - accept 和 read流程

Netty学习笔记(4) Netty源码 - accept 和 read流程

文章目录

前言1. nio中的accept回顾2. netty中的accept流程

1. int localRead = doReadMessages(readBuf)2. pipeline.fireChannelRead(readBuf.get(i))

1. childGroup.register(child).addListener(new ChannelFutureListener() 3. netty 中的 read 流程

---

前言

笔记基于黑马的Netty教学讲义加上自己的一些理解，感觉这是看过的视频中挺不错的，基本没有什么废话，视频地址：黑马Netty。下面是。

还是这一段代码：

public class TestSourceServer {
    public static void main(String[] args) {
        new ServerBootstrap()
                //EventLoop有一个线程和执行器selector，用于关注事件，解决一些任务
                .group(new NioEventLoopGroup())
                .channel(NioServerSocketChannel.class)
                .childHandler(new ChannelInitializer(){

                    @Override
                    protected void initChannel(NioSocketChannel ch) throws Exception {
                        ch.pipeline().addLast(new LoggingHandler());
                    }
                }).bind(8080);
    }
}

[1] 标记

1. nio中的accept回顾

selector.selecr() 阻塞直到事件发生遍历处理 selectedKeys拿到一个 key，判断类型是不是 accept创建 SocketChannel，设置非阻塞将 SocketChannel注册到 selector设置 SocketChannel 关注 read 事件

2. netty中的accept流程

接着上一篇文章 NioServerSocketChannel 的第10点，下面这里就是进入 accept事件，可以说到了这里完成了nio 的1，2，3点，而unsafe.read(); 完成剩下的三点

下面就是 read 方法中的代码，这里面我们主要观察4、5、6三点在哪会被执行

@Override
        public void read() {
            assert eventLoop().inEventLoop();
            final ChannelConfig config = config();
            final ChannelPipeline pipeline = pipeline();
            final RecvByteBufAllocator.Handle allocHandle = unsafe().recvBufAllocHandle();
            allocHandle.reset(config);

            boolean closed = false;
            Throwable exception = null;
            try {
                try {
                    do {
                    	//4、创建 SocketChannel，设置非阻塞
                    	//下面看了源码后这里是 localRead =1 
                        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：拿到NioServertSocketChannel的流水线
                    //调用上面的handler处理
                    //这一步其实上面的处理器只有三个 head-accept-end
                    //都是前面的文章说过的
                    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. int localRead = doReadMessages(readBuf)

@Override
protected int doReadMessages(List