概述
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()
新聞熱點
疑難解答