前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >『互联网架构』软件架构-dubbo协议底层原理与实现(44)

『互联网架构』软件架构-dubbo协议底层原理与实现(44)

作者头像
IT架构圈
发布2019-05-14 16:25:12
8630
发布2019-05-14 16:25:12
举报
文章被收录于专栏:IT架构圈IT架构圈

相信通过上三次的文章,基本都了解了dubbo的一些套路,分布式如何做,注册中心,admin怎么玩的。其实对dubbo没有这么深入了解的老铁,也很多会使用dubbo。但是我们仅仅做到使用就完了吗?其实并不是的。我们角度仅仅不能满足使用,深层的意义就是满足底层远离和实现机制。

(一)RPC协议与使用场景

在一个典型RPC的使用场景中,包含了服务发现、负载、容错、网络传输、序列化等组件,其中RPC协议就指明了程序如何进行网络传输和序列化 。也就是说一个RPC协议的实现就等于一个非透明的RPC调用,如何做到的的呢?

红色部分经过了一个线程池,RPC拿到数据后不能直接调用server的方法,必须要经过一个线程池。RPC协议服务端在进行反序列化,协议解码,网络传输,进行IO操作。如果IO线程去执行业务方法,业务方法本身需要做很多的操作,server的方法性能就非常的慢,导致RPC协议的IO线程,会被业务执行的逻辑堵塞,导致大量的客户端堵塞,最后链接挂了。

  • 协议的基本组成

1.地址:服务提供者地址 2.端口:协议指定开放的端口 3.运行服务:

  • netty
  • mina
  • RMI 服务
  • servlet 容器(jetty、Tomcat、Jboss)

4.报文编码:协议报文编码

  • http 报文编码
  • Dubbo 报文编码

5.序列化方式:

  • Hessian2Serialization
  • DubboSerialization
  • JavaSerialization
  • JsonSerialization
(二)协议报文编码
  • http协议
  • dubbo协议

协议的编解码过程

Dubbo 协议编解码实现过程 (源码来源于dubbo2.5.8 )

1.DubboCodec.encodeRequestData() 116L // 编码request 2.DecodeableRpcInvocation.decode() 89L // 解码request 3.DubboCodec.encodeResponseData() 184L // 编码response 4.DecodeableRpcResult.decode() 73L // 解码response

(三)Dubbo中所支持RPC协议使用

dubbo 支持的RPC协议列表

名称

实现描述

连接描述

适用场景

dubbo

传输服务: mina, netty(默认), grizzy 序列化: dubbo, hessian2(默认), java, fastjson 自定义报文

单个长连接 NIO异步传输

1.常规RPC调用 2.传输数据量小 3.提供者少于消费者

rmi

传输:java rmi 服务序列化:java原生二进制序列化

多个短连接 BIO同步传输

1.常规RPC调用 2.与原RMI客户端集成 3.可传少量文件 4.不支持防火墙穿透

hessian

传输服务:servlet容器 序列化:hessian二进制序列化

基于Http 协议传输,依懒servlet容器配置

1.提供者多于消费者2.可传大字段和文件 3.跨语言调用

http

传输服务:servlet容器 序列化:http表单

依懒servlet容器配置

数据包大小混合

thrift

与thrift RPC 实现集成,并在其基础上修改了报文头

长连接、NIO异步传输

关于RMI不支持防火墙穿透的补充说明: 原因在于RMI 底层实现中会有两个端口,一个是固定的用于服务发现的注册端口,另外会生成一个随机端口用于网络传输。这个随机端口就不能在防火墙中提前设置开放开。所以存在防火墙穿透问题 。

(五)协议的使用与配置

Dubbo框架为了更灵活扩展,其支持多种协议,用户只需要在 provider 应用中 配置即可元素即可。

代码语言:javascript
复制
<!--
name: 协议名称 dubbo|rmi|hessian|http|
host:本机IP可不填,则系统自动获取
port:端口、填-1表示系统自动选择
server:运行服务 mina|netty|grizzy|servlet|jetty
serialization:序列化方式 dubbo|hessian2|java|compactedjava|fastjson
[详细配置参见dubbo 官网 dubbo.io](http://dubbo.io/books/dubbo-user-book/references/xml/dubbo-protocol.html)
-->
<dubbo:protocol name="dubbo" host="192.168.0.11" port="20880" server="netty"
serialization=“hessian2” charset=“UTF-8” />
  • 演示采用其它协议来配置Dubbo

dubbo 协议采用 json 进行序列化 (源码参见:com.alibaba.dubbo.rpc.protocol.dubbo.DubboProtocol) 采用RMI协议 (源码参见:com.alibaba.dubbo.rpc.protocol.rmi.RmiProtocol) 采用Http协议 (源码参见:com.alibaba.dubbo.rpc.protocol.http.HttpProtocol.InternalHandler) 采用Heason协议 (源码参见:com.alibaba.dubbo.rpc.protocol.hessian.HessianProtocol.HessianHandler)

PS:dubbo很多协议都封装好了,直接xml已配置就ok了,其实并不复杂,对于底层实现其实就是RPC通信,就是socket没啥特别的。建议读下源码,debug跟踪下效果体会的更加明显。

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

本文分享自 编程坑太多 微信公众号,前往查看

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

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

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • (一)RPC协议与使用场景
  • (二)协议报文编码
  • (三)Dubbo中所支持RPC协议使用
  • (五)协议的使用与配置
相关产品与服务
文件存储
文件存储(Cloud File Storage,CFS)为您提供安全可靠、可扩展的共享文件存储服务。文件存储可与腾讯云服务器、容器服务、批量计算等服务搭配使用,为多个计算节点提供容量和性能可弹性扩展的高性能共享存储。腾讯云文件存储的管理界面简单、易使用,可实现对现有应用的无缝集成;按实际用量付费,为您节约成本,简化 IT 运维工作。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档