概述
gRPC 是谷歌開源的一個(gè)rpc（遠(yuǎn)程程序調(diào)用）框架，可以輕松實(shí)現(xiàn)跨語言，跨平臺(tái)編程，其采用gRPC協(xié)議（基于HTTP2）。
rpc：
remote procedure call， 翻譯過來就是是遠(yuǎn)程程序調(diào)用。具體來說，就是客戶端c1需要調(diào)用服務(wù)器s1上的某個(gè)方法（函數(shù)），得到相應(yīng)的返回值并傳遞給c1。
gRPC協(xié)議
要說gRPC協(xié)議需要先了解HTTP2， 雖然HTTP1.X 協(xié)議至今仍是主流協(xié)議，但是隨著我們對性能要求越來越高，和web規(guī)模的不斷擴(kuò)大，HTTP2就應(yīng)運(yùn)而生。
在這里，我們只需要知道其性能是高于現(xiàn)有的HTTP1就好了，感興趣的朋友可以深入了解HTTP2。
使用原因
在上家公司，因?yàn)橹暗捻?xiàng)目有一下幾個(gè)痛點(diǎn)，所以決定采用rpc框架：
所以我們花了點(diǎn)時(shí)間處理這些問題，將訂單，用戶等模塊拆開，方便獨(dú)立部署，獨(dú)立升級(jí)，獨(dú)立維護(hù)，這樣可以大大提高維護(hù)效率和項(xiàng)目的伸縮性。
使用方法
1.準(zhǔn)備.proto文件
syntax = "proto3";package order;message OrderRequest {// 定義請求數(shù)據(jù) string phone = 1; string price = 2; map<string, string> request_arg = 3;//便于字段擴(kuò)展 } 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
運(yùn)行后會(huì)生成兩個(gè)文件（test_pb2.py, test_pb2_grpc.py）
3.編寫server端代碼
import timeimport test_pb2import test_pb2_grpcimport grpc def test(request): # 實(shí)際調(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請求會(huì)進(jìn)入這個(gè)類中進(jìn)行分發(fā)，根據(jù)客戶端請求的方法找到對應(yīng)的處理方法 感興趣的可以打斷點(diǎn)查看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í)有所幫助，也希望大家多多支持VEVB武林網(wǎng)。
新聞熱點(diǎn)
疑難解答
圖片精選
