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<string, int32> map_result = 2; //支持map數(shù)據(jù)格式，類似dict
};
​
message Skill {
    string name = 1;
};

#! /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()

#! /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()