NioServerSocketChannel

NioServerSocketChannel

• • • • 回顾前言
      • 执行NioServerSocketChannel构造函数
      • NioServerSocketChannel构造函实现
    • AbstractNioMessageChannel
    • • 构造函数
    • AbstractNioChannel
    • • 构造函数
    • AbstractChannel
    • • 构造函数
    • NioServerSocketChannelConfig
    • DefaultServerSocketChannelConfig
    • • 构造函数
    • DefaultChannelConfig
    • • 构造函数
      • • doReadMessages
        • • NIO accept
    • doBind Channel通过基本的通信组件建立连接
    • doReadMessages
    • • buf.add(new NioSocketChannel(this, ch));

回顾前言

在netty Bootstrap启动之后会执行 channel，此时将NioServerSocketChannel的Class对象加入到BootStrap 的ChannelFactory之中，这个ChannelFactory是ReflectiveChannelFactory类型的

但是什么时候真正使用该Channel呢？


这里调用Class.newInstance()会跳到该类的构造函数

执行NioServerSocketChannel构造函数

可以看出先创建一个ServerSocketChannelImpl对象，然后以该对象作为入参执行NioServerSocketChannel的构造函数

首先执行 newSocket方法

熟悉NIO的话就明白了，ServerSocketChannelImpl是NIO最基本的组件，可见Netty是对NIo的进一步优化和封装。

然后再以ServerSocketChannelImpl为入参执行构造方法构造NioServerSocketChannel

NioServerSocketChannel构造函实现

跳转到父类AbstractNioMessageChannel构造函数

AbstractNioMessageChannel

构造函数

AbstractNioChannel

构造函数

设置非阻塞

AbstractChannel

构造函数

两个重要组件在这里初次登场
DefaultChannelId和DefaultChannelPipeline，还有比较重要的Unsafe

DefaultChannelId

DefaultChannelPipeline

NioServerSocketChannelConfig

DefaultServerSocketChannelConfig

构造函数

DefaultChannelConfig

构造函数

doReadMessages

NIO accept

  public SocketChannel accept() throws IOException {synchronized(this.lock) {if (!this.isOpen()) {throw new ClosedChannelException();} else if (!this.isBound()) {throw new NotYetBoundException();} else {SocketChannelImpl var2 = null;int var3 = 0;FileDescriptor var4 = new FileDescriptor();InetSocketAddress[] var5 = new InetSocketAddress[1];InetSocketAddress var6;try {this.begin();if (!this.isOpen()) {var6 = null;return var6;}this.thread = NativeThread.current();do {var3 = this.accept(this.fd, var4, var5);} while(var3 == -3 && this.isOpen());} finally {this.thread = 0L;this.end(var3 > 0);assert IOStatus.check(var3);}if (var3 < 1) {return null;} else {IOUtil.configureBlocking(var4, true);var6 = var5[0];var2 = new SocketChannelImpl(this.provider(), var4, var6);SecurityManager var7 = System.getSecurityManager();if (var7 != null) {try {var7.checkAccept(var6.getAddress().getHostAddress(), var6.getPort());} catch (SecurityException var13) {var2.close();throw var13;}}return var2;}}}}

doBind Channel通过基本的通信组件建立连接

javaChannel其实就是我们Nio中的ServerSocketChannelImpl

接下来就是NIO实现了

doReadMessages

    protected int doReadMessages(List<Object> buf) throws Exception {SocketChannel ch = this.javaChannel().accept();try {if (ch != null) {buf.add(new NioSocketChannel(this, ch));return 1;}} catch (Throwable var6) {logger.warn("Failed to create a new channel from an accepted socket.", var6);try {ch.close();} catch (Throwable var5) {logger.warn("Failed to close a socket.", var5);}}return

buf.add(new NioSocketChannel(this, ch));

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！