概述

gRPC 是谷歌開源的一個rpc（遠程程序調用）框架，可以輕松實現跨語言，跨平臺編程，其采用gRPC協議（基于HTTP2）。

rpc：

remote procedure call， 翻譯過來就是是遠程程序調用。具體來說，就是客戶端c1需要調用服務器s1上的某個方法（函數），得到相應的返回值并傳遞給c1。

gRPC協議

要說gRPC協議需要先了解HTTP2， 雖然HTTP1.X 協議至今仍是主流協議，但是隨著我們對性能要求越來越高，和web規模的不斷擴大，HTTP2就應運而生。

在這里，我們只需要知道其性能是高于現有的HTTP1就好了，感興趣的朋友可以深入了解HTTP2。

使用原因

在上家公司，因為之前的項目有一下幾個痛點，所以決定采用rpc框架：

項目的app，網站，m站，小程序等是獨立項目， 一處改，處處改，效率低下

所有模塊在一個項目里面，維護起來需要熟悉所有業務流程，維護難度加大

擴展性不強，應付高一點的并發需要將項目所有東西復制到新加服務器，運行所有模塊，包括并發量不高的模塊，造成資源浪費

所以我們花了點時間處理這些問題，將訂單，用戶等模塊拆開，方便獨立部署，獨立升級，獨立維護，這樣可以大大提高維護效率和項目的伸縮性。

使用方法

1.準備.proto文件

syntax = "proto3";

package order;

message OrderRequest {// 定義請求數據

string phone = 1;

string price = 2;

map request_arg = 3;//便于字段擴展

}

message JSONResponse{// 定義返回格式

string rst_string = 1; //統一返回json字符串作處理

}

service OrderHandler {

// format a list of events.

rpc create_order (OrderRequest) returns (JSONResponse) {}

}

// 其中:

// message: 定義數據結構

// service: 定義接口的名字，參數，

2.生成所需文件(服務器和客戶端均需要)

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

運行后會生成兩個文件（test_pb2.py, test_pb2_grpc.py）

3.編寫server端代碼

import time

import test_pb2

import test_pb2_grpc

import grpc

def test(request):

# 實際調用到的函數

json_response = test_pb2.JSONResponse()

json_response.rst_string = json.dumps({"ret":"Hi gRPC"})# 構造出proto文件中定義的返回值格式

return json_response

class OrderHandler(test_pb2_grpc.OrderHandlerServicer):

"""

gRPC請求會進入這個類中進行分發，根據客戶端請求的方法找到對應的處理方法

感興趣的可以打斷點查看request， context中的內容，他們包含了請求的所有信息

"""

def create_order(self, request, context):

return test(request, context)

def serve():

# 開啟gRPC服務，監聽特定端口，

server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))

test_pb2_grpc.add_OrderHandlerServicer_to_server(

OrderHandler(), server)

server.add_insecure_port("[::]:{}".format(12006))

server.start()

try:

while True:

time.sleep(186400)

except KeyboardInterrupt:

server.stop(0)

serve()

4.編寫客戶端代碼進行 測試 client.py

import grpc

import test_pb2_grpc

import test_pb2

channel = grpc.insecure_channel("127.0.0.1:12006")

stub = test_pb2_grpc.OrderHandlerStub(channel)

# 要完成請求需要先構造出proto文件中定義的請求格式

ret = stub.create_order(test_pb2.OrderRequest(phone="12990", price="50"))

print(ret.rst_string)

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

總結

以上是生活随笔為你收集整理的python rpc框架-python使用rpc框架gRPC的方法的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。