python使用rpc框架gRPC的方法

更新時間：2018年08月24日 14:38:49 作者：余震杰yzj

這篇文章主要為大家詳細(xì)介紹了python使用rpc框架gRPC的方法，具有一定的參考價值，感興趣的小伙伴們可以參考一下

概述

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

rpc：

remote procedure call，翻譯過來就是是遠(yuǎn)程程序調(diào)用。具體來說，就是客戶端c1需要調(diào)用服務(wù)器s1上的某個方法（函數(shù)），得到相應(yīng)的返回值并傳遞給c1。

gRPC協(xié)議

要說gRPC協(xié)議需要先了解HTTP2，雖然HTTP1.X 協(xié)議至今仍是主流協(xié)議，但是隨著我們對性能要求越來越高，和web規(guī)模的不斷擴大，HTTP2就應(yīng)運而生。
在這里，我們只需要知道其性能是高于現(xiàn)有的HTTP1就好了，感興趣的朋友可以深入了解HTTP2。

使用原因

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

項目的app，網(wǎng)站，m站，小程序等是獨立項目，一處改，處處改，效率低下
所有模塊在一個項目里面，維護(hù)起來需要熟悉所有業(yè)務(wù)流程，維護(hù)難度加大
擴展性不強，應(yīng)付高一點的并發(fā)需要將項目所有東西復(fù)制到新加服務(wù)器，運行所有模塊，包括并發(fā)量不高的模塊，造成資源浪費

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

使用方法

1.準(zhǔn)備.proto文件

syntax = "proto3";
package order;
message OrderRequest {// 定義請求數(shù)據(jù)
   string phone = 1;
   string price = 2;
   map<string, string> request_arg = 3;//便于字段擴展
 }

 message JSONResponse{// 定義返回格式
   string rst_string = 1; //統(tǒng)一返回json字符串作處理
   }

 service OrderHandler {
  // format a list of events.
  rpc create_order (OrderRequest) returns (JSONResponse) {}
 }
// 其中:
// message: 定義數(shù)據(jù)結(jié)構(gòu)<br>
// service: 定義接口的名字，參數(shù)，

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

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):
  # 實際調(diào)用到的函數(shù)
  json_response = test_pb2.JSONResponse()
  json_response.rst_string = json.dumps({"ret":"Hi gRPC"})# 構(gòu)造出proto文件中定義的返回值格式
  return json_response
  
 class OrderHandler(test_pb2_grpc.OrderHandlerServicer):
  '''
  gRPC請求會進(jìn)入這個類中進(jìn)行分發(fā)，根據(jù)客戶端請求的方法找到對應(yīng)的處理方法
  感興趣的可以打斷點查看request， context中的內(nèi)容，他們包含了請求的所有信息
  '''

   def create_order(self, request, context):
     return test(request, context)

 def serve():
   # 開啟gRPC服務(wù)，監(jiān)聽特定端口，
   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.編寫客戶端代碼進(jìn)行測試 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)
 # 要完成請求需要先構(gòu)造出proto文件中定義的請求格式
 ret = stub.create_order(test_pb2.OrderRequest(phone="12990", price="50"))
 
 print(ret.rst_string)

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: