The C based gRPC (C++, Python, Ruby, Objective-C, PHP, C#)
https://grpc.io/
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
93 lines
3.0 KiB
93 lines
3.0 KiB
""" |
|
Author: Zhongying Wang |
|
Email: kerbalwzy@gmail.com |
|
License: MPL2 |
|
DateTime: 2019-08-13T23:30:00Z |
|
PythonVersion: Python3.6.3 |
|
""" |
|
import grpc |
|
import time |
|
from customGrpcPackages import demo_pb2, demo_pb2_grpc |
|
|
|
# Constants |
|
PyGrpcServerAddress = "127.0.0.1:23334" |
|
ClientId = 1 |
|
|
|
|
|
# 简单模式 |
|
# Unary |
|
def simple_method(stub): |
|
print("--------------Call SimpleMethod Begin--------------") |
|
req = demo_pb2.Request(Cid=ClientId, ReqMsg="called by Python client") |
|
resp = stub.SimpleMethod(req) |
|
print(f"resp from server({resp.Sid}), the message={resp.RespMsg}") |
|
print("--------------Call SimpleMethod Over---------------") |
|
|
|
|
|
# 客户端流模式（在一次调用中, 客户端可以多次向服务器传输数据, 但是服务器只能返回一次响应） |
|
# Client Streaming (In a single call, the client can transfer data to the server several times, |
|
# but the server can only return a response once.) |
|
def c_stream_method(stub): |
|
print("--------------Call CStreamMethod Begin--------------") |
|
|
|
# 创建一个生成器 |
|
# create a generator |
|
def req_msgs(): |
|
for i in range(5): |
|
req = demo_pb2.Request(Cid=ClientId, ReqMsg=f"called by Python client, message: {i}") |
|
yield req |
|
|
|
resp = stub.CStreamMethod(req_msgs()) |
|
print(f"resp from server({resp.Sid}), the message={resp.RespMsg}") |
|
print("--------------Call CStreamMethod Over---------------") |
|
|
|
|
|
# 服务端流模式（在一次调用中, 客户端只能一次向服务器传输数据, 但是服务器可以多次返回响应） |
|
# Server Streaming (In a single call, the client can only transmit data to the server at one time, |
|
# but the server can return the response many times.) |
|
def s_stream_method(stub): |
|
print("--------------Call SStreamMethod Begin--------------") |
|
req = demo_pb2.Request(Cid=ClientId, ReqMsg="called by Python client") |
|
resp_s = stub.SStreamMethod(req) |
|
for resp in resp_s: |
|
print(f"recv from server({resp.Sid}, message={resp.RespMsg})") |
|
|
|
print("--------------Call SStreamMethod Over---------------") |
|
|
|
|
|
# 双向流模式 (在一次调用中, 客户端和服务器都可以向对方多次收发数据) |
|
# Bidirectional Streaming (In a single call, both client and server can send and receive data |
|
# to each other multiple times.) |
|
def twf_method(stub): |
|
print("--------------Call TWFMethod Begin---------------") |
|
|
|
# 创建一个生成器 |
|
# create a generator |
|
def req_msgs(): |
|
for i in range(5): |
|
req = demo_pb2.Request(Cid=ClientId, ReqMsg=f"called by Python client, message: {i}") |
|
yield req |
|
time.sleep(1) |
|
|
|
resp_s = stub.TWFMethod(req_msgs()) |
|
for resp in resp_s: |
|
print(f"recv from server({resp.Sid}, message={resp.RespMsg})") |
|
|
|
print("--------------Call TWFMethod Over---------------") |
|
|
|
|
|
def main(): |
|
with grpc.insecure_channel(PyGrpcServerAddress) as channel: |
|
stub = demo_pb2_grpc.GRPCDemoStub(channel) |
|
|
|
simple_method(stub) |
|
|
|
c_stream_method(stub) |
|
|
|
s_stream_method(stub) |
|
|
|
twf_method(stub) |
|
|
|
|
|
if __name__ == '__main__': |
|
main()
|
|
|