国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Python > 正文

python使用rpc框架gRPC的方法

2020-02-15 22:48:30
字體:
來源:轉載
供稿:網友

概述

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<string, string> request_arg = 3;//便于字段擴展 } message JSONResponse{// 定義返回格式   string rst_string = 1; //統一返回json字符串作處理   } service OrderHandler {  // format a list of events.  rpc create_order (OrderRequest) returns (JSONResponse) {} }// 其中:// message: 定義數據結構<br>// service: 定義接口的名字,參數,

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

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

運行后會生成兩個文件(test_pb2.py, test_pb2_grpc.py)

3.編寫server端代碼

import timeimport test_pb2import test_pb2_grpcimport 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()            
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 东丽区| 鄂伦春自治旗| 仙游县| 塘沽区| 盐津县| 鄂托克旗| 都昌县| 绥中县| 壤塘县| 清流县| 耒阳市| 合作市| 滁州市| 梧州市| 内江市| 石嘴山市| 霍林郭勒市| 武清区| 靖边县| 丹巴县| 德清县| 兴山县| 富顺县| 长泰县| 团风县| 武义县| 临朐县| 错那县| 汾阳市| 柘城县| 平凉市| 广德县| 安阳县| 云南省| 万源市| 仙桃市| 榆中县| 庆安县| 察哈| 兴山县| 潼关县|