Dubbo协议解析过程
Dubbo有哪些底层协议
同学们以为Dubbo只有一个RPC协议吗?非也，既然是阿里巴巴出品的开源项目，那自然秉承了“包罗万象”的一贯传统。Dubbo的底层有支持多达9种通信协议，并且他们都有各自的适用场景。我们快速的一扫而过:
- Dubbo本尊这也是官方首推的底层通信协议
- RMI Java界的老法师可能会对RMI比较熟悉，没错，这个就
是JDK中“java.rmi”包下的实现，底层采用阻塞式(同步传输)的短连接+JDK中标准的二进制序列化。- 适用场景参数数据包大小不一，服务提供者和服务消费者的个数相近
- Hessian用于集成Hessian的服务，基于HTTP短连接，采用S ervlet向外暴露服务
- 适用场景参数数据包较大，服务提供者的数量远多于消费者数量
- HTTP最简单的基于HTTP表单的协议
- 适用场景可以使用浏览器直接查看，适用于需要同时给后台应用程序以及浏览器提供服务的场景(很多其他协议无法通过浏览器直接发起调用)
- WebService基于大名鼎鼎的Apache CXF，使用基于SOAP 的序列化技术
- 适用场景比如公司内部的系统是由多种不同语言构成的，那么这个场景就比较适合采用WebService协议，WebService通 常使用在系统集成和跨语言调用场景
- REST基于标准的Java REST API (JAX-RS 2.0) 实现的RES
T风格调用，Dubbo花了大力气在这部分的实现上面，它的使用风格和原生Spring MVC类似。但它不是今天的主角，同学们如果感兴趣的话可以自己花点时间去阅读REST协议的源码 - 杂七杂八的协议 Dubbo还支持基于Thrift, Memcached和Red is的协议，不过相信大家在职业生涯中应该是用不到的
Dubbo协议Dubbo协议的特性和性能
我们先来看一看 Dubbo协议的特性:
| 项目 | 说明 |
|---|---|
| 连接个数 | 单连接 |
| 连接方式 | 长连接 |
| 传输协议 | TCP |
| 底层通信框架 | Netty异步NIO |
| 序列化方式 | Hessian2或Dubbo序列化 |
在官方的测试报告中，由于Dubbo将底层的通信框架从mina换成了Netty,大大提升了稳定性，主要体现在JVM Old区对象的数量减少了很多，因此Full GC的触发频率大幅减少。
Dubbo协议的适用场景
尺有所短寸有所长，Dubbo并不是万能药，我们在使用它之前务必要知道它的适用场景:
适用场景传入传出参数数据包较小(建议小于100K)，但是并发量高的场景。简单来说就是短平快，QPS/TPS高但是数据量小的情况
不适场景尽量不要用Dubbo协议传输大数据包(比如大文件、视频、超大字符串等)，这类场景建议使用上面介绍过的其他协议栈
Dubbo协议的调用流程
接下来我们通过一幅图，看一下Dubbo协议的工作流程
这次我们换个姿势，采用从中间向两边展开的方式解读这个协议工作流程
Transporter
大家注意看图片底部最中间的Transporter，这个是底层网络传输组件，目前Dubbo支持Mina和Netty。大家可能对Netty比较熟悉，但并没有接触过Mina。在Dubbo的2.0版本以后已经从Mina全面替换为Netty，基于Netty的传输层在稳定性和性能上都要更好一些。
Header & Body
接下来我们看图中的绿色部分，就是Header和Body，这部分是Dubbo定义的私有RPC协议中的数据格式部分，它是一个变长协议，由定长的Header和不定长的Body组成。
- Header
上面是Header的结构，图片中的数字代表Header中Bit位置，下 面的文字表示这段字节所携带的信息，Header总 长度为16字节。其中Magic High=0xda, Magic Low=0xbb，标识了这是个Dubbo协议。
后面紧跟着16-23比特位带有两个信息:当前请求的类型以及序列化的方式。其中高四位表示当前请求的Request flag (有 三种类型: REQUEST, TWOWAY和EVENT)，低四位表示序列化的方式，Du bbo有四种序列化方式，分别对应Dubbo, FastJson, Hessian2和Java 原生序列化。
接下来24-31位是响应报文才有的信息，作为Request报文并不包含这部分信息。其中定义了详情请求的状态，比如OK，BAD_ RESP ONSE，SERVER TIMEOUT。注意这些Status Code可不是HTTP St atus,而是Dubbo自定义的状态。
最后两个部分分别对应Request ID (唯一请求ID)和经过序列化后的Body内容的长度。
- Body
这部分是Dubbo协议中不定长的部分，在传输之前会经过序列化处理，对于一个请求包来说，主要包含三部分的信息:
- 协议版本Dubbo当前的版本
- 寻址信息目标服务的名称，服务版本，方法名，方法签名类型
- 数据方法参数值，附件形式的数据等
Client, Server和ThreadPool
Client对应调用发起方，Server对 应服务提供方。
- Client在发起调用之前会将整个消息进行序列化，组装成上面的Header+ Body的变长协议格式
- Server根据Header里标识的序列化方式，对Body 中的内容进行反序列化
- ThreadPool响应服务调用请求的线程池，可以选择配置Fix ed或Cached Thread Pool
Dispatcher线程派发模型
Dispatcher用来创建具有线程派发能力的ChannelHandler,将来访Request派发到线程池或当前I0线程。我们可以给Dispatcher配置5种派发策略
| 策略 | 说明 |
|---|---|
| all | 所有消息都派发到线程池，包括请求，响应，连接事件，断开事件等 |
| direct | 所有消息都不派发到线程池，全部在IO线程上直接执行 |
| message | 只有请求和响应消息派发到线程池，其它消息均在IO线程上执行 |
| execution | 只有请求消息派发到线程池，不含响应。其它消息均在IO线程上执行 |
| connection | 在IO线程上，将连接断开事件放入队列，有序逐个执行，其它消息派发到线程池 |
协议的约束
既然Dubbo协议应用了序列化和反序列化技术，那么对我们数据传输有几个约束条件:
- Serializable 参数和返回值必须实现Serializablc接口，否则在调用的时候会抛出无法序列化反序列化的异常
- 使用JDK原生类 比如Map、Date、 List、 Number等-系列接
口，我们不能在返回值和参数中使用自己创建的实现类，只能使用JDK原生的接口实现类。
服务的同步和异步调用
Dubbo支持同步和异步两种调用方式，整个链路流程非常复杂，我们只抓重点看下两个调用模式的不同
- 异步调用 异步调用还可细分为“有返回值”的异步调用和“无返回值”的异步调用。所谓“无返回值”异步调用是指服务消费方只管调用，但不关心调用结果，此时Dubbo会直接返回一个空的RpcResult。若要使用异步特性，需要服务消费方手动进行配置。
- 同步调用 这是默认情况下Dubbo所采用的调用方式，调用方等待服务提供者返回处理结果
本文已收录至我的个人网站：程序员波特，主要记录Java相关技术系列教程，共享电子书、Java学习路线、视频教程、简历模板和面试题等学习资源，让想要学习的你，不再迷茫。
