日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

參照《Netty系列之Netty 服務(wù)端創(chuàng)建》，研究了netty的服務(wù)端創(chuàng)建過程。至于netty的優(yōu)勢，可以參照網(wǎng)絡(luò)其他文章。《Netty系列之Netty 服務(wù)端創(chuàng)建》是 李林鋒撰寫的netty源碼分析的一篇好文，絕對是技術(shù)干貨。但拋開技術(shù)來說，也存在一些瑕疵。

為湘潭等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計制作服務(wù)，及湘潭網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為成都網(wǎng)站制作、網(wǎng)站建設(shè)、湘潭網(wǎng)站設(shè)計，以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務(wù)，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達到每一位用戶的要求，就會得到認可，從而選擇與我們長期合作。這樣，我們也可以走得更遠！

缺點如下

1. 代碼銜接不連貫，上下不連貫。

2. 代碼片段是截圖，對閱讀代理不便（可能和閱讀習(xí)慣有關(guān)）

本篇主要內(nèi)容，參照《Netty系列之Netty 服務(wù)端創(chuàng)建》，梳理出自己喜歡的閱讀風(fēng)格。

1.整體邏輯圖

整體將服務(wù)端創(chuàng)建分為2部分：（1）綁定端口，提供服務(wù)過程；（2）輪詢網(wǎng)絡(luò)請求

1.1 綁定端口序列圖

1.2 類圖

類圖僅僅涵蓋了綁定過程中比較重要的幾個組件

1.3 代碼分析

step 2 doBind 綁定本地端口，啟動服務(wù)

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線程的多路復(fù)用器上
    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實現(xiàn)，創(chuàng)建新的NioServerSocketChannel，并完成Channel初始化,以及注冊。

4.ServerBootstrap.createChannel

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

它有兩個參數(shù)，參數(shù)1是從父類的NIO線程池中順序獲取一個NioEventLoop，它就是服務(wù)端用于監(jiān)聽和接收客戶端連接的Reactor線程。第二個參數(shù)就是所謂的workerGroup線程池，它就是處理IO讀寫的Reactor線程組。

5.ServerBootstrap.init

void init(Channel channel) throws Exception {
//設(shè)置Socket參數(shù)和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