def grpc_server(grpc_addr):
server = grpc.server(futures.ThreadPoolExecutor(max_workers=2))
hello_pb2_grpc.add_HelloServicer_to_server(rpc.HelloGRpcServer(), server)
for addr in grpc_addr:
server.add_insecure_port(addr)
server.start()
yield server
server.stop(0)
评论列表
文章目录