gRPC 在 Python中的应用
2017-11-26 00:18
253 查看
gRPC 简介:
gRPC 是一款高性能、开源的 RPC 框架,产自 Google,基于 ProtoBuf 序列化协议进行开发,支持多种语言(Golang、Python、Java等),本篇只介绍 Python 的 gRPC 使用。因为 gRPC 对 HTTP/2 协议的支持使其在 Android、IOS 等客户端后端服务的开发领域具有良好的前景。gRPC 提供了一种简单的方法来定义服务,同时客户端可以充分利用 HTTP2 stream 的特性,从而有助于节省带宽、降低 TCP 的连接次数、节省CPU的使用等。
安装:
gRPC 的安装:$ pip install grpcio
安装 ProtoBuf 相关的 python 依赖库:
$ pip install protobuf
安装 python grpc 的 protobuf 编译工具:
$ pip install grpcio-tools
实践:
下面我们使用 gRPC 定义一个接口,该接口实现对传入的数据进行大写的格式化处理。 * 创建项目 python demo 工程:
client目录下的 main.py 实现了客户端用于发送数据并打印接收到 server 端处理后的数据
server 目录下的 main.py 实现了 server 端用于接收客户端发送的数据,并对数据进行大写处理后返回给客户端
example 包用于编写 proto 文件并生成 data 接口
定义 gRPC 接口:
syntax = "proto3"; package example; service FormatData { rpc DoFormat(Data) returns (Data){} } message Data { string text = 1; }1
2
3
4
5
6
7
8
编译 protobuf:
$ python -m grpc_tools.protoc -I. –python_out=. –grpc_python_out=. ./data.proto #在 example 目录中执行编译,会生成:data_pb2.py 与 data_pb2_grpc.py
实现 server 端:
#! /usr/bin/env python # -*- coding: utf-8 -*- import grpc import time from concurrent import futures from example import data_pb2, data_pb2_grpc _ONE_DAY_IN_SECONDS = 60 * 60 * 24 _HOST = 'localhost' _PORT = '8080' class FormatData(data_pb2_grpc.FormatDataServicer): def DoFormat(self, request, context): str = request.text return data_pb2.Data(text=str.upper()) def serve(): grpcServer = grpc.server(futures.ThreadPoolExecutor(max_workers=4)) data_pb2_grpc.add_FormatDataServicer_to_server(FormatData(), grpcServer) grpcServer.add_insecure_port(_HOST + ':' + _HOST) grpcServer.start() try: while True: time.sleep(_ONE_DAY_IN_SECONDS) except KeyboardInterrupt: grpcServer.stop(0) if __name__ == '__main__': serve()1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
实现 client 端:
#! /usr/bin/env python # -*- coding: utf-8 -*- import grpc from example import data_pb2, data_pb2_grpc _HOST = 'localhost' _PORT = '8080' def run(): conn = grpc.insecure_channel(_HOST + ':' + _PORT) client = data_pb2_grpc.FormatDataStub(channel=conn) response = client.DoFormat(data_pb2.Data(text='hello,world!')) print("received: " + response.text) if __name__ == '__main__': run()1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
执行验证结果:
先启动 server,之后再执行 client
client 侧控制台如果打印的结果为:“received: HELLO,WORLD!” ,证明 gRPC 接口定义成功
相关文章推荐
- python __getattr__ 巧妙应用
- redis的哨兵(sentinel)配置和python程序应用示例
- 《python》学习笔记(Day6),采用MVC模式的Web应用例子
- Python基础应用---虚拟主机创建
- python3之数字(在实际应用中的数字--整数精度)
- python中map和reduce的应用
- python logging模块的多文件应用
- python测试框架及应用
- python dtrace 安装与应用
- Python网络编程Socket应用,并解决了error:10054错误
- dotcloud 托管 python web应用 第二章 mysql数据库操作
- python中的三角函数应用
- Python 数据排序和列表迭代和列表推导应用
- Python3 OpenCV应用
- python语法 5 应用guess 之 while True 、break
- python中event事件应用举例
- 使用 py2app 把 python 项目打包成mac下可执行的应用
- Python应用1
- 在Linux上使用Python和Flask创建你的第一个应用
- Python学习--threading应用和socket应用