Netty知识点

BootStrap & ServerBootStrap

1. BootStrap 用来引导客户端程序，配置绑定，连接等
2. ServerBootstrap用来引导服务端程序配置，绑定，Channel，ChannelHandler配置等

EventLoopGroup & EventLoop

1. EventLoopGroup会给Channel分配EventLoop，一个EventLoop会被分到多个Channel，准确的说它是用来注册channel的
2. 每个EventLoop有一个只有一个线程的Exector， EventLoopGroup会把channel交给EventLoop去注册

Channel

1. Channel存着evenloop的引用

ChannelHandler

ChannelFuture

1. ChannelFuture实际上就是回调

数据如何传递的

io.netty.channel.nioNioEventLoop

 
private static void processSelectedKey(SelectionKey k, NioTask<SelectableChannel> task) {
        int state = 0;
        try {
            task.channelReady(k.channel(), k);
            state = 1;
        } catch (Exception e) {
            k.cancel();
            invokeChannelUnregistered(task, k, e);
            state = 2;
        } finally {
            switch (state) {
            case 0:
                k.cancel();
                invokeChannelUnregistered(task, k, null);
                break;
            case 1:
                if (!k.isValid()) { // Cancelled by channelReady()
                    invokeChannelUnregistered(task, k, null);
                }
                break;
            }
        }
    }

Netty的流程

http://blog.csdn.net/zjuclh/article/details/51002491

HeadContext是最接近Socket层，TailContext最接近业务层

 
​x
@Override
        public final void read() {
            final ChannelConfig config = config();
            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 = allocHandle.allocate(allocator);
                    allocHandle.lastBytesRead(doReadBytes(byteBuf));
                    if (allocHandle.lastBytesRead() <= 0) {
                        // nothing was read. release the buffer.
                        byteBuf.release();
                        byteBuf = null;
                        close = allocHandle.lastBytesRead() < 0;
                        break;
                    }
​
                    allocHandle.incMessagesRead(1);
                    readPending = false;
                    pipeline.fireChannelRead(byteBuf);
                    byteBuf = null;
                } while (allocHandle.continueReading());
​
                allocHandle.readComplete();
                pipeline.fireChannelReadComplete();
​
                if (close) {
                    closeOnRead(pipeline);
                }
            } catch (Throwable t) {
                handleReadException(pipeline, byteBuf, t, close, allocHandle);
            } finally {
                if (!readPending && !config.isAutoRead()) {
                    removeReadOp();
                }
            }
        }

HeadContext 调用Unsafe去做connect, read, write触发pipeline的fireChannelRead，fireChannelReadComplete

问题

EventLoopGroup如何把连接注册到EventLoop上去的。