RPC
-
RPC(Remote Procedure Call，远程过程调用)是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络细节的应用程序通信协议。
-
RPC协议构建于TCP或UDP,或者是HTTP上，允许开发者直接调用另一台服务器上的程序，而开发者无需另外的为这个调用过程编写网络通信相关代码，使得开发网络分布式程序在内的应用程序更加容易。
-
RPC采用客户端-服务器端的工作模式，请求程序就是一个客户端，而服务提供程序就是一个服务器端。
-
当执行一个远程过程调用时，客户端程序首先先发送一个带有参数的调用信息到服务端，然后等待服务端响应。在服务端，服务进程保持睡眠状态直到客户端的调用信息到达。当一个调用信息到达时，服务端获得进程参数，计算出结果，并向客户端发送应答信息。然后等待下一个调用。
gRPC
-
gRPC 是 Google 开源的基于 Protobuf 和 Http2.0 协议的通信框架，默认采用Protocol Buffers数据序列化协议Protocol Buffers基本语法，支持多种开发语言。
-
gRPC提供了一种简单的方法来精确的定义服务，并且为客户端和服务端自动生成可靠的功能库
gRPC vs Restful API
-
gRPC和restful API都提供了一套通信机制，用于server/client模型通信，而且它们都使用http作为底层的传输协议(严格地说, gRPC使用的http2.0，而restful api则不一定。
-
gRPC可以通过protobuf来定义接口，从而可以有更加严格的接口约束条件。通过protobuf可以将数据序列化为二进制编码，这会大幅减少需要传输的数据量，从而大幅提高性能。
-
gRPC可以方便地支持流式通信(理论上通过http2.0就可以使用streaming模式, 但是通常web服务的restful api似乎很少这么用，通常的流式数据应用如视频流，一般都会使用专门的协议如HLS，RTMP等，这些就不是我们通常web服务了，而是有专门的服务器应用。
Protobuf
- Protobuf是一套类似Json或者XML的数据传输格式和规范，用于不同应用或进程之间进行通信时使用。
- 通信时所传递的信息是通过Protobuf定义的message数据结构进行打包，然后编译成二进制的码流再进行传输或者存储。
- protobuf经历了protobuf2和protobuf3，目前主流是protobuf3。
python操作
库
pip install grpcio
pip install grpcio-tools
protobuf3
以proto结尾：
syntax = "proto3";
// 只能发message类的信息
message HelloRequest{
string name = 1; // name的编号是1
}
生成python文件
python -m grpc_tools.protoc --python_out=. --grpc_python_out=. -I. hello.proto
# 生成两个python文件
# 1. python包
# 2. grpc调用
# -I input -I. 表示是当前目录下找input
# hello.proto 表示proto文件
使用
from proto import hello_pb2
# 转为二进制
request = hello_pb2.HelloRequest()
request.name = "bobby"
res = request.SerializeToString()
print(res)
# 从二进制转回来
request2 = hello_pb2.HelloRequest()
request2.ParseFromString(res)
print(request2.name)
grpc使用
hello.proto
syntax = "proto3";
# 定义grpc服务
service Greeter{
# 参数只可以是message声明的变量
rpc SayHello(HelloRequest) returns(HelloResponse);
}
message HelloRequest{
# name 的标号为1；
string name = 1;
}
message HelloResponse{
# 不同message 的标号不冲突；
string name = 1;
}
server.py
from grpc_hello import hello_pb2, hello_pb2_grpc
from concurrent.futures import ThreadPoolExecutor
import grpc
# 实现服务
# 生产的pb2.grpc文件中已经含有一个Servicer的类
class Greeter(hello_pb2_grpc.GreeterServicer):
# 实现proto定义的方法
def SayHello(self, request, context):
return hello_pb2.HelloResponse(name=f"我是{request.name}")
if __name__ == '__main__':
# 启动一个多线程服务
server = grpc.server(ThreadPoolExecutor(max_workers=10))
# 将Greeter注册到server中
hello_pb2_grpc.add_GreeterServicer_to_server(Greeter(), server)
# 启动
server.add_insecure_port('127.0.0.1:8001')
server.start()
server.wait_for_termination()
client.py
from proto import hello_pb2,hello_pb2_grpc
import grpc
if __name__ == '__main__':
with grpc.insecure_channel("127.0.0.1:80001') as channel:
# 建立连接通道
# 拿到服务对象
stub = hello_pb2_grpc.GreeterStub(channel)
# rsp: hello_pb2.HelloResponse 类型描述
# 拿到调用的返回值
rsp: hello_pb2.HelloResponse = stub.SayHello(hello_pb2.HelloRequest(name='zzz'))
print(rsp.name)