前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Netty在Dubbo中的线程名称

Netty在Dubbo中的线程名称

作者头像
书唐瑞
发布2022-06-02 13:59:51
1.3K0
发布2022-06-02 13:59:51
举报
文章被收录于专栏:Netty历险记

在项目中,我们会使用RocketMQ和Dubbo.前者用于发送或消费消息,后者用于两个模块之间的接口调用.

RocketMQ和Dubbo在它们的底层都使用Netty作为网络通信的框架.那么今天我们就来看一下,在Dubbo中,使用的Netty线程名称叫什么?

环境和流程如下

1.启动zookeeper

2.一个简单的Dubbo提供者,并启动它

3.通过telnet和invoke命令连接并调用接口

启动zookeeper之后,我们接下来主要看下Dubbo提供者代码.

在官网下载了Dubbo的源码,在源码中增加了一个自己的简单Dubbo提供者代码.

先看下代码结构

beans.xml内容如下

代码语言:javascript
复制
<?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内容

代码语言:javascript
复制
package com.infuq.provider;

public interface QueryComputerListService {
   int queryComputerCount();
}

QueryComputerListServiceImpl.java内容

代码语言:javascript
复制
package com.infuq.provider;

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

Example.java测试类

代码语言:javascript
复制
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命令调用接口,暂时打个断点,我们看下线程栈的信息.

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

代码语言:javascript
复制
# 连接
telnet 127.0.0.1 20880

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

Dubbo作为提供者,有两类线程.一类是Dubbo自己的线程,另一类就是底层通信的Netty线程.

在Netty中也有线程池的概念,但是它的池是以Group组的形式存在的.

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

代码语言:javascript
复制
K-1-1
K-1-2
K-1-3

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

代码语言:javascript
复制
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也会使用一个线程池.

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

本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2020-11-16,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 Netty历险记 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档