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

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

如何在攔截器中安全地將值添加到 grpc ServerStream

如何在攔截器中安全地將值添加到 grpc ServerStream

Go
拉風(fēng)的咖菲貓 2022-05-23 17:23:16
我的 grpc 服務(wù)器有一個(gè)日志攔截器,并且想向元數(shù)據(jù)添加一個(gè)值(我想在整個(gè)生命周期內(nèi)跟蹤請求):func (m *middleware) loggingInterceptor(srv interface{},    ss grpc.ServerStream,    info *grpc.StreamServerInfo,    handler grpc.StreamHandler)     md, ok := metadata.FromIncomingContext(ss.Context())    if !ok {        return errors.New("could not get metadata from incoming stream context")    }    // add the transaction id to the metadata so that business logic can track it    md.Append("trans-id", "some-transaction-id")    // call the handler func    return handler(srv, ss)}但文檔FromIncomingContext聲明:// FromIncomingContext returns the incoming metadata in ctx if it exists.  The// returned MD should not be modified. Writing to it may cause races.// Modification should be made to copies of the returned MD.好的,所以我看一下復(fù)制功能并復(fù)制元數(shù)據(jù):mdCopy := md.Copy()mdCopy.Append("trans-id", "some-transaction-id")并想“我如何將這個(gè)元數(shù)據(jù)附加回ServerStream上下文?”,然后我檢查是否有一些ss.SetContext(newCtx),但我沒有看到任何類似的東西。我是從錯(cuò)誤的角度考慮這個(gè)問題,還是我錯(cuò)過了其他東西?
查看完整描述

2 回答

?
人到中年有點(diǎn)甜

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

您需要使用NewIncomingContext在流中創(chuàng)建當(dāng)前上下文的副本。

然后,您必須創(chuàng)建一個(gè)wrappedStream覆蓋Context方法 in的類型ServerStream以返回修改后的context. 您需要將其傳遞wrappedStreamhandler您在攔截器中收到的。

你可以在這里看到一個(gè)例子(它在這里覆蓋了其他方法,但想法是一樣的): https ://github.com/grpc/grpc-go/blob/master/examples/features/interceptor/server/main .go#L106-L124

希望這可以幫助。


查看完整回答
反對(duì) 回復(fù) 2022-05-23
?
慕運(yùn)維8079593

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

您可以創(chuàng)建自己的 ServerStream 實(shí)現(xiàn),用您自己的上下文覆蓋 Context() 方法,或者在 grpc 包中有一個(gè)結(jié)構(gòu)WrappedServerStream (github.com/grpc-ecosystem/go-grpc-middleware),您可以在其中傳遞上下文和原始服務(wù)器流對(duì)象并在其中使用它handler。


例子:


    // This methods get the current context, and creates a new one

    newContext, err := interceptor.authorize(ss.Context(), info.FullMethod)

    if err != nil {

        log.Printf("authorization failed: %v", err)

        return err

    }


    

    err = handler(srv, &grpc_middleware.WrappedServerStream{

        ServerStream:   ss,

        WrappedContext: newContext,

    })


查看完整回答
反對(duì) 回復(fù) 2022-05-23
  • 2 回答
  • 0 關(guān)注
  • 156 瀏覽

添加回答

舉報(bào)

0/150
提交
取消
微信客服

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

幫助反饋 APP下載

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

公眾號(hào)

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