同时访问多个 gRPC 服务
问题:
在具有多个 gRPC 服务的服务器中在单个端口上可用,为什么从客户端拨号时需要为每个服务建立单独的连接?
<code class="go">func NewSubscriber() (c SubscriberRPC, err error) { c.conn, err = grpc.Dial("localhost:6000", grpc.WithInsecure()) if err != nil { log.Fatal(err) } c.client = pb.NewSubscriberServiceClient(c.conn) return } func NewDropper() (c DropperRPC, err error) { c.conn, err = grpc.Dial("localhost:6000", grpc.WithInsecure()) if err != nil { log.Fatal(err) } c.client = pb.NewDropperServiceClient(c.conn) return }</code>
解决方案:
与最初相反假设,可以通过单个连接访问同一服务器上的多个 gRPC 服务。这可以通过创建一个 grpc.ClientConn 并将其传递给多个 pb.New*Client 函数来实现。
<code class="go">func main() { cc, err := grpc.Dial("localhost:6000", grpc.WithInsecure()) if err != nil { log.Fatal(err) } c1 := pb.NewSubscriberServiceClient(cc) c2 := pb.NewDropperServiceClient(cc) }</code>
使用接口:
自定义客户端使用 pb.go 文件中提供的生成代码可以实现侧面体验。但是,生成的代码已经处理了所有必需的 RPC 功能。
为了方便起见,可以将多个服务组合到一个结构中:
<code class="go">type SubscriberDropper struct { pb.SubscriberServiceClient pb.DropperServiceClient } func main() { // ... as above ... sd := &SubscriberDropper{c1, c2} }</code>
以上是单连接可以访问多个gRPC服务吗?的详细内容。更多信息请关注PHP中文网其他相关文章!