gRPC阅读日记（七）客户端的RPC构建

Client-side streaming RPC

客户端的流式方法RecordRoute跟服务端的相似，除了我们只传了context，获取到RouteGuide_RecordRouteClient流对象回来。流可以让我们既可以写也可以读消息。

// Create a random number of random points
r := rand.New(rand.NewSource(time.Now().UnixNano()))
pointCount := int(r.Int31n(100)) + 2 // Traverse at least two points
var points []*pb.Point
for i := 0; i < pointCount; i++ {
  points = append(points, randomPoint(r))
}
log.Printf("Traversing %d points.", len(points))
stream, err := client.RecordRoute(context.Background())
if err != nil {
  log.Fatalf("%v.RecordRoute(_) = _, %v", client, err)
}
for _, point := range points {
  if err := stream.Send(point); err != nil {
    log.Fatalf("%v.Send(%v) = %v", stream, point, err)
  }
}
reply, err := stream.CloseAndRecv()
if err != nil {
  log.Fatalf("%v.CloseAndRecv() got error %v, want %v", stream, err, nil)
}
log.Printf("Route summary: %v", reply)

RouteGuide_RecordRouteClient有Send方法，可以发送请求给server，一旦我们用Send发完了请求，让gRPC知道我们已经结束写阶段，希望获取响应了，就能从CloseAndRecv()返回的err得治RPC状态。如果状态是nil，那么CloseAndRecv()返回的就是有效的服务响应。

Bidirectional streaming RPC

双向流RPC RouteChat()，使用了goroutine去对steam做读，然后主的goroutine去做写，最后client端洗完了，调用了CloseSend()最后还做了线程同步，等goroutine都结束。

stream, err := client.RouteChat(context.Background())
waitc := make(chan struct{})
go func() {
  for {
    in, err := stream.Recv()
    if err == io.EOF {
      // read done.
      close(waitc)
      return
    }
    if err != nil {
      log.Fatalf("Failed to receive a note : %v", err)
    }
    log.Printf("Got message %s at point(%d, %d)", in.Message, in.Location.Latitude, in.Location.Longitude)
  }
}()
for _, note := range notes {
  if err := stream.Send(note); err != nil {
    log.Fatalf("Failed to send a note: %v", err)
  }
}
stream.CloseSend()
<-waitc

外加再补充一句，客户端和服务端请求和响应的消息顺序一直是有序的，但是他们处理消息的顺序可以in any orider。这句话基础教程里提了好多次了

下一期讲gRPC basics tutorial的总结， respect！！！

Reference

https://grpc.io/docs/languages/go/basics/