在项目中,我们会使用RocketMQ和Dubbo.前者用于发送或消费消息,后者用于两个模块之间的接口调用.
RocketMQ和Dubbo在它们的底层都使用Netty作为网络通信的框架.那么今天我们就来看一下,在Dubbo中,使用的Netty线程名称叫什么?
环境和流程如下
1.启动zookeeper
2.一个简单的Dubbo提供者,并启动它
3.通过telnet和invoke命令连接并调用接口
启动zookeeper之后,我们接下来主要看下Dubbo提供者代码.
在官网下载了Dubbo的源码,在源码中增加了一个自己的简单Dubbo提供者代码.
先看下代码结构
beans.xml内容如下
<?xml version="1.0" encoding="UTF-8"?>
QueryComputerListService.java内容
package com.infuq.provider;
QueryComputerListServiceImpl.java内容
package com.infuq.provider;
Example.java测试类
package com.infuq.provider;
代码介绍完成.现在我们以debug方式启动提供者,然后再通过invoke命令调用接口,暂时打个断点,我们看下线程栈的信息.
我们在实现类中打了个断点
# 连接
Dubbo作为提供者,有两类线程.一类是Dubbo自己的线程,另一类就是底层通信的Netty线程.
在Netty中也有线程池的概念,但是它的池是以Group组的形式存在的.
比如我们有个名字叫K的线程池,它是第1个线程池,它里面有3个线程.那么这三个线程的名字就是
K-1-1
比如我们有个名字叫Q的线程池,它是第4个线程池,它里面有3个线程,那么这三个线程的名字就是
Q-4-1
规则是 线程池名称-第几个线程池-池中第几个线程
在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个开始了.
本文分享自微信公众号 - Netty历险记（infuq217）。
如有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一起分享。
