启动 server
一旦你实现了所有的方法,下一步就是启动一个 gRPC 服务器,以便客户端可以使用你的服务。
def serve():
server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
route_guide_pb2_grpc.add_RouteGuideServicer_to_server(RouteGuideServicer(), server)
server.add_insecure_port("[::]:50051")
server.start()
server.wait_for_termination()
server 的 start()
方法是非阻塞的。一个新线程会被启动用于处理请求。调用 server.start()
的线程此刻没有其他事情可做,你可以主动调用 server.wait_for_termination()
来显式地阻塞调用线程直到 server 终止。
Loading...
> 此处输出代码运行结果