syntax = "proto3";
package example;
service FormatData {  //定義服務(wù),用在rpc傳輸中
 rpc DoFormat(actionrequest) returns (actionresponse){}
}
message actionrequest {
 string text = 1;
}
message actionresponse{
 string text=1;
}

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

# 實(shí)現(xiàn)了 server 端用于接收客戶端發(fā)送的數(shù)據(jù)，并對數(shù)據(jù)進(jìn)行大寫處理后返回給客戶端
# ! /usr/bin/env python
# -*- coding: utf-8 -*-
import grpc
import time
from concurrent import futures
from example import data_pb2, data_pb2_grpc
_ONE_DAY_IN_SECONDS = 60 * 60 * 24
_HOST = 'localhost'
_PORT = '8080'
# 實(shí)現(xiàn)一個(gè)派生類,重寫rpc中的接口函數(shù).自動(dòng)生成的grpc文件中比proto中的服務(wù)名稱多了一個(gè)Servicer
class FormatData(data_pb2_grpc.FormatDataServicer):
  # 重寫接口函數(shù).輸入和輸出都是proto中定義的Data類型
  def DoFormat(self, request, context):
    str = request.text
    return data_pb2.actionresponse(text=str.upper()) # 返回一個(gè)類實(shí)例
def serve():
  # 定義服務(wù)器并設(shè)置最大連接數(shù),corcurrent.futures是一個(gè)并發(fā)庫，類似于線程池的概念
  grpcServer = grpc.server(futures.ThreadPoolExecutor(max_workers=4))  # 創(chuàng)建一個(gè)服務(wù)器
  data_pb2_grpc.add_FormatDataServicer_to_server(FormatData(), grpcServer) # 在服務(wù)器中添加派生的接口服務(wù)（自己實(shí)現(xiàn)了處理函數(shù)）
  grpcServer.add_insecure_port(_HOST + ':' + _PORT)  # 添加監(jiān)聽端口
  grpcServer.start()  # 啟動(dòng)服務(wù)器
  try:
    while True:
      time.sleep(_ONE_DAY_IN_SECONDS)
  except KeyboardInterrupt:
    grpcServer.stop(0) # 關(guān)閉服務(wù)器
if __name__ == '__main__':
  serve()

# 實(shí)現(xiàn)了客戶端用于發(fā)送數(shù)據(jù)并打印接收到 server 端處理后的數(shù)據(jù)
# ! /usr/bin/env python
# -*- coding: utf-8 -*-
import grpc
from example import data_pb2, data_pb2_grpc
_HOST = 'localhost'
_PORT = '8080'
def run():
  conn = grpc.insecure_channel(_HOST + ':' + _PORT) # 監(jiān)聽頻道
  print(conn)
  client = data_pb2_grpc.FormatDataStub(channel=conn)  # 客戶端使用Stub類發(fā)送請求,參數(shù)為頻道,為了綁定鏈接
  print(client)
  response = client.DoFormat(data_pb2.actionrequest(text='hello,world!'))  # 返回的結(jié)果就是proto中定義的類
  print("received: " + response.text)
if __name__ == '__main__':
  run()