dubbo系列--dubbo线程模型

在netty中的两种线程:boss线程、work线程

1 boss线程

作用:

  • accept客户端的连接

  • 将接收到的连接注册一个worker线程上

个数:

通常情况下,服务端每绑定一个端口,开启一个boss线程

2 worker线程

作用:

处理注册在其身上的连接connection上的各种io事件

个数:

认是:核数+1

注意:

dubbo的事件派发策略和线程池

1、dubbo基于netty。有5种派发策略:

  • all:(),所有消息都派发到线程池,包括请求,响应,连接事件,断开事件,心跳等。 即worker线程接收到事件后,将该事件提交到业务线程池中,自己再去处理其他事。

  • direct:worker线程接收到事件后,由worker执行到底。

  • message:只有请求响应消息派发到线程池,其它连接断开事件,心跳等消息,直接在 IO线程上执行

  • execution:只请求消息派发到线程池,不含响应(客户端线程池),响应和其它连接断开事件,心跳等消息,直接在 IO 线程上执行

  • connection:在 IO 线程上,将连接断开事件放入队列,有序逐个执行,其它消息派发到线程池。


2、业务线程池:


  • fixed:固定大小线程池,启动时建立线程,不关闭,一直持有。()

    • coresize:200

    • maxsize:200

    • 队列:SynchronousQueue

    • 回绝策略:AbortPolicyWithReport - 打印线程信息jstack,之后抛出异常


  •  

  • cached:缓存线程池,空闲一分钟自动删除,需要时重建。

  •  


  • limited:可伸缩线程池,但池中的线程数只会增长不会收缩。只增长不收缩的目的是为了避免收缩时突然来了大流量引起的性能问题。


服务端

两种线程池:

  • io线程池:netty的boss和worker线程池。

    • boss:建立connection

    • worker:处理注册在其身上的连接connection上的各种io事件

  • 业务线程池:

  • fixedThreadPool():“dubboServerHandler-10.10.10.11:20880”

  • 见“ dubbo的事件派发策略和线程池

    • 与worker配合处理各种请求

 

客户端

两种线程池:

  • io线程池:netty的boss和worker线程池

    • 同上

  • 业务线程池:

  • cachedThreadPool:“dubboClientHandler-10.10.10.10:20880”

    • 与worker配合处理各种响应,最后得到响应后唤醒被阻塞的主线程

dubbo线程模型图


整体步骤:(受限于派发策略,以认的all为例, 以netty4为例)


  1. 客户端的主线程发出一个请求后获得future,在执行get时进行阻塞等待;

  2. 服务端使用worker线程(netty通信模型)接收到请求后,将请求提交到server线程池中进行处理

  3. server线程处理完成之后,将相应结果返回给客户端的worker线程池(netty通信模型),最后,worker线程将响应结果提交到client线程池进行处理

  4. client线程将响应结果填充到future中,然后唤醒等待的主线程,主线程获取结果,返回给客户端


相关文章

在网络请求时,总会有各种异常情况出现,我们需要提前处理这...
作者:宇曾背景软件技术的发展历史,从单体的应用,逐渐演进...
hello,大家好呀,我是小楼。最近一个技术群有同学at我,问我...
 一个软件开发人员,工作到了一定的年限(一般是3、4年左右...
当一个服务调用另一个远程服务出现错误时的外观Dubbo提供了多...
最近在看阿里开源RPC框架Dubbo的源码,顺带梳理了一下其中用...