RPC协议底层原理与实现「建议收藏」

全栈程序员-站长 • 2022年5月19日上午7:40 • 未分类 • 阅读 30

大家好，又见面了，我是你们的朋友全栈君。

 RPC协议基本组成

 在一个典型RPC的使用场景中，包含了服务发现、负载、容错、

 网络传输

 、

 序列化

 等组件，其中RPC协议就指明了程序如何进行网络传输和序列化 。也就是说一个RPC协议的实现就等于一个非透明的RPC调用，如何做到的的呢？

  Client

 客户端

  Server

 服务端

 <img decoding="async" src="https://img-blog.csdn.net/20180301164224990" title="" alt="RPC协议底层原理与实现「建议收藏」">

 协议基本组成：

RPC协议底层原理与实现「建议收藏」

1.

地址：服务提供者地址；

  2.

     端口：协议指定开放的端口；

  3.

     运行服务:

  1.

 netty（默认）

  2.

 mina

  3.

 RMI 服务

  4.

 servlet 容器（jetty、Tomcat、Jboss）

  4.

     报文编码（编解码）：协议报文编码 。

 注①:http 报文编码 。注②:Dubbo 报文编码

  5.

    dubbo 序列化方式：

  1.

     Hessian2Serialization

 、(默认)

  2.

     DubboSerialization

 、

  3.

     JavaSerialization

  4.

     JsonSerialization

 RPC协议报文编码与实现详解

 注①：http 报文编码

 注②Dubbo 协议报文编码：

RPC协议底层原理与实现「建议收藏」

 （注：相关源码参见 

 c

 om.alibaba.dubbo.rpc.protocol.dubbo.DubboCodec

 ）

 协议的编解码过程：

   

 <img decoding="async" src="https://img-blog.csdn.net/20180301164327404" title="" alt="RPC协议底层原理与实现「建议收藏」">

 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	传输服务: 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容器配置	1、数据包大小混合
thrift	与thrift RPC 实现集成，并在其基础上修改了报文头	长连接、NIO异步传输

 协议的使用与配置:

  Dubbo框架为了更灵活扩展，其支持多种协议，用户只需要在 provider 应用中 配置即可 < dubbo:protocol

 >

  元素即可。

 <!–

 name:

 协议名称

 dubbo|rmi|hessian|http|

 host:本机IP可不填，则系统自动获取

 port：端口、填-1表示系统自动选择

 server：运行服务

 mina|netty|grizzy|servlet|jetty

 serialization：序列化方式

 dubbo|hessian2|java|compactedjava|fastjson

 详细配置参见dubbo 官网 dubbo.io

 –>

 <dubbo:protocol name=”dubbo”

 host=”192.168.0.11″

 port=”20880″ server=”netty”

 serialization= “

 hessian2”

 charset= “

 UTF-8” />

 #TODO 演示采用其它协议来配置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)

发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/144624.html原文链接：https://javaforall.net