Netty启动步骤绑定端口示例方法源码分析

更新时间：2022年03月25日 11:54:46 作者：向南是个万人迷

这篇文章主要介绍了Netty启动步骤绑定端口源码分析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪

绑定端口

上一小节我们学习了channel注册在selector的步骤, 仅仅做了注册但并没有监听事件, 事件是如何监听的呢?

我们继续跟第一小节的最初的doBind()方法

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;
    }
}

上一小节跟完了initAndRegister()方法, 我们继续往下走:

第二步, 获得channel

final Channel channel = regFuture.channel();

通过ChannelFuture的channel()方法获得了我们刚刚注册的NioServerSocketChannel, 拿到这个channel我们跟到第三步, 绑定

跟进方法doBind0(regFuture, channel, localAddress, promise):

private static void doBind0(final ChannelFuture regFuture, final Channel channel, final SocketAddress localAddress, final ChannelPromise promise) { 
    channel.eventLoop().execute(new Runnable() {
        @Override
        public void run() {
            if (regFuture.isSuccess()) {
                //绑定端口
                channel.bind(localAddress, promise).addListener(ChannelFutureListener.CLOSE_ON_FAILURE);
            } else {
                promise.setFailure(regFuture.cause());
            }
        }
    });
}

最终会走到channel.bind(localAddress, promise)这个方法当中

继续跟, 会走到AbstractChannel的bind()方法中:

public ChannelFuture bind(SocketAddress localAddress, ChannelPromise promise) {
    //通过pipeline绑定端口
    return pipeline.bind(localAddress, promise);
}

这里的pipeline就是channel初始化创建的pipline, pipline是事件传输通道, 这里我们暂不跟传输过程, 我们只需知道最后这个方法走到了AbstractChannel的bind()方法

跟到AbstractChannel的bind()方法:

public final void bind(final SocketAddress localAddress, final ChannelPromise promise) {
    //代码省略
    //端口绑定之前不是active, 返回false
    boolean wasActive = isActive();
    try {
        //做jdk底层的绑定
        doBind(localAddress);
    } catch (Throwable t) {
        //省略
        return;
    }
    //端口绑定之前不是active, 端口绑定之后变成active了
    if (!wasActive && isActive()) {
        invokeLater(new Runnable() {
            @Override
            public void run() {
                pipeline.fireChannelActive();
            }
        });
    }
    safeSetSuccess(promise);
}

重点关注下doBind(localAddress)方法

跟到NioSeverSocketChannel的doBind()方法:

protected void doBind(SocketAddress localAddress) throws Exception {
    //jdk版本的判断
    if (PlatformDependent.javaVersion() >= 7) {
        javaChannel().bind(localAddress, config.getBacklog());
    } else {
        javaChannel().socket().bind(localAddress, config.getBacklog());
    }
}

开始是一个jdk版本的判断, 我们以jdk7以上为例, 看到这条语句:

javaChannel().bind(localAddress, config.getBacklog());

终于找到了和jdk底层相关的绑定逻辑了, javaChannel()返回的是当前channel绑定的jdk底层的channel, 而bind()方法, 就是jdk底层的channel绑定端口的逻辑

回到bind(final SocketAddress localAddress, final ChannelPromise promise)方法:

首先看if判断: if (!wasActive && isActive())

这里意思是如果之前不是active, 绑定之后是active的话, 执行if块, 显然这里符合条件, 继续往里走

最终会走到这一步, pipeline.fireChannelActive()

这也是传输active事件, 目前我们只需知道, 事件完成之后, 会调用AbstractChannel内部类AbstractUnsafe的beginRead()方法

跟到AbstractUnsafe的beginRead()方法中:

public final void beginRead() {
    assertEventLoop();
    if (!isActive()) {
        return;
    }
    try {
        doBeginRead();
    } catch (final Exception e) {
        //代码省略
    }
}

我们关注doBeginRead()方法:

protected void doBeginRead() throws Exception {
    //拿到selectionKey
    final SelectionKey selectionKey = this.selectionKey;
    if (!selectionKey.isValid()) {
        return;
    }
    readPending = true;
    //获得感兴趣的事件
    final int interestOps = selectionKey.interestOps();
    //判断是不是对任何事件都不监听
    if ((interestOps & readInterestOp) == 0) {
        //此条件成立
        //将之前的accept事件注册, readInterest代表可以读取一个新连接的意思
        selectionKey.interestOps(interestOps | readInterestOp);
    }
}

这里到了jdk底层的调用逻辑, 通过注释不难看出其中的逻辑, 我们拿到和channel绑定的jdk底层的selectionKey, 获取其监听事件, 一上节我们知道, channel注册的时候没有注册任何事件, 所以我们这里if ((interestOps & readInterestOp) == 0) 返回true, 之后, 将accept事件注册到channel中, 也就是 selectionKey.interestOps(interestOps | readInterestOp) 这步执行的

注册完accept事件之后, 就可以轮询selector, 监听是否有新连接接入了

章节总结

通过了这一章的学习, 我们了解了server启动的大概流程, 这里重点掌握整个启动脉络, 知道关键步骤在哪个类执行, 后面的章节会分析每一个模块的含义

以上就是Netty启动步骤绑定端口源码分析的详细内容，更多关于Netty启动的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

mybatis框架入门学习教程
MyBatis是一个支持普通SQL查询，存储过程和高级映射的优秀持久层框架。这篇文章主要介绍了mybatis框架入门学习教程,需要的朋友可以参考下
2017-02-02
Sping Security前后端分离两种实战方案
这篇文章主要介绍了Sping Security前后端分离两种方案,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2023-03-03
Kotlin Coroutines执行异步加载示例详解
这篇文章主要给大家介绍了关于Kotlin Coroutines执行异步加载的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧。
2018-01-01
Java中的LinkedHashMap源码分析
这篇文章主要介绍了Java中的LinkedHashMap源码分析,LinkedHashMap是HashMap的子类,所以基本的操作与hashmap类似,不过呢,在插入、删除、替换key-value对的时候,需要的朋友可以参考下
2023-12-12
JSR303校验前端传递的数据方式
这篇文章主要介绍了JSR303校验前端传递的数据方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2024-01-01
浅谈一下Java中的堆和栈
这篇文章主要介绍了一下Java中的堆和栈,Java数据类型在执行过程中存储在两种不同形式的内存中：栈和堆，它们通常由运行Java虚拟机(JVM)的底层平台维护,需要的朋友可以参考下
2023-04-04
排序算法图解之Java快速排序的分步刨析
快速排序是通过一趟排序将要排序的数据分割为独立的两个部分，一部分的所有数据比另外一部分的所有数据要小，然后按照此方法对这两部分分别进行快速排序，整个过程可以递归进行，以此达到整个数据变成有序序列。本文通过示例讲解了快速排序的实现，需要的可以参考一下
2022-11-11
一文详解Java中的AuthRequest类(附Demo)
公共接口,定义了对第三方平台进行授权、登录、撤销授权和刷新 token 的操作,本文将详细分析Java中的AuthRequest类（附Demo）,文中通过代码示例介绍的非常详细,具有一定的参考价值,需要的朋友可以参考下
2024-04-04
Java中static修饰的静态变量、方法及代码块的特性与使用
这篇文章主要介绍了Java中static修饰的静态变量、方法及代码块的特性与使用,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2023-04-04
在SpringBoot项目中的使用Swagger的方法示例
这篇文章主要介绍了在SpringBoot项目中的使用Swagger的方法示例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-05-05