使用gRPC在不同goroutine中进行客户端/存根操作

从现在开始，我们要努力学习啦！今天我给大家带来《使用gRPC在不同goroutine中进行客户端/存根操作》，感兴趣的朋友请继续看下去吧！下文中的内容我们主要会涉及到等等知识点，如果在阅读本文过程中有遇到不清楚的地方，欢迎留言呀！我们一起讨论，一起学习！

我正在尝试 protobuf 和 grpc，并正在学习 go 基础教程：https://www.grpc.io/docs/languages/go/basics/

从我在有关 clientconn 的文档中看到的内容来看，同时使用相同的 clientconn 似乎是安全的。但我对创建的存根/客户端无能为力......

假设我通过 http post 请求接收数据，我想通过 grpc 作为 protobuf 转发该数据，然后响应 http 请求。我应该在每次处理 http 请求时创建一个客户端/存根，还是可以在设置 http 服务器时创建客户端/存根并在设置 http 处理程序时传入客户端/存根？

示例：我认为这没问题

var opts []grpc.dialoption
conn, err := grpc.dial("127.0.0.1:1234", opts...)
if err != nil {
    log.panic(err)
}
defer conn.close()
grpcservice := service.service{grpc: conn}
http.handlefunc("/", util.validaterequest(grpcservice.handleroot))

// listen to port
http.listenandserve(fmt.sprintf("%s:%d", viper.getstring("server.address"), viper.getint32("server.port")), nil)

但是这个怎么样

var opts []grpc.DialOption
conn, err := grpc.Dial("127.0.0.1:1234", opts...)
if err != nil {
    log.Panic(err)
}
defer conn.Close()
client := pb.NewEventShipperClient(conn)
grpcService := service.Service{GRPC: conn, Client: client}
http.HandleFunc("/", util.ValidateRequest(grpcService.HandleRoot))

// listen to port
http.ListenAndServe(fmt.Sprintf("%s:%d", viper.GetString("server.address"), viper.GetInt32("server.port")), nil)

正确答案

线程安全（“同时运行它是否安全”）在 Generated-code reference 中有介绍：

线程安全：请注意，客户端 RPC 调用和服务器端 RPC 处理程序是线程安全的，并且应该在并发 goroutine 上运行。但还要注意，对于各个流，传入和传出数据是双向的，但是串行的；所以例如各个流不支持并发读取或并发写入（但读取与写入可以安全并发）。

所以，是的，pb.NewEventShipperClient(conn) 返回的 struct 上的方法可以同时调用。

您还可以通过查看 pb.NewEventShipperClient 的实现来亲自检查这一点。目前（我猜这可能会改变）唯一的成员变量将是一个接口（cc grpc.ClientConnInterface - 由 *ClientConn 实现），每个方法都使用与 Invoke 的连接进行 gRPC 调用。

但是请注意，您在实现 service.Service 时需要小心，以确保它也是线程安全的，并注意有关流的警告。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《使用gRPC在不同goroutine中进行客户端/存根操作》文章吧，也可关注golang学习网公众号了解相关技术文章。