---

小可爱们，这一篇基本搬运另一篇文，地址已经贴出来了，只不过加了一些go相关的而已（原文以java举例），因为我自己单纯浏览看不下去，总是走神，所以边敲边看更容易长脑子
参考：https://cloud.tencent.com/developer/article/2021745

一、RPC

1. 什么是RPC

RPC（Remote Procedure Call Protocol）远程过程调用协议。一个通俗的描述是：客户端在不知道调用细节的情况下，调用存在于远程计算机上的某个对象，就像调用本地应用程序中的对象一样。
比较正式的描述是：一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。

• RPC是协议：既然是协议就只是一套规范，那么就需要有人遵循这套规范来进行实现。目前典型的RPC实现包括：Dubbo、Thrift、GRPC、Hetty等。
• 网络协议和网络IO模型对其透明：既然RPC的客户端认为自己是在调用本地对象。那么传输层使用的是TCP/UDP还是HTTP协议，又或者是一些其他的网络协议它就不需要关心了。
• 信息格式对其透明：我们知道在本地应用程序中，对于某个对象的调用需要传递一些参数，并且会返回一个调用结果。至于被调用的对象内部是如何使用这些参数，并计算出处理结果的，调用方是不需要关心的。那么对于远程调用来说，这些参数会以某种信息格式传递给网络上的另外一台计算机，这个信息格式是怎样构成的，调用方是不需要关心的。
• 应该有跨语言能力：为什么这样说呢？因为调用方实际上也不清楚远程服务器的应用程序是使用什么语言运行的。那么对于调用方来说，无论服务器方使用的是什么语言，本次调用都应该成功，并且返回值也应该按照调用方程序语言所能理解的形式进行描述。
  

2. 为什么要用RPC

\qquad 应用开发到一定的阶段的强烈需求驱动的。如果我们开发简单的单一应用，逻辑简单、用户不多、流量不大，那我们用不着。当我们的系统访问量增大、业务增多时，我们会发现一台单机运行此系统已经无法承受。此时，我们可以将业务拆分成几个互不关联的应用，分别部署在各自机器上，以划清逻辑并减小压力。此时，我们也可以不需要RPC，因为应用之间是互不关联的。
\qquad 当我们的业务越来越多、应用也越来越多时，自然的，我们会发现有些功能已经不能简单划分开来或者划分不出来。此时，可以将公共业务逻辑抽离出来，将之组成独立的服务Service应用 。而原有的、新增的应用都可以与那些独立的Service应用 交互，以此来完成完整的业务功能。

所以此时，我们急需一种高效的应用程序之间的通讯手段来完成这种需求，所以你看，RPC大显身手的时候来了！

其实描述的场景也是服务化 、微服务和分布式系统架构的基础场景。即RPC框架就是实现以上结构的有力方式。

2.1 常见的RPC框架

• Thrift：thrift是一个软件框架，用来进行可扩展且跨语言的服务的开发。它结合了功能强大的软件堆栈和代码生成引擎，以构建在 C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, Smalltalk, and OCaml 这些编程语言间无缝结合的、高效的服务。
• gRPC：一开始由 google 开发，是一款语言中立、平台中立、开源的远程过程调用(RPC)系统。
• Dubbo：Dubbo是一个分布式服务框架，以及SOA治理方案。其功能主要包括：高性能NIO通讯及多协议集成，服务动态寻址与路由，软负载均衡与容错，依赖分析与降级等。Dubbo是阿里巴巴内部的SOA服务化治理方案的核心框架，Dubbo自2011年开源后，已被许多非阿里系公司使用。
• Spring Cloud：Spring Cloud由众多子项目组成，如Spring Cloud Config、Spring Cloud Netflix、Spring Cloud Consul 等，提供了搭建分布式系统及微服务常用的工具，如配置管理、服务发现、断路器、智能路由、微代理、控制总线、一次性token、全局锁、选主、分布式会话和集群状态等，满足了构建微服务所需的所有解决方案。Spring Cloud基于Spring Boot, 使得开发部署极其简单。

3. RPC原理

3.1 RPC调用流程

要让网络通信细节对使用者透明，需要对通信细节进行封装：

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

RPC的目标就是要2~8这些步骤都封装起来，让用户对这些细节透明。

3.2 如何做到透明化远程服务调用

在 Go 语言中，实现透明化的远程服务调用（RPC）可以通过类似于 Java 动态代理的方式来封装通信细节，使得用户可以像调用本地方法一样调用远程服务。以下是一个简单的介绍，说明如何在 Go 中实现这一点。

3.2.1 动态代理的概念

在 Go 中，虽然没有 Java 中的动态代理机制，但可以通过反射和接口来实现类似的功能。我们可以创建一个代理对象，该对象实现了目标接口，并在方法调用时封装通信逻辑。

3.2.2 实现 RPC 代理

以下是一个简单的示例，展示如何在 Go 中实现一个 RPC 代理：

package mainimport ("fmt""reflect"
)// 定义一个接口
type HelloWorldService interface {SayHello(name string) string
}// RPC 代理结构体
type RPCProxyClient struct {target interface{}
}// 创建代理
func NewRPCProxyClient(target interface{}) *RPCProxyClient {return &RPCProxyClient{target: target}
}// 实现代理方法
func (p *RPCProxyClient) Invoke(methodName string, args ...interface{}) (interface{}, error) {// 使用反射获取方法method := reflect.ValueOf(p.target).MethodByName(methodName)if !method.IsValid() {return nil, fmt.Errorf("method %s not found", methodName)}// 准备参数in := make([]reflect.Value, len(args))for i, arg := range args {in[i] = reflect.ValueOf(arg)}// 调用方法result := method.Call(in)return result[0].Interface(), nil
}// 实现 HelloWorldService 的一个具体类型
type HelloWorldServiceImpl struct{}func (h *HelloWorldServiceImpl) SayHello(name string) string {return "Hello, " + name
}func main() {// 创建服务实现service := &HelloWorldServiceImpl{}// 创建代理proxy := NewRPCProxyClient(service)// 调用代理方法result, err := proxy.Invoke("SayHello", "test")if err != nil {fmt.Println("Error:", err)} else {fmt.Println("Result:", result)}
}

3.2.3 序列化与反序列化

在 Go 中，常用的序列化方案包括 JSON、Protobuf、Gob 等。选择合适的序列化方案需要考虑通用性、性能和可扩展性。
JSON：简单易用，适合轻量级应用。
Protobuf：高效，适合大规模分布式系统。
Gob：Go 内置的序列化方案，适合 Go 内部通信。

3.2.4 服务注册与发现

在 Go 中，常用的服务注册与发现工具包括 ETCD 和 Consul。它们可以帮助管理服务的注册、心跳和客户端的服务发现。
ETCD：分布式键值存储，支持高可用和一致性。
Consul：提供服务发现、配置和分布式锁等功能。

3.2.5 消息中的 requestID

requestID 用于唯一标识每个请求，确保在并发环境中能够正确匹配请求和响应，避免混淆。
通过以上步骤，可以在 Go 中实现一个简单的 RPC 框架，使得远程服务调用对用户透明化。

二、gRPC

1. gRPC

1.1简介

gRPC是一个高性能、通用的开源RPC框架，其由Google 2015年主要面向移动应用开发并基于HTTP/2协议标准而设计，基于ProtoBuf序列化协议开发，且支持众多开发语言。
由于是开源框架，通信的双方可以进行二次开发，所以客户端和服务器端之间的通信会更加专注于业务层面的内容，减少了对由gRPC框架实现的底层通信的关注。

如下图，DATA部分即业务层面内容，下面所有的信息都由gRPC进行封装。

1.2 gRPC特点

• 语言中立，支持多种语言；
• 基于 IDL 文件定义服务，通过 proto3 工具生成指定语言的数据结构、服务端接口以及客户端 Stub；
• 通信协议基于标准的 HTTP/2 设计，支持双向流、消息头压缩、单 TCP 的多路复用、服务端推送等特性，这些特性使得 gRPC 在移动端设备上更加省电和节省网络流量；
• 序列化支持 PB（Protocol Buffer）和 JSON，PB 是一种语言无关的高性能序列化框架，基于 HTTP/2 + PB, 保障了 RPC 调用的高性能。

1.3 gPRC 交互过程

• 交换机在开启gRPC功能后充当gRPC客户端的角色，采集服务器充当gRPC服务器角色；
• 交换机会根据订阅的事件构建对应数据的格式（GPB/JSON），通过Protocol Buffers进行编写proto文件，交换机与服务器建立gRPC通道，通过gRPC协议向服务器发送请求消息；
• 服务器收到请求消息后，服务器会通过Protocol Buffers解译proto文件，还原出最先定义好格式的数据结构，进行业务处理；
• 数据处理完后，服务器需要使用Protocol Buffers重编译应答数据，通过gRPC协议向交换机发送应答消息；
• 交换机收到应答消息后，结束本次的gRPC交互。

简单地说，gRPC就是在客户端和服务器端开启gRPC功能后建立连接，将设备上配置的订阅数据推送给服务器端。我们可以看到整个过程是需要用到Protocol Buffers将所需要处理数据的结构化数据在proto文件中进行定义。

…未完待续