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

透過實作這種方法，連線的客戶端可以連續地從伺服器檢索更新。