1、安裝python所需的庫(kù)。

專(zhuān)注于為中小企業(yè)提供做網(wǎng)站、成都做網(wǎng)站服務(wù),電腦端+手機(jī)端+微信端的三站合一,更高效的管理,為中小企業(yè)云龍免費(fèi)做網(wǎng)站提供優(yōu)質(zhì)的服務(wù)。我們立足成都，凝聚了一批互聯(lián)網(wǎng)行業(yè)人才，有力地推動(dòng)了超過(guò)千家企業(yè)的穩(wěn)健成長(zhǎng)，幫助中小企業(yè)通過(guò)網(wǎng)站建設(shè)實(shí)現(xiàn)規(guī)模擴(kuò)充和轉(zhuǎn)變。

pip install gRPCio
pip install grpcio-tools  
pip install protobuf

2、定義gRPC接口。

syntax = "proto3";
option cc_generic_services = true;
//定義服務(wù)接口
service GrpcService {
    rpc hello (HelloRequest) returns (HelloResponse) {}  //一個(gè)服務(wù)中可以定義多個(gè)接口，也就是多個(gè)函數(shù)功能
}
//請(qǐng)求的參數(shù)
message HelloRequest {
    string data = 1;   //數(shù)字1,2是參數(shù)的位置順序，并不是對(duì)參數(shù)賦值
    Skill skill = 2;  //支持自定義的數(shù)據(jù)格式，非常靈活
};
//返回的對(duì)象
message HelloResponse {
    string result = 1;
    map map_result = 2; //支持map數(shù)據(jù)格式，類(lèi)似dict
};
message Skill {
    string name = 1;
};

3、用protoc和插件編譯生成語(yǔ)言代碼。

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

使用編譯工具將proto文件轉(zhuǎn)換成py文件，直接在當(dāng)前文件目錄下運(yùn)行上述代碼。

4、編寫(xiě)grpc服務(wù)器代碼。

#! /usr/bin/env python
# coding=utf8
import time
from concurrent import futures
import grpc
from gRPC_example import hello_pb2_grpc, hello_pb2
_ONE_DAY_IN_SECONDS = 60 * 60 * 24
class TestService(hello_pb2_grpc.GrpcServiceServicer):
    '''
    繼承GrpcServiceServicer,實(shí)現(xiàn)hello方法
    '''
    def __init__(self):
        pass
    def hello(self, request, context):
        '''
        具體實(shí)現(xiàn)hello的方法，并按照pb的返回對(duì)象構(gòu)造HelloResponse返回
        :param request:
        :param context:
        :return:
        '''
        result = request.data + request.skill.name + " this is gprc test service"
        list_result = {"12": 1232}
        return hello_pb2.HelloResponse(result=str(result),
                                       map_result=list_result)
def run():
    '''
    模擬服務(wù)啟動(dòng)
    :return:
    '''
    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
    hello_pb2_grpc.add_GrpcServiceServicer_to_server(TestService(),server)
    server.add_insecure_port('[::]:50052')
    server.start()
    print("start service...")
    try:
        while True:
            time.sleep(_ONE_DAY_IN_SECONDS)
    except KeyboardInterrupt:
        server.stop(0)
if __name__ == '__main__':
    run()

5、編寫(xiě)gRPC客戶(hù)端代碼。

#! /usr/bin/env python
# coding=utf8
import grpc
from gRPC_example import #! /usr/bin/env python
# coding=utf8
import grpc
from gRPC_example import hello_pb2_grpc, hello_pb2
def run():
    '''
    模擬請(qǐng)求服務(wù)方法信息
    :return:
    '''
    conn=grpc.insecure_channel('localhost:50052')
    client = hello_pb2_grpc.GrpcServiceStub(channel=conn)
    skill = hello_pb2.Skill(name="engineer")
    request = hello_pb2.HelloRequest(data="xiao gang", skill=skill)
    respnse = client.hello(request)
    print("received:",respnse.result)
if __name__ == '__main__':
    run()
def run():
    '''
    模擬請(qǐng)求服務(wù)方法信息
    :return:
    '''
    conn=grpc.insecure_channel('localhost:50052')
    client = hello_pb2_grpc.GrpcServiceStub(channel=conn)
    skill = hello_pb2.Skill(name="engineer")
    request = hello_pb2.HelloRequest(data="xiao gang", skill=skill)
    response = client.hello(request)
    print("received:",response.result)
if __name__ == '__main__':
    run()

6、調(diào)用測(cè)試。

首先啟動(dòng)運(yùn)行服務(wù)器的代碼，然后啟動(dòng)運(yùn)行客戶(hù)端的代碼。

以上就是Python搭建gRPC服務(wù)的方法，希望對(duì)大家有所幫助。更多Python學(xué)習(xí)指路：創(chuàng)新互聯(lián)Python教程

本文教程操作環(huán)境：windows7系統(tǒng)、Python 3.9.1，DELL G3電腦。

新聞標(biāo)題：創(chuàng)新互聯(lián)Python教程：Python如何搭建gRPC服務(wù)
文章分享：http://uogjgqi.cn/article/cddddhe.html