gRPC

gRPC 簡介：

gRPC 是一款高性能、開源的 RPC 框架，產自 Google，基於 ProtoBuf 序列化協議進行開發，支持多種語言（Golang、Python、Java等），本篇只介紹 Python 的 gRPC 使用。由於 gRPC 對 HTTP/2 協議的支持使其在 Android、IOS 等客戶端後端服務的開發領域具備良好的前景。gRPC 提供了一種簡單的方法來定義服務，同時客戶端能夠充分利用 HTTP/2 stream 的特性，從而有助於節省帶寬、下降 TCP 的鏈接次數、節省CPU的使用等。

安裝：

1. gRPC 的安裝：

$ pip install grpcio

1. 安裝 ProtoBuf 相關的 python 依賴庫：

$ pip install protobuf

1. 安裝 python grpc 的 protobuf 編譯工具：

$ pip install grpcio-tools

實踐：

下面咱們使用 gRPC 定義一個接口，該接口實現對傳入的數據進行大寫的格式化處理。

• 建立項目 python demo 工程：

  
  
   

  

  Paste_Image.png

1. client目錄下的 main.py 實現了客戶端用於發送數據並打印接收到 server 端處理後的數據

1. server 目錄下的 main.py 實現了 server 端用於接收客戶端發送的數據，並對數據進行大寫處理後返回給客戶端
2. example 包用於編寫 proto 文件並生成 data 接口

• 定義 gRPC 接口：

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

• 編譯 protobuf：

$ python -m grpc_tools.protoc -I. --python_out=. --grpc_python_out=. ./data.proto #在 example 目錄中執行編譯，會生成：data_pb2.py 與 data_pb2_grpc.py

• 實現 server 端：

#! /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' 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() 

• 實現 client 端：

#! /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) client = data_pb2_grpc.FormatDataStub(channel=conn) response = client.DoFormat(data_pb2.Data(text='hello,world!')) print("received: " + response.text) if __name__ == '__main__': run() 

• 執行驗證結果：

1. 先啓動 server，以後再執行 client

1. client 側控制檯若是打印的結果爲：「received: HELLO,WORLD!」 ，證實 gRPC 接口定義成功