如何通过长轮询实现 gRPC 服务器到客户端的广播？

gRPC 服务器到客户端广播

在 gRPC 中，将事件从服务器广播到多个连接的客户端时会出现常见的挑战。提出的问题寻求有关如何使用流实现此目的的指导，特别是服务器知道谁连接以及如何寻址每个客户端。

利用长轮询方法

流的另一种解决方案是实现长轮询方法。此技术涉及客户端向服务器发送连续请求，从而保持连接处于活动状态。当服务器上发生事件时，它会通知所有等待的客户端，提示它们结束并创建新请求。

长轮询的代码示例

以下代码示例说明了如何在 Python 中实现长轮询：

.PROTO 定义

<code class=".PROTO">service Updater {
    rpc GetUpdates(GetUpdatesRequest) returns (GetUpdatesResponse);
}

message GetUpdatesRequest {
    int64 last_received_update = 1;
}

message GetUpdatesResponse {
    repeated Update updates = 1;
    int64 update_index = 2;
}

message Update {
    // Your update structure
}</code>

服务器代码

<code class="python">class UpdaterServer(UpdaterServicer):
    def __init__(self):
        self.condition = threading.Condition()
        self.updates = []

    def post_update(self, update):
        with self.condition:
            # Remove old updates after some time
            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:]
            response = GetUpdatesResponse()
            for update in new_updates:
                response.updates.add().CopyFrom(update)
            response.update_index = req.last_received_update + len(new_updates)
            return response</code>

客户端中的单独线程

<code class="python">request = GetUpdatesRequest()
request.last_received_update = -1
while True:
    stub = UpdaterStub(channel)
    try:
        response = stub.GetUpdates(request, timeout=60*10)
        handle_updates(response.updates)
        request.last_received_update = response.update_index
    except grpc.FutureTimeoutError:
        pass</code>

此示例演示客户端如何使用长轮询来接收更新，而无需服务器启动流。

以上是如何通过长轮询实现 gRPC 服务器到客户端的广播？的详细内容。更多信息请关注PHP中文网其他相关文章！