【发布时间】:2019-03-30 14:56:08
【问题描述】:
我正在尝试在this example 之后创建一个 gRPC python 服务器-客户端应用程序,但我无法将服务器放在我的代码上处于侦听状态。添加几乎与示例完全相同的代码并运行start 方法后,指定的端口上没有任何内容正在侦听。我的代码是:
#!/usr/bin/env python3
# -*- coding: utf-8 -*-
import grpc
import interface_pb2
import interface_pb2_grpc
from concurrent import futures
import time
# some other imports...
class GrpcInterface(interface_pb2_grpc.ManipulaMapaServicer):
def CriaItem(self, request, context):
# do stuff...
def LeItem(self, request, context):
# do stuff...
def AtualizaItem(self, request, context):
# do stuff...
def DeletaItem(self, request, context):
# do stuff...
_ONE_DAY_IN_SECONDS = 60 * 60 * 24
def main():
server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
interface_pb2_grpc.add_ManipulaMapaServicer_to_server(GrpcInterface(), server)
print('Vai iniciar o servidor gRPC na porta ' + str(8888))
server.add_insecure_port('[::]:' + str(8888))
server.start()
try:
while True:
time.sleep(_ONE_DAY_IN_SECONDS)
except KeyboardInterrupt:
server.stop(0)
if __name__ == '__main__':
try:
main()
except Exception as e:
print('Erro ao rodar servidor: ')
print(str(e))
interface_pb2_grpc.ManipulaMapaServicer 的代码当然是根据我的interface.proto 自动生成的(使用命令python3 -m grpc_tools.protoc -I . --python_out=. --grpc_python_out=. interface.proto):
syntax = "proto3";
message msgItem {
int64 chave = 1;
string valor = 2;
}
message status {
string resposta = 1;
msgItem itemResposta = 2;
}
service ManipulaMapa {
rpc CriaItem (msgItem) returns (status) {}
rpc LeItem (msgItem) returns (msgItem) {}
rpc AtualizaItem (msgItem) returns (status) {}
rpc DeletaItem (msgItem) returns (status) {}
}
执行到达main 内的while True: 循环,但端口8888 上没有运行服务器。这里有什么问题?顺便说一句,这个问题与this 没有重复,因为在最后一个问题中,问题是由在start 方法之后运行的垃圾收集器引起的。
【问题讨论】:
-
你在什么操作系统上运行这个?
-
在 Devuan Linux 上
-
我已经启动了一个虚拟机并试用了你的脚本,它正在运行。当然,这是一个基本的安装。也许,您可以尝试使用更高的端口号?你是如何尝试连接它的?
nc?您是在同一台机器上尝试还是在另一台主机上尝试? -
我没有尝试连接它,因为它没有在听。如果我运行
netstat -tulpn它不会出现在那里 -
您在调用服务器时是否遇到任何错误?另外,您可以在调用服务器并共享回溯时尝试 strace 命令吗?干杯,Dheeraj
标签: python python-3.x protocol-buffers grpc grpc-python