gRPC 簡介：

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

安裝：

1. gRPC 的安裝：

   $ pip install grpcio

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

   $ pip install protobuf

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

   $ pip install grpcio-tools

實踐：

下面我們使用 gRPC 定義一個介面，該介面實現對傳入的資料進行大寫的格式化處理。
* 建立專案 python demo 工程：

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 + ':' + _HOST)
    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 介面定義成功

• 交流可以加 QQ 群：397234385
• 或者 QQ 掃碼入群：