Netty源碼分析第1章(Netty啓動流程)---->第2節: NioServerSocketChannel的建立

 

Netty源碼分析第一章:  Server啓動流程

 

第二節:NioServerSocketChannel的建立

 

咱們若是熟悉Nio, 則對channel的概念則不會陌生, channel在至關於一個通道, 用於數據的傳輸

Netty將jdk的channel進行了包裝, 併爲其擴展了更多的功能

在netty中也分爲服務端channel和客戶端channel, 在Nio模式下, 服務端channel對應的類爲NioServerSocketChannel, 包裝的jdk的ServerSocketChannel

客戶端channel對應的類爲NioSocketChannel, 所包裝的jdk的類爲SocketChannel

最簡單的繼承關係以下(經簡化):

1-2-1

 

咱們繼續看第一小節demo:

//建立boss和worker線程(1)
EventLoopGroup bossGroup = new NioEventLoopGroup(1); EventLoopGroup workerGroup = new NioEventLoopGroup(); //建立ServerBootstrap(2)
ServerBootstrap b = new ServerBootstrap(); //初始化boss和work線程化兩個線程(3)
b.group(bossGroup, workerGroup) //聲明NioServerSocketChannel(4)
        .channel(NioServerSocketChannel.class) //初始化客戶端Handler(5)
        .childHandler(new ChannelInitializer<SocketChannel>() { @Override public void initChannel(SocketChannel ch) { ch.pipeline().addLast(new StringDecoder()); ch.pipeline().addLast(new StringEncoder()); ch.pipeline().addLast(new ServerHandler()); } }); //綁定端口(6)
ChannelFuture f = b.bind(8888).sync(); f.channel().closeFuture().sync();

咱們繼續看第六步, 綁定端口:

ChannelFuture f = b.bind(8888).sync();

在此, 咱們看到綁定了8888端口

 

咱們跟到bind(8888)方法中:

public ChannelFuture bind(int inetPort) { return bind(new InetSocketAddress(inetPort)); }

端口封裝成socket地址對象

 

繼續跟bind方法:

public ChannelFuture bind(SocketAddress localAddress) { validate(); return doBind(localAddress); }

validate()作了一些屬性驗證

 

咱們繼續跟到doBind(localAddress)方法:

private ChannelFuture doBind(final SocketAddress localAddress) { //初始化並註冊(1)
    final ChannelFuture regFuture = initAndRegister(); //得到channel(2)
    final Channel channel = regFuture.channel(); if (regFuture.cause() != null) { return regFuture; } if (regFuture.isDone()) { ChannelPromise promise = channel.newPromise(); //綁定(3) 
 doBind0(regFuture, channel, localAddress, promise); return promise; } else { //去除非關鍵代碼
        return promise; } }

去除了一些非關鍵的代碼, 重點關注註釋標註的第一步, 初始化並註冊:

final ChannelFuture regFuture = initAndRegister();

咱們跟進initAndRegister()方法:

final ChannelFuture initAndRegister() { Channel channel = null; try { //建立channel
        channel = channelFactory.newChannel(); init(channel); } catch (Throwable t) { //忽略非關鍵代碼
 } ChannelFuture regFuture = config().group().register(channel); //忽略非關鍵代碼
    return regFuture; }

關注添加註釋的步驟, 建立channel, 這一點也是咱們這節須要講明白的內容

 

看這一步:

channel = channelFactory.newChannel();

這裏channelFactory調用了newChannel()的這個方法, 這個方法從名字就不難理解, 是新建一個channel, 回顧下上一小節, 這個channelFactory是在哪裏初始化呢?

 

根據上一小節代碼, channelFactory是在Bootstrap的channelFactory ()方法初始化的:

public B channelFactory(ChannelFactory<? extends C> channelFactory) { this.channelFactory = channelFactory; return (B) this; }

而這個方法又是channel()方法中調用的:

public B channel(Class<? extends C> channelClass) { return channelFactory(new ReflectiveChannelFactory<C>(channelClass)); }

這裏傳入ReflectiveChannelFactory對象就是初始化的channelFactory對象

因此newChannel()是調用ReflectiveChannelFactory對象的newChannel方法

 

跟到ReflectiveChannelFactory對象的newChannel方法中:

@Override public T newChannel() { try { return clazz.newInstance(); } catch (Throwable t) { throw new ChannelException("Unable to create Channel from class " + clazz, t); } }

咱們看到這個clazz對象經過反射建立了channel, 這個clazz對象, 就是咱們上一節提到過的, 初始化的NioServerSocketChannel的class對象

這裏經過反射調用, 會建立一個NioServerSokectChannel

 

學習過nio的小夥伴都知道jdk的ServerSocketChannel, 用於接受連接事件, 而netty的NioServerSocketChannel是和jdk的channel有什麼關係呢?

 

實際上netty的channel和jdk的channel的含義同樣, 也是一個通道, 只是netty爲其作了擴展, 而channel的事件處理, 也是經過jdk的channel去作的, 咱們跟隨着NioServerSocketChannel的建立過程, 來了解他們之間的關聯關係

 

clazz.newInstance()經過反射建立一個NioServerSocketChannel對象, 首先會走到NioServerSocketChannel的構造方法, 咱們跟到他的構造方法, 查看NioServerSocketChannel的建立過程

首先會調用它的無參構造方法:

public NioServerSocketChannel() { this(newSocket(DEFAULT_SELECTOR_PROVIDER)); }

咱們看到這個構造方法調用了另外一個有參的構造方法, 傳入參數是 newSocket(DEFAULT_SELECTOR_PROVIDER) 

咱們首先看DEFAULT_SELECTOR_PROVIDER這個這變量:

private static final SelectorProvider DEFAULT_SELECTOR_PROVIDER = SelectorProvider.provider();

看到這初始化了一個SelectorProvider對象, 而這個對象是經過靜態方法provider()建立的, SelectorProvider對象能夠用於建立jdk底層的ServerSocketChannel

 

咱們繼續跟到newSocket(DEFAULT_SELECTOR_PROVIDER)中:

private static ServerSocketChannel newSocket(SelectorProvider provider) { return provider.openServerSocketChannel(); }

去掉try-catch塊, 發現這個方法是經過SelectorProvider對象的openServerSocketChannel()方法建立一個jdk底層的ServerSocketChannel, 至此咱們能夠知道, 與NioServerSokectChannel綁定的jdk底層的ServerSocketChannel就是這麼建立的

 

那麼建立以後如何與netty的channel綁定?繼續跟代碼

跟到this(newSocket(DEFAULT_SELECTOR_PROVIDER))中:

public NioServerSocketChannel(ServerSocketChannel channel) { super(null, channel, SelectionKey.OP_ACCEPT); config = new NioServerSocketChannelConfig(this, javaChannel().socket()); }

咱們看到這裏調用了父類的構造方法，繼續往裏跟:

protected AbstractNioMessageChannel(Channel parent, SelectableChannel ch, int readInterestOp) { super(parent, ch, readInterestOp); }

這裏調用了其父類AbstractNioMessageChannel類的構造方法, AbstractNioMessageChannel這個類同窗們請記住, 有關是NioServerSocketChannel的父類, 表明着服務端channel的相關屬性和操做, 以後有關服務端channel的一些事件會在這個類中完成

咱們看到這個類的構造方法中又調用了它的父類的構造方法, 咱們繼續跟:

protected AbstractNioChannel(Channel parent, SelectableChannel ch, int readInterestOp) { super(parent); //保存channel
    this.ch = ch; //綁定事件
    this.readInterestOp = readInterestOp; try { //設置爲非阻塞
        ch.configureBlocking(false); } catch (IOException e) { //去掉非關鍵代碼
 } }

這裏又調用了其父類AbstractChannel的構造方法, 跟進去這個方法以前, 咱們先往下看

 

首先看這一步:

this.ch = ch;

這步就是綁定jdk底層的ServerSocketChannel, 至此咱們知道, jdk的channel和netty定義的channel是組合關係, netty的channel中有個jdk的channel的成員變量, 而這個成員變量就定義在AbstractNioChannel這個類當中, 但願同窗們將這個結論緊緊記住, 對之後的學習頗有幫助

 

咱們看到後面的這一步:

ch.configureBlocking(false);

這一步, 就是將jdk的channel設置爲非阻塞模式, 這裏熟悉Nio的同窗應該不會陌生, 這裏再也不贅述

 

 咱們繼續跟到super(parent)中, 走到其父類AbstractChannel的構造方法:

protected AbstractChannel(Channel parent) { this.parent = parent; id = newId(); unsafe = newUnsafe(); pipeline = newChannelPipeline(); }

首先看下這個parent, 這個parent是NioServerSocketChannel調用其父類構造方法傳入的, 傳入的是null, 因此這一步AbstractChannel的屬性parent也是null, 這個parent, 咱們以後再講客戶端channel的時候會講到

id = newId()是爲每一個channel建立一個惟一id

 

咱們重點關注下後兩步:

unsafe = newUnsafe(); pipeline = newChannelPipeline();

這裏初始化了兩個屬性unsafe, 和pipeline, 目前咱們只須要知道這兩個屬性是在這裏初始化的, 至於這兩個屬性的概念, 後面的章節會講到

以上就是建立NioServerSocketChannel的過程, 同窗們能夠課後跟進源碼去熟悉鞏固

 

上一節: 服務端初始化

下一節: 服務端Channel的初始化