小编Hug*_*ugo的帖子

我如何知道另一端已收到我通过 gRPC 流发送的消息？

是否有一种构建方法可以在 gRPC 双向流式传输中执行此操作，或者我是否需要仅使用流式传输，然后发回响应？

原型文件：

service SimpleService {
rpc SimpleRPC (stream SimpleData) returns (stream SimpleData) {}
}

message SimpleData {
string msg = 1;
}

去代码：

client := pb.NewSimpleServiceClient(conn)
stream, err := client.SimpleRPC(context.Background())
waitc := make(chan struct{})

msg := &pb.SimpleData{"sup"}
go func() {
for {
   stream.Send(msg)
    }
}()
<-waitc
stream.CloseSend()