法国女人名字,童心幼儿园,莴笋叶的做法
本文介绍了在python中使用grpc的方法示例，分享给大家，具体如下：
使用protocol buffers的跨平台rpc系统。
安装
使用 pip
pip install grpcio pip install grpcio-tools googleapis-common-protos
grpc由两个部分构成，grpcio 和 grpc 工具， 后者是编译 protocol buffer 以及提供生成代码的插件。
使用
编写protocol buffer
使用 grpc 首先需要做的是设计 protocol buffer。新建一个 msg.proto 文件。
我要评论
syntax = "proto3";
service msgservice {
rpc getmsg (msgrequest) returns (msgresponse){}
}
message msgrequest {
string name = 1;
}
message msgresponse {
string msg = 1;
}
以上面的这个消息服务为例，首先是规定语法，这里使用的是 proto3 的语法。接着使用 service 关键字定义服务，grpc 提供4种 rpc 类型的服务，这里定义的是第一种单一请求单一回应，类似普通的函数调用，其他的使用到了 stream 关键字，将其放在括号里，代表这个数据是流数据。这个以后再来研究，本次先设计一个简单的rpc。
之后定义两个 message ，一个是请求的结构，一个是回应的结果。 这里表示这个数据结构是字符串，protocol buffer 还可以定义为 int32，int64，double，float 等等。这里赋予的初值可以随便填写，实际使用中，会被赋予新的值。
生成接口代码
因为之前安装好了一些辅助插件，使用这里直接可以生成。
python -m grpc_tools.protoc -i . --pythoout=. --grpc_python_out=. msg.proto
这里会生成两个文件， msg_pb2.py 和 msg_pb2_grpc.py 。这两个文件是为后续的服务端和客户端所用。前者是定义了一些变量，例如 _msgrequest 中就包含了请求函数的名字，可接受的变量，实际上还是 msg.proto 里定义的东西。
创建服务端
首先需要导入 rpc 必备的包，以及刚才生成的两个文件。
import grpc import msg_pb2 import msg_pb2_grpc
因为 rpc 应该长时间运行，考虑到性能，还需要用到并发的库。
from concurrent import futures import time _one_day_in_seconds = 60 * 60 * 24
在 server 中，主要是实现服务，按照 msg.proto 定义的，这里需要写一个服务类 msgservicer ，这个类需要实现之前定义的 getmsg 。
class msgservicer(msg_pb2_grpc.msgserviceservicer):
def getmsg(self, request, context):
print("received name: %s" % request.name)
return msg_pb2.msgresponse(msg='hello, %s!' % request.name)
getmsg 接收到的请求是在 request 中， msg.proto 中定义的 name 就是 request.name ，接着在 getmsg 中设计 msg.proto 中定义的 msgresponse 。
之后实现启动服务的部分即可。
def serve():
server = grpc.server(futures.threadpoolexecutor(max_workers=10))
msg_pb2_grpc.add_msgserviceservicer_to_server(msgservicer(), server)
server.add_insecure_port('[::]:50051')
server.start()
try:
while true:
time.sleep(_one_day_in_seconds)
except keyboardinterrupt:
server.stop(0)
通过并发库，将服务端放到多进程里运行。
完整 msg_server.py 代码如下
import grpc
import msg_pb2
import msg_pb2_grpc
from concurrent import futures
import time
_one_day_in_seconds = 60 * 60 * 24
class msgservicer(msg_pb2_grpc.msgserviceservicer):
def getmsg(self, request, context):
print("received name: %s" % request.name)
return msg_pb2.msgresponse(msg='hello, %s!' % request.name)
def serve():
server = grpc.server(futures.threadpoolexecutor(max_workers=10))
msg_pb2_grpc.add_msgserviceservicer_to_server(msgservicer(), server)
server.add_insecure_port('[::]:50051')
server.start()
try:
while true:
time.sleep(_one_day_in_seconds)
except keyboardinterrupt:
server.stop(0)
if __name__ == '__main__':
serve()
创建客户端
客户端相对简单一些，这里我写了一个简单的客户端。
import grpc
import msg_pb2
import msg_pb2_grpc
def run():
# note(grpc python team): .close() is possible on a channel and should be
# used in circumstances in which the with statement does not fit the needs
# of the code.
with grpc.insecure_channel('localhost:50051') as channel:
stub = msg_pb2_grpc.msgservicestub(channel)
response = stub.getmsg(msg_pb2.msgrequest(name='world'))
print("client received: " + response.msg)
if __name__ == '__main__':
run()
使用 grpc.insecure_channel('localhost:50051') 进行连接 服务端， 接着在这个 channel 上创建 stub ， 在 msg_pb2_grpc 里可以找到 msgservicestub 这个类相关信息。这个 stub 可以调用远程的 getmsg 函数。 msgrequest 中的 name 即 msg.proto 中定义的数据。在回应里可以得到 msg.proto 中定义的 msg 。
运行
首先运行 python msg_server.py 启动服务端，接着运行 python msg_client.py 机会看到客户端接收到了服务端传来的消息。以上就是一个简单的 rpc 的使用。
总结
这里只是简单的用了一下 grpc，关于另外三种模式，还在摸索。比起grpc，我感觉简单 restful 更讨我喜欢。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持移动技术网。
如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复
新手学习Python2和Python3中print不同的用法
Python基于os.environ从windows获取环境变量
网友评论