Netty在Dubbo中的线程名称

在项目中,我们会使用RocketMQ和Dubbo.前者用于发送或消费消息,后者用于两个模块之间的接口调用.
RocketMQ和Dubbo在它们的底层都使用Netty作为网络通信的框架.那么今天我们就来看一下,在Dubbo中,使用的Netty线程名称叫什么?

环境和流程如下:
1.启动zookeeper
2.一个简单的Dubbo提供者,并启动它
3.通过telnet和invoke命令连接并调用接口

关于zookeeper环境的简单搭建可以查看此篇文章.

启动zookeeper之后,我们接下来主要看下Dubbo提供者代码.
在官网下载了Dubbo的源码,在源码中增加了一个自己的简单Dubbo提供者代码.
先看下代码结构

image.png

beans.xml内容如下

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       https://www.springframework.org/schema/beans/spring-beans-2.0.xsd
       http://dubbo.apache.org/schema/dubbo
       http://dubbo.apache.org/schema/dubbo/dubbo.xsd">


    <dubbo:application name="infuq-x"/>
    <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"/>
    <dubbo:protocol name="dubbo" port="20880" host="127.0.0.1"/>

        <dubbo:service group="tmp" version="1.0" interface="com.infuq.provider.QueryComputerListService" ref="queryComputer" timeout="100" />
    <bean id="queryComputer" class="com.infuq.provider.QueryComputerListServiceImpl"/>

</beans>

QueryComputerListService.java内容

package com.infuq.provider;

public interface QueryComputerListService {

    int queryComputerCount();

}

QueryComputerListServiceImpl.java内容

package com.infuq.provider;

public class QueryComputerListServiceImpl implements QueryComputerListService {
    @Override
    public int queryComputerCount() {
        System.out.println("执行提供者接口的线程:" + Thread.currentThread().getName());

        return 100;
    }
}

Example.java测试类

package com.infuq.provider;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.io.IOException;

public class Example {
    public static void main(String[] args) throws IOException {
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("beans.xml");
        System.out.println("提供者启动成功...");
        // 为了让提供者不退出
        System.in.read();
    }
}

代码介绍完成.现在我们以debug方式启动提供者,然后再通过invoke命令调用接口,暂时打个断点,我们看下线程栈的信息.

我们在实现类中打了个断点

image.png

# 连接
telnet 127.0.0.1 20880

# 调用
invoke com.infuq.provider.QueryComputerListService.queryComputerCount()

image.png

Dubbo作为提供者,有两类线程.一类是Dubbo自己的线程,另一类就是底层通信的Netty线程.
在Netty中也有线程池的概念,但是它的池是以Group组的形式存在的.
比如我们有个名字叫K的线程池,它是第1个线程池,它里面有3个线程.那么这三个线程的名字就是

K-1-1
K-1-2
K-1-3

比如我们有个名字叫Q的线程池,它是第4个线程池,它里面有3个线程,那么这三个线程的名字就是

Q-4-1
Q-4-2
Q-4-3

规则是 线程池名称-第几个线程池-池中第几个线程

在Netty中有两类线程,一类是Selector线程,它单独在由一个线程池提供,这个线程池里一般只有一个线程. 另一类线程是Worker线程,它又单独由另一个线程池提供,这个线程池会有好几个线程.

上面图中的NettyServerBoss-4-1就是Selector线程.
NettyServerWorker-5-1和NettyServerWorker-5-2就是Worker线程.
根据上面线程的名称我们应该知道Selector线程的名字应该叫NettyServerBoss-1-1才对,为啥叫NettyServerBoss-4-1.说明在创建Selector线程的时候已经创建了3个线程池,所以创建Selector线程的时候才是第4个线程池,创建NettyServerWorker-5-1这类线程的时候是第5个线程池.
那么我们找下前面3个线程池是由谁创建的(或者给谁使用的).

仔细再看下上面那个图,我们还会发现一个线程,它的名字叫qos-boss-1-1. 关于Dubbo的QOS的线程是在更早的时候就被创建的.即创建qos-boss线程会使用一个线程池,而且创建qos-worker也会使用一个线程池.

image.png

这么算下来,应该还少一个线程池才对.没错,在Netty中有一个GlobalEventExecutor类,在它里面有个静态常量的单例.它也会使用一个线程池.所以说轮到正在的为Dubbo提供者创建线程池的时候,就轮到第4个开始了.

image.png