netty5alph1源码分析(服务端创建过程）-创新互联

参照《Netty系列之Netty 服务端创建》，研究了netty的服务端创建过程。至于netty的优势，可以参照网络其他文章。《Netty系列之Netty 服务端创建》是 李林锋撰写的netty源码分析的一篇好文，绝对是技术干货。但抛开技术来说，也存在一些瑕疵。

缺点如下

1. 代码衔接不连贯，上下不连贯。

2. 代码片段是截图，对阅读代理不便（可能和阅读习惯有关）

本篇主要内容，参照《Netty系列之Netty 服务端创建》，梳理出自己喜欢的阅读风格。

1.整体逻辑图

整体将服务端创建分为2部分：（1）绑定端口，提供服务过程；（2）轮询网络请求

1.1 绑定端口序列图

1.2 类图

类图仅仅涵盖了绑定过程中比较重要的几个组件

1.3 代码分析

step 2 doBind 绑定本地端口，启动服务

private ChannelFuture doBind(final SocketAddress localAddress) {
    final ChannelFuture regFuture = initAndRegister();//1
    final Channel channel = regFuture.channel();
    if (regFuture.cause() != null) {
        return regFuture;
    }

    final ChannelPromise promise;
    if (regFuture.isDone()) {
        promise = channel.newPromise();
        doBind0(regFuture, channel, localAddress, promise);//2
    } else {
        // Registration future is almost always fulfilled already, but just in case it's not.
        promise = new DefaultChannelPromise(channel, GlobalEventExecutor.INSTANCE);
        regFuture.addListener(new ChannelFutureListener() {
            @Override
            public void operationComplete(ChannelFuture future) throws Exception {
                doBind0(regFuture, channel, localAddress, promise);//2
            }
        });
    }

    return promise;
}

主要分为2个处理单元

step3 initAndRegister

final ChannelFuture initAndRegister() {
    Channel channel;
    try {
        channel = createChannel();
    } catch (Throwable t) {
        return VoidChannel.INSTANCE.newFailedFuture(t);
    }

    try {
        init(channel);
    } catch (Throwable t) {
        channel.unsafe().closeForcibly();
        return channel.newFailedFuture(t);
    }
//注册NioServerSocketChannel到Reactor线程的多路复用器上
    ChannelPromise regFuture = channel.newPromise();
    channel.unsafe().register(regFuture);
    if (regFuture.cause() != null) {
        if (channel.isRegistered()) {
            channel.close();
        } else {
            channel.unsafe().closeForcibly();
        }
    }

    return regFuture;
}

createChannel由子类ServerBootstrap实现，创建新的NioServerSocketChannel，并完成Channel初始化,以及注册。

4.ServerBootstrap.createChannel

Channel createChannel() {
    EventLoop eventLoop = group().next();
    return channelFactory().newChannel(eventLoop, childGroup);
}

它有两个参数，参数1是从父类的NIO线程池中顺序获取一个NioEventLoop，它就是服务端用于监听和接收客户端连接的Reactor线程。第二个参数就是所谓的workerGroup线程池，它就是处理IO读写的Reactor线程组。

5.ServerBootstrap.init

void init(Channel channel) throws Exception {
//设置Socket参数和NioServerSocketChannel的附加属性
    final Map, Object> options = options();
    synchronized (options) {
        channel.config().setOptions(options);
    }
    final Map, Object> attrs = attrs();
    synchronized (attrs) {
        for (Entry, Object> e: attrs.entrySet()) {
            @SuppressWarnings("unchecked")
            AttributeKey