単一接続を介した複数の gRPC サービスへのアクセス

提供された例のように、共有アドレスをリッスンする同じサーバー上に複数の gRPC サービスが存在するシナリオでは、各サービスへの個別の接続を確立するのは冗長に思えるかもしれません。この記事の目的は、一般に個別の接続が必要な理由に対処し、単一の接続を利用して複数の gRPC サービスにアクセスする方法を検討することです。

複数の接続の必要性を排除する

ホストされているさまざまな gRPC サービスに効果的にアクセスするには同じサーバー上では、単一の gRPC クライアント接続を利用できます。このアプローチには、grpc.ClientConn オブジェクトを初期化し、それを個々のサービス クライアント ファクトリに渡して、同じ基礎となる接続を共有できるようにすることが含まれます。 cc、エラー := grpc.Dial("localhost:6000", grpc.WithInsecure()) エラーの場合 != nil { log.致命的(エラー) } c1 := pb.NewSubscriberServiceClient(cc) c2 := pb.NewDropperServiceClient(cc) }

func main() {
    cc, err := grpc.Dial("localhost:6000", grpc.WithInsecure())
    if err != nil {
        log.Fatal(err)
    }
    c1 := pb.NewSubscriberServiceClient(cc)
    c2 := pb.NewDropperServiceClient(cc)
}

pb.go ファイルで提供される生成された gRPC コードには、RPC の実行に必要な機能がすべて含まれています。したがって、各呼び出し中に特定のロジックを自動的に実行する必要がない限り、追加のクライアント側実装は必要ありません。

利便性のためのインターフェイスの使用 (オプション)

サービスが異なる場合の場合メソッド名を単一の構造体にマージすると、さらに便利になります。

type SubscriberDropper struct { pb.SubscriberServiceClient pb.DropperServiceClient } 関数 main() { // ... 上記と同様 ... sd := &SubscriberDropper{c1, c2} }

type SubscriberDropper struct {
    pb.SubscriberServiceClient
    pb.DropperServiceClient
}

func main() {
    // ... as above ...
    sd := &SubscriberDropper{c1, c2}
}