Netty服务端Channel注册Selector及绑定服务器端…

2019-12-17 16:03:44来源:博客园 阅读 ()

新老客户大回馈,云服务器低至5折

Netty服务端Channel注册Selector及绑定服务器端口

当服务端Channel 创建并且初始化完成之后,会将其注册到 selector,通过语句config().group().register(channel)进行注册工作,该方法最终调用 AbstractUnsafe 类的 register 方法。以下各图是服务端Channel注册到Selector上的函数调用链。             截止到此,服务器Channel虽然已经注册到了Selector,但是注册时配置的感兴趣的事件时0,可以看看doRegister()方法:   而且,这里服务端Channel也还没有绑定服务器的端口,服务端Channel的绑定工作是在AbstractBootstrap的doBind0()方法中完成的。     在AbstractBootstrap的doBind0()方法中,给服务端Channel已经绑定的NioEventLoop中添加了一个Runnable任务,这个任务中实现了服务端Channel绑定服务器端口的工作。那NioEventLoop是什么时候去执行这个任务的?这里先说一下NioEventLoop的职责,它主要做两件事:①处理Channel中已经准备就绪的IO事件;②处理在任务队列中的非IO任务。服务端Channel绑定服务器的端口就属于一个非IO任务。并且NioEventLoop在处理IO事件与非IO任务时,可以根据ioRatio这个成员变量来分配处理IO事件与非IO任务的时间,默认情况ioRatio是50,说明分配给两者的处理时间是一样的。下面就是NioEventLoop启动后处理IO事件与非IO任务的代码,在NioEventLoop类的run方法中,由以下代码可知,在服务端的NioEventLoop启动之前,已经将绑定端口的任务添加到了任务队列,进到下面的for循环时,因为队列中有任务且还没有绑定服务器的端口,将执行selectNow方法并且直接返回,在switch中什么也不干,因此在调用processSelectedKeys方法后因为没有准备就绪的IO事件所以也直接返回,然后执行任务队列中的任务,完成服务器端口的绑定工作。
for (;;) {
    // 当taskQueue中有任务时,使用非阻塞的selectNow方法来获取Channel中准备就绪的IO事件
    // 如果Channel中没有准备就绪的IO事件,selectNow可以快速返回,然后处理taskQueue中的任务
    switch (selectStrategy.calculateStrategy(selectNowSupplier, hasTasks())) {
        case SelectStrategy.CONTINUE:
            continue;
        case SelectStrategy.SELECT:
            select(wakenUp.getAndSet(false));
        default:
    }
    cancelledKeys = 0;
    needsToSelectAgain = false;
    final int ioRatio = this.ioRatio;
    if (ioRatio == 100) {
        try {
            processSelectedKeys();
        } finally {
            // Ensure we always run tasks.
            // 处理在任务队列中的非IO任务
            runAllTasks();
        }
    } else {
        final long ioStartTime = System.nanoTime();
        try {
            processSelectedKeys();
        } finally {
            // Ensure we always run tasks.
            final long ioTime = System.nanoTime() - ioStartTime;
            runAllTasks(ioTime * (100 - ioRatio) / ioRatio);
        }
    }

至此,服务端Channel不仅创建、初始化完成,也注册到了Selector,并且绑定了服务端端口,在这之后,服务器便可以接收客户端的连接并进行处理了。  

原文链接:https://www.cnblogs.com/zviolet/p/12052320.html
如有疑问请与原作者联系

标签:

版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有

上一篇:Dubbo源码分析之SPI(二)

下一篇:Spring源码加载BeanDefinition过程