Dean's blog

环境配置

安装gRPC

pip install grpcio

安装ProtoBuf依赖库：

pip install protobuf

安装Python gRPC 的ProtoBuf 编译工具：

pip install grpcio-tools

注：在安装grpcio-tools的时候，pip提示了个错误：

ERROR: Could not find a version that satisfies the requirement grpcio-tools (from versions: none)
ERROR: No matching distribution found for grpcio-tools

后来问度娘后，升级pip就解决了：

python -m pip install -U pip

生成文件

1、编写proto文件：

添加example目录并添加data.proto，proto文件是定义的消息，内容：

syntax = "proto3";
package example;
service FormatData {
  rpc DoFormat(Data) returns (Data){}
}
message Data {
  string text = 1;
}

2、生成Python文件：

使用cmd进入example目录，并执行如下语句：

python -m grpc_tools.protoc -I. --python_out=. --grpc_python_out=../data.proto 

最后example目录文件清单如下：

│ data.proto
│ data_pb2.py
│ data_pb2_grpc.py

添加文件

1、添加server(main.py)：

import grpc
import time
from concurrent import futures
import sys
sys.path.append('..')
#sys.path
 
from example import data_pb2, data_pb2_grpc
 
_ONE_DAY_IN_SECONDS = 60 * 60 * 24
_HOST = 'localhost'
_PORT = '8080'
 
class FormatData(data_pb2_grpc.FormatDataServicer):
    def DoFormat(self, request, context):
        str = request.text
        return data_pb2.Data(text=str.upper())
 
def serve():
    grpcServer = grpc.server(futures.ThreadPoolExecutor(max_workers=4))
    data_pb2_grpc.add_FormatDataServicer_to_server(FormatData(), grpcServer)
    grpcServer.add_insecure_port(_HOST + ':' + _PORT)
    grpcServer.start()
    try:
        while True:
            time.sleep(_ONE_DAY_IN_SECONDS)
    except KeyboardInterrupt:
        grpcServer.stop(0)
 
if __name__ == '__main__':
    serve()

2、添加client(main.py)：

import grpc
import sys
import sys
sys.path.append('..')
 
from example import data_pb2, data_pb2_grpc

 
_HOST = 'localhost'
_PORT = '8080'
 
def run():
    conn = grpc.insecure_channel(_HOST + ':' + _PORT)
    client = data_pb2_grpc.FormatDataStub(channel=conn)
    response = client.DoFormat(data_pb2.Data(text='hello,world!'))
    print("received: " + response.text)
 
if __name__ == '__main__':
    run()

最后项目目录结构：

测试

依次运行server/client，即可看到效果

相关链接

Protobuf之proto文件编写规则： https://blog.csdn.net/jiaweiok123/article/details/87809831

gRPC中文文档：http://doc.oschina.net/grpc?t=60138