第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問(wèn)題,去搜搜看,總會(huì)有你想問(wèn)的

如何在使用gRPC服務(wù)器流式處理的云運(yùn)行中檢測(cè)已取消/丟失/關(guān)閉的連接?

如何在使用gRPC服務(wù)器流式處理的云運(yùn)行中檢測(cè)已取消/丟失/關(guān)閉的連接?

Go
茅侃侃 2022-08-24 10:27:39
我有一個(gè)服務(wù)器端流媒體RPC托管在Google Cloud Run上。具有以下原型定義:syntax = "proto3";package test.v1;service MyService {    // Subscribe to a stream of events.    rpc Subscribe (SubscribeRequest) returns (stream SubscribeResponse) {}}message SubscribeRequest {}message SubscribeResponse {}使用BloomRPC /grpcurl,當(dāng)我停止該方法時(shí),我得到一個(gè)事件,我可以用來(lái)優(yōu)雅地停止某些任務(wù)。以下是 Suscribe 方法的一個(gè)示例:stream.Context().Done()func (s *myService) Subscribe(req *pb.SubscribeRequest, stream pb.Instruments_SubscribeServer) error {        // Create a channel for this client.    ch := make(chan *pb.SubscribeResponse)        // Add the channel object 'ch' to a Global list of channels where we have a 'broadcaster' sending    // messages to all connected clients.    // TODO: pass to broadcaster client list.        for {        select {        case <-stream.Context().Done():            close(ch)            fmt.Println("Removed client from global list of channels")            return nil        case res := <-ch:            _ = stream.Send(res)        }    }}在客戶端,當(dāng)我在本地測(cè)試服務(wù)(即在Golang中運(yùn)行本地gRPC服務(wù)器)時(shí),使用BloomRPC / grpcurl,每當(dāng)我停止BloomRPC / grpcurl連接時(shí),我都會(huì)在通道上收到一條消息。這是預(yù)期的行為。stream.Context().Done()但是,以相同的方式(通過(guò)BloomRPC / grpcurl)在Cloud Run上運(yùn)行完全相同的代碼,我沒(méi)有收到消息 - 為什么這在Google Cloud Run上會(huì)有所不同?查看 Cloud Run 日志,對(duì) Subscribe 方法的調(diào)用基本上會(huì)“掛起”,直到請(qǐng)求達(dá)到其超時(shí)。stream.Context().Done()
查看完整描述

1 回答

?
慕村225694

TA貢獻(xiàn)1880條經(jīng)驗(yàn) 獲得超4個(gè)贊

我需要在 Cloud Run 中啟用 HTTP/2 連接才能正常工作。


查看完整回答
反對(duì) 回復(fù) 2022-08-24
  • 1 回答
  • 0 關(guān)注
  • 129 瀏覽
慕課專欄
更多

添加回答

舉報(bào)

0/150
提交
取消
微信客服

購(gòu)課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)