python怎么玩rpc_python使用rpc服务

1.安装

# python3

pip install futures&＃61;&＃61;3.1.1

pip install grpcio protobuf grpcio-tools

# python2

pip install grpcio protobuf grpcio-tools

2.目录结构

.

&＃43;-- client

| &＃43;-- __init__.py

| &＃43;-- main.py

&＃43;-- proto

| data.proto

&＃43;-- proto_py

| &＃43;-- __init_.py

| &＃43;-- data_pd2.py

| &＃43;-- data_pb2_grpc.py

&＃43;-- server

| &＃43;-- __init_.py

| &＃43;-- main.py

client目录下的 main.py 实现了客户端用于发送数据并打印接收到 server 端处理后的数据

server 目录下的 main.py 实现了 server 端用于接收客户端发送的数据&＃xff0c;并对数据进行大写处理后返回给客户端

proto 包用于编写 proto 文件并生成 data 接口

proto_py 存储proto生成的py文件

3.数据

定义 gRPC 接口&＃xff1a;

syntax &＃61; "proto3";

package example;

service FormatData { //定义服务,用在rpc传输中

rpc DoFormat(Data) returns (Data){}

}

message Data {

string text &＃61; 1;

}

编译 protobuf&＃xff1a;

$ python -m grpc_tools.protoc -I. --python_out&＃61;. --grpc_python_out&＃61;. ./data.proto #在 proto 目录中执行编译&＃xff0c;会生成&＃xff1a;data_pb2.py 与 data_pb2_grpc.py

实现 server 端&＃xff1a;

#! /usr/bin/env python

# -*- coding: utf-8 -*-

# 实现了 server 端用于接收客户端发送的数据&＃xff0c;并对数据进行大写处理后返回给客户端

import grpc

import time

from concurrent import futures

from proto_py import data_pb2, data_pb2_grpc

_ONE_DAY_IN_SECONDS &＃61; 60 * 60 * 24

_HOST &＃61; &＃39;localhost&＃39;

_PORT &＃61; &＃39;8080&＃39;

# 实现一个派生类,重写rpc中的接口函数.自动生成的grpc文件中比proto中的服务名称多了一个Servicer

class FormatData(data_pb2_grpc.FormatDataServicer):

# 重写接口函数.输入和输出都是proto中定义的Data类型

def DoFormat(self, request, context):

str &＃61; request.text

return data_pb2.Data(text&＃61;str.upper()) # 返回一个类实例

def serve():

# 定义服务器并设置最大连接数,corcurrent.futures是一个并发库&＃xff0c;类似于线程池的概念

grpcServer &＃61; grpc.server(futures.ThreadPoolExecutor(max_workers&＃61;4)) # 创建一个服务器

data_pb2_grpc.add_FormatDataServicer_to_server(FormatData(), grpcServer) # 在服务器中添加派生的接口服务(自己实现了处理函数)

grpcServer.add_insecure_port(_HOST &＃43; &＃39;:&＃39; &＃43; _PORT) # 添加监听端口

grpcServer.start() # 启动服务器

try:

while True:

time.sleep(_ONE_DAY_IN_SECONDS)

except KeyboardInterrupt:

grpcServer.stop(0) # 关闭服务器

if __name__ &＃61;&＃61; &＃39;__main__&＃39;:

serve()

实现 client 端&＃xff1a;

#! /usr/bin/env python

# -*- coding: utf-8 -*-

# 实现了客户端用于发送数据并打印接收到 server 端处理后的数据

import grpc

from proto_py import data_pb2, data_pb2_grpc

_HOST &＃61; &＃39;localhost&＃39;

_PORT &＃61; &＃39;8080&＃39;

def run():

conn &＃61; grpc.insecure_channel(_HOST &＃43; &＃39;:&＃39; &＃43; _PORT) # 监听频道

client &＃61; data_pb2_grpc.FormatDataStub(channel&＃61;conn) # 客户端使用Stub类发送请求,参数为频道,为了绑定链接

response &＃61; client.DoFormat(data_pb2.Data(text&＃61;&＃39;hello,world!&＃39;)) # 返回的结果就是proto中定义的类

print("received: " &＃43; response.text)

if __name__ &＃61;&＃61; &＃39;__main__&＃39;:

run()

执行验证结果&＃xff1a;

先启动 server&＃xff0c;之后再执行 client

client 侧控制台如果打印的结果为&＃xff1a;“received: HELLO,WORLD!” &＃xff0c;证明 gRPC 接口定义成功

参考&＃xff1a;