python使用rpc框架gRPC的方法

syntax = "proto3";
package order;
message OrderRequest {// 定義請(qǐng)求數(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ù)，

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

import time
import test_pb2
import test_pb2_grpc
import 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請(qǐng)求會(huì)進(jìn)入這個(gè)類(lèi)中進(jìn)行分發(fā)，根據(jù)客戶(hù)端請(qǐng)求的方法找到對(duì)應(yīng)的處理方法
  感興趣的可以打斷點(diǎn)查看request， context中的內(nèi)容，他們包含了請(qǐng)求的所有信息
  '''

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

 def serve():
   # 開(kāi)啟gRPC服務(wù)，監(jiān)聽(tīng)特定端口，
   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()

 import grpc
 import test_pb2_grpc
 import test_pb2

 channel = grpc.insecure_channel("127.0.0.1:12006")
 stub = test_pb2_grpc.OrderHandlerStub(channel)
 # 要完成請(qǐng)求需要先構(gòu)造出proto文件中定義的請(qǐng)求格式
 ret = stub.create_order(test_pb2.OrderRequest(phone="12990", price="50"))
 
 print(ret.rst_string)