pip3.6 install grpcio #安裝grpc
pip3.6 install grpcio-tools #安裝grpc tools

syntax = "proto3";
message HelloRequest {
  string name = 1;
}

cd hello.proto文件路徑下
命令：python3.6 -m grpc_tools.protoc --python_out=. --grpc_python_out=. -I. hello.proto
注意：只有python生成兩個(gè)文件
命令解釋?zhuān)?
python3.6 -m grpc_tools.protoc:實(shí)際需要使用grpc_tools.protoc這里面的命令
--python_out=. :生成的python文件放在當(dāng)前路徑下，這是給rpc用的文件
--grpc_python_out=. :生成的python文件放在當(dāng)前路徑下，這是給grpc用的文件
-I.:指import，當(dāng)前目錄下找hello.proto文件

res.SerializeToString() # 序列化二進(jìn)制
res2.ParseFromString(res_str) # 反序列化二進(jìn)制
import json
from python_grpc.proto import hello_pb2
def main():
    res = hello_pb2.HelloRequest()
    res.name = "jeff"
    res_str = res.SerializeToString() # 序列化二進(jìn)制
    print(res_str) # b'\n\x04jeff'
    print(len((res_str))) # 6，和json對(duì)比，josn長(zhǎng)度為：16
    res2 = hello_pb2.HelloRequest()
    res2.ParseFromString(res_str) # 反序列化二進(jìn)制
    print(res2.name) # jeff
    res_json = {
        "name":"jeff"
    }
    print(len(json.dumps(res_json))) # 16,json和proto壓縮對(duì)比，proto壓縮后：6
if __name__ == '__main__':
    main()

syntax = "proto3";
package services;
option go_package = "./;proto";
service Greeter {
    // 定義SayHello方法
    rpc SayHello (HelloRequest) returns (HelloReply);
}
message HelloRequest {
    string name = 1; //編號(hào)
}
message HelloReply {
    string message = 1; //編號(hào)
}

cd hello.proto文件路徑下
命令：python3.6 -m grpc_tools.protoc --python_out=. --grpc_python_out=. -I. hello.proto
注意：只有python生成兩個(gè)文件
命令解釋?zhuān)?
python3.6 -m grpc_tools.protoc:實(shí)際需要使用grpc_tools.protoc這里面的命令
--python_out=. :生成的python文件放在當(dāng)前路徑下，這是給rpc用的文件
--grpc_python_out=. :生成的python文件放在當(dāng)前路徑下，這是給grpc用的文件
-I.:指import，當(dāng)前目錄下找hello.proto文件
注意：生成的*_grpc.py文件的導(dǎo)包需要修改，否則報(bào)錯(cuò)：要讓python找到hello_pb2
import hello_pb2 as hello__pb2 改為：
from python_grpc.proto import hello_pb2 as hello__pb2

from concurrent import futures
import grpc
from python_grpc.proto import hello_pb2, hello_pb2_grpc
# 業(yè)務(wù)處理
class Greeter(hello_pb2_grpc.GreeterServicer):
    def SayHello(self, request, context):
        return hello_pb2.HelloReply(message=f"你好，{request.name}")
# 啟動(dòng)
def start():
    # 1.實(shí)例化server
    Thread = futures.ThreadPoolExecutor(max_workers=10)  ## 設(shè)置線(xiàn)程池，并發(fā)大小
    server = grpc.server(Thread)
    # 2.注冊(cè)邏輯到server中
    hello_pb2_grpc.add_GreeterServicer_to_server(Greeter(), server)
    # 3.啟動(dòng)server
    server.add_insecure_port("127.0.0.1:8888")
    server.start()
    server.wait_for_termination()
if __name__ == '__main__':
    start()

import grpc
from python_grpc.proto import hello_pb2, hello_pb2_grpc
# rpc調(diào)用
def main():
    # 這里使用with，調(diào)用完會(huì)自動(dòng)關(guān)閉。優(yōu)雅寫(xiě)法
    with grpc.insecure_channel("127.0.0.1:8888") as channel:
        stub = hello_pb2_grpc.GreeterStub(channel)
        # 調(diào)用定義的SayHello方法
        rep = stub.SayHello(
            hello_pb2.HelloRequest(name="jeff")  # 傳遞定義的HelloRequest類(lèi)型參數(shù)
        )
        return rep
# 業(yè)務(wù)代碼
def start():
    rep = main()
    print(rep.message)  # 你好，jeff
if __name__ == '__main__':
    start()