环境和流程如下
1.启动zookeeper
2.一个简单的Dubbo提供者,并启动它
3.通过telnet和invoke命令连接并调用接口
启动zookeeper之后,我们接下来主要看下Dubbo提供者代码.
在官网下载了Dubbo的源码,在源码中增加了一个自己的简单Dubbo提供者代码.
先看下代码结构
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/beanshttps://www.springframework.org/schema/beans/spring-beans-2.0.xsdhttp://dubbo.apache.org/schema/dubbohttp://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 {@Overridepublic 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命令调用接口,暂时打个断点,我们看下线程栈的信息.
我们在实现类中打了个断点
# 连接telnet 127.0.0.1 20880# 调用invoke com.infuq.provider.QueryComputerListService.queryComputerCount()复制
Dubbo作为提供者,有两类线程.一类是Dubbo自己的线程,另一类就是底层通信的Netty线程.
在Netty中也有线程池的概念,但是它的池是以Group组的形式存在的.
比如我们有个名字叫K的线程池,它是第1个线程池,它里面有3个线程.那么这三个线程的名字就是
K-1-1K-1-2K-1-3复制
比如我们有个名字叫Q的线程池,它是第4个线程池,它里面有3个线程,那么这三个线程的名字就是
Q-4-1Q-4-2Q-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个开始了.
