分布式-3-RPC

角色组成

rpc-001.jpg

• Server
  • 服务提供方
• Client
  • 服务消费方
• Registry
  • 服务注册和发现中心
  • Server启动后主动向Registry注册机器IP、Port及服务列表
  • Client启动时向Registry获取Server地址列表，可实现软负载均衡和Failover

调用流程

rpc-002.jpg

1. client以本地调用方式调用服务
2. client stub收到调用后将方法、参数组装成能够进行网络传输的消息体
3. client stub找到服务地址，将消息发送到服务端
4. server skeleton收到消息后解码
5. server skeleton根据解码结果调用本地服务
6. 本地服务执行并将结果返回server skeleton
7. server skeleton将结果打包成消息发送至消费方
8. client stub接收到消息，进行解码
9. client得到最终结果

• RPC框架的目标是将2~8步骤封装起来，让用户对细节透明

技术实现

• 动态代理
  • client stub和server skeleton依靠动态代理实现
  • jdk、cglib（底层是asm）、javassist
• 序列化
  • 原生效率低
  • 文本：fastjson、jackson
  • 二进制：protobuf（有压缩）、Thrift、Kryo、hessian（类似于map）、Msgpack（类似于值的数组，所以兼容的时候要考虑顺序）
• 通信
  • 模式：BIO、NIO、AIO
  • IDL：Interface Description Language
  • 开源框架：netty（HSF、dubbo、Hadoop Avro都在用）
• 注册中心
  • Redis、Zookeeper、Consul、Etcd、Eureka（Spring Cloud）

优秀开源框架

• 阿里巴巴 Dubbo：https://github.com/alibaba/dubbo
• 新浪微博 Motan：https://github.com/weibocom/motan
• 谷歌 gRPC：https://github.com/grpc/grpc
• rpcx（Go语言生态圈的Dubbo）：https://github.com/smallnest/rpcx
• Apache Thrift ：https://thrift.apache.org/