什么是RPC

RPC（Remote Procedure Call Protocol）-- 遠(yuǎn)程過程調(diào)用協(xié)議，它是一種通過網(wǎng)絡(luò)從遠(yuǎn)程計算機(jī)程序上請求服務(wù)，而不需要了解底層網(wǎng)絡(luò)協(xié)議的協(xié)議。RPC協(xié)議假定某些傳輸協(xié)議的存在，如TCP或UDP，為通信程序之間攜帶信息數(shù)據(jù)。在OSI網(wǎng)絡(luò)通信模型中，RPC跨越了傳輸層和應(yīng)用層。RPC使得開發(fā)包括網(wǎng)絡(luò)分布式多程序在內(nèi)的應(yīng)用程序更加容易。

?

什么是gRPC

gRPC 是Google開源的一款高性能的 RPC 框架，它基于 ProtoBuf 序列化協(xié)議進(jìn)行開發(fā)，支持多種開發(fā)語言（Golang、Python、Java、C/C++等）。gRPC 提供了一種簡單的方法來定義服務(wù)，同時客戶端可以充分利用 HTTP/2 stream 的特性，從而有助于節(jié)省帶寬、降低 TCP 的連接次數(shù)、節(jié)省CPU的使用等。

?

本文參考官方文檔[grpc.html]，以及gRPC的GitHub開源項目grpc/grpc。并通過一個小demo展示框架用法。

安裝gRPC及gRPC工具

pip install grpcio pip install grpcio-tools

grpcio-tools包含了protobuf的編輯工具 protoc，用來根據(jù) .proto 服務(wù)定義生成服務(wù)器端和客戶端代碼。

?

自定義 gRPC 接口

假定這里我們需要定義一個數(shù)據(jù)接收服務(wù)Receiver，用來接收客戶端傳遞給服務(wù)器端的數(shù)據(jù)。

syntax = "proto3"; import "google/protobuf/struct.proto";// 服務(wù)定義 service Receiver {rpc receive (Event) returns (Reply) {} }// 接收消息定義 message Event {string appid = 1;int32 xwhen = 2;string xwho = 3;string xwhat = 4;google.protobuf.Struct xcontext = 5; }// 返回消息定義 message Reply {int32 status = 1;string message = 2; }

?

編譯 proto 文件生成服務(wù)接口

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

這里會生成兩個python文件：

receiver_pb2.py receiver_pb2_grpc.py

?

編寫Server端代碼

# _*_ coding: utf-8 _*_import grpc import receiver_pb2 import receiver_pb2_grpcimport time from concurrent import futures_ONE_DAY_IN_SECONDS = 60 * 60 * 24class Receiver(receiver_pb2_grpc.ReceiverServicer):# 重寫父類方法，返回消息def receive(self, request, context):print('request:', request)return receiver_pb2.Reply(message='Hello, %s!' % request.xwho)if __name__ == '__main__':server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))receiver_pb2_grpc.add_ReceiverServicer_to_server(Receiver(), server)server.add_insecure_port('[::]:50051')server.start()print('server start...')try:while True:time.sleep(_ONE_DAY_IN_SECONDS)except KeyboardInterrupt:server.stop(0)

?

編寫client端代碼

# _*_ coding: utf-8 _*_import grpc import receiver_pb2 import receiver_pb2_grpc from google.protobuf import struct_pb2def run():channel = grpc.insecure_channel('localhost:50051')stub = receiver_pb2_grpc.ReceiverStub(channel)# 自定義struct結(jié)構(gòu)struct = struct_pb2.Struct()struct['idfa'] = 'idfa1'struct['amount'] = 123response = stub.receive(receiver_pb2.Event(xwhat='install', appid='fuckgod', xwhen=123, xwho='jerry', xcontext=struct))print("client status: %s received: %s" % (response.status, response.message))if __name__ == '__main__':run()

?

測試流程

（1）啟動server：python?server.py?&

（2）運(yùn)行client.py發(fā)送消息

server輸出：

server start... request: appid: "fuckgod" xwhen: 123 xwho: "jerry" xwhat: "install" xcontext {fields {key: "amount"value {number_value: 123.0}}fields {key: "idfa"value {string_value: "idfa1"}} }

client輸出：

client status: 0 received: Hello, jerry!

表示測試成功。

轉(zhuǎn)載自https://zhuanlan.zhihu.com/p/37158888

總結(jié)

以上是生活随笔為你收集整理的grpc例子的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。