gRPC 中的广播：服务器到客户端通信

建立 gRPC 连接时，通常需要将事件或更新从服务器广播到客户端连接的客户端。为了实现这一点，可以采用各种方法。

Stream Observables

一种常见的方法是利用服务器端流。每个连接的客户端都与服务器建立自己的流。然而，直接订阅其他服务器客户端流是不可行的。

长轮询

另一种选择是实现长轮询方法。这涉及让客户端定期轮询服务器，检查新的更新。收到更新后，客户端将收到响应并等待下一个轮询间隔。

示例实现

以下是如何实现长轮询的示例使用 gRPC:

服务器端代码

import threading

class UpdaterServer:
    def __init__(self):
        self.condition = threading.Condition()
        self.updates = []

    def post_update(self, update):
        with self.condition:
            self.updates.append(updates)
            self.condition.notify_all()

    def GetUpdates(self, req, context):
        with self.condition:
            while self.updates[req.last_received_update   1:] == []:
                self.condition.wait()
            new_updates = self.updates[req.last_received_update   1:]
            return GetUpdatesResponse(
                updates=new_updates,
                update_index=req.last_received_update   len(new_updates),
            )

客户端代码（单独线程）

from threading import Event

def handle_updates(updates):
    pass

event = Event()
request = GetUpdatesRequest(last_received_update=-1)

while not event.is_set():
    try:
        stub = UpdaterStub(channel)
        response = stub.GetUpdates(request, timeout=60*10)
        handle_updates(response.updates)
        request.last_received_update = response.update_index
    except grpc.FutureTimeoutError:
        pass

通过实现这种方法，连接的客户端可以连续地从服务器检索更新。