澳门新蒲京娱乐

新蒲京官方下载 4
缓冲区问题,自定义函数
澳门新蒲京娱乐 19
16安装及配置澳门新蒲京娱乐:,12安装及配置

python调用RPC接口

https://grpc.io/docs/tutorials/basic/python.html

gRPC 简介:

gQX56PC 是一款高质量、开源的 汉兰达PC 框架,产自 谷歌(Google),基于 ProtoBuf
系列化协议实行付出,辅助四种语言(Golang、Python、Java等),本篇只介绍
Python 的 gGL450PC 使用。因为 gLX570PC 对 HTTP/2 协议的支持使其在 Android、IOS
等客户端后端服务的支出世界有所卓绝的前景。gPAJEROPC
提供了一种简易的方法来定义服务,同时客户端能够充裕利用 HTTP/2 stream
的特色,从而拉动节省带宽、下跌 TCP 的连年次数、节省CPU的利用等。

3.protobuf相关python依赖库

实践:

上面大家使用 g景逸SUVPC
定义1个接口,该接口完结对传播的数据进行大写的格式化处理。

  • 创设项目 python demo 工程:
![](https://upload-images.jianshu.io/upload_images/208550-bd34d08e0c12cdeb.png)

Paste\_Image.png
  1. client目录下的 main.py 完成了客户端用于发送数据并打字与印刷接收到 server
    端处理后的数据
  1. server 目录下的 main.py 完毕了 server
    端用于吸纳客户端发送的多少,并对数码举行大写处理后回去给客户端
  2. example 包用于编写 proto 文件并扭转 data 接口
  • 定义 gRPC 接口:

syntax = "proto3";
package example;
service FormatData {
  rpc DoFormat(Data) returns (Data){}
}
message Data {
  string text = 1;
}
  • 编译 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 + ':' + _PORT)
    grpcServer.start()
    try:
        while True:
            time.sleep(_ONE_DAY_IN_SECONDS)
    except KeyboardInterrupt:
        grpcServer.stop(0)

if __name__ == '__main__':
    serve()
  • 实现 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. 先运转 server,之后再实施 client
  1. client 侧控制台假设打字与印刷的结果为:“received: HELLO,WOENVISIONLD!” ,注解gLANDPC 接口定义成功

  • 交换能够加 QQ 群:397234385
  • 恐怕 QQ 扫码入群:

新蒲京官方下载 1

qq群.jpg

pip install
protobuf

新蒲京官方下载 ,安装:

  1. gRPC 的安装:

$ pip install grpcio

  1. 安装 ProtoBuf 相关的 python 依赖库:

$ pip install protobuf

  1. 安装 python grpc 的 protobuf 编译工具:

$ pip install grpcio-tools

 

 

会生成:data_pb2.py
与 data_pb2_grpc.py

 

syntax = "proto3";
package grpcDemo;

message HelloRequest {
   string name = 1;
}

message HelloReply {
   string message = 1;
}


service gRPC {
  rpc SayHello (HelloRequest) returns (HelloReply) {}
}

接口调用内容示例:

2.grpc的python
protobuf相关的编写翻译工具

rpc相关文书档案:

 

pip install
grpcio-tools

4.局地大规模原型的生成python类的集合:

 

 

 

pip
install grpcio

相关文章

No Comments, Be The First!
近期评论
    功能
    网站地图xml地图