我在服務(wù)器中實(shí)現(xiàn)了一個(gè) gRPC 流攔截器，如下所示：// Service define:// rpc searchProducts(google.protobuf.StringValue) returns (stream Product);func (w *wrappedStream) RecvMsg(m interface{}) error { log.Printf("%T, %v", m, m) return w.ServerStream.RecvMsg(m)}// Log print:// *wrapperspb.StringValue, 它可以%T正確使用打印消息類型，但是打印的消息值%v只是一個(gè)空白。我確定服務(wù)器收到了正確的消息，因?yàn)樗貜?fù)了客戶正確的信息。攔截器包裝器RecvMsg在客戶端也不工作。
1 回答
ITMISS
TA貢獻(xiàn)1871條經(jīng)驗(yàn) 獲得超8個(gè)贊
w.ServerStream.RecvMsg(m)將數(shù)據(jù)解組為，只需在調(diào)用m后移動(dòng)打印。RecvMsg()
func (w *wrappedStream) RecvMsg(m interface{}) error {
err := w.ServerStream.RecvMsg(m)
log.Printf("%T, %v", m, m)
return err
}
- 1 回答
- 0 關(guān)注
- 96 瀏覽
添加回答
舉報(bào)
0/150
提交
取消