client订阅服务器

client订阅服务器

简介

这里订阅的意思就是当服务器没有启动的时候，默认情况下，如果客户端如果直接发送一个调用的请求的话，会立刻抛出一个异常：

failed to connect to all addresses

但是如果我们调用了 subscribe 方法，此时就可以让客户端对服务端的启动进行等待，当服务端完成启动之后，客户端接收到启动的通知后，再对对应的 grpc 方法进行调用。

...
# 创建一个  channel
channel = grpc.insecure_channel(server_address)
# 添加 channel 的回调函数
channel.subscribe(wait_for_transient_failure)
...

如上所述的方法，我们称之为 wait-for-ready 的语义结构。

更加深入的理解就是： wait_for_ready 参数的使用。

代码书写

① 工具方法

1. 绑定套接字

首先是一个工具方法，用于绑定套接字：

@contextmanager
def get_free_loopback_tcp_port():if socket.has_ipv6:tcp_socket = socket.socket(socket.AF_INET6)else:tcp_socket = socket.socket(socket.AF_INET)tcp_socket.bind(('', 0))address_tuple = sockname()yield "localhost:%s" % (address_tuple[1])tcp_socket.close()

2. server’s interface

server 端接口的实现：

class Greeter(helloworld_pb2_grpc.GreeterServicer):def SayHello(self, request, unused_context):return helloworld_pb2