.NET クライアントを使用して gRPC サービスを呼び出す

[アーティクル]
11/30/2023

.NET gRPC クライアントライブラリは、Grpc.Net.Client NuGet パッケージで提供されています。このドキュメントでは、以下の方法について説明します。

gRPC サービスを呼び出すように gRPC クライアントを構成します。
unary、サーバーストリーミング、クライアントストリーミング、双方向ストリーミングの各メソッドに対する gRPC 呼び出しを行います。

gRPC クライアントを構成する

gRPC クライアントは、.proto ファイルから生成される具象クライアント型です。具象 gRPC クライアントには、.proto ファイル内の gRPC サービスに変換するためのメソッドが含まれます。たとえば、Greeter というサービスにより、サービスを呼び出すメソッドを含む GreeterClient 型が生成されます。

gRPC クライアントはチャネルから作成されます。まず GrpcChannel.ForAddress を使用してチャネルを作成し、次にそのチャネルを使用して、gRPC クライアントを作成します。

var channel = GrpcChannel.ForAddress("https://localhost:5001");
var client = new Greet.GreeterClient(channel);

チャネルは、gRPC サービスへの有効期限が長い接続を表します。チャネルが作成されるときには、サービスの呼び出しに関連するオプションを使用して構成されます。たとえば呼び出しを行うために使用される HttpClient の場合、GrpcChannelOptions で送受信メッセージの最大サイズとログ記録を指定し、GrpcChannel.ForAddress と共に使用することができます。オプションの完全な一覧については、クライアント構成のオプションに関するページを参照してください。

var channel = GrpcChannel.ForAddress("https://localhost:5001");

var greeterClient = new Greet.GreeterClient(channel);
var counterClient = new Count.CounterClient(channel);

// Use clients to call gRPC services

TLS の構成

gRPC クライアントでは、呼び出されたサービスと同じ接続レベルのセキュリティを使用する必要があります。 gRPC クライアントのトランスポート層セキュリティ (TLS) は、gRPC チャネルの作成時に構成されます。 gRPC クライアントによってサービスが呼び出され、そのチャネルとサービスの接続レベルのセキュリティが一致しなかった場合、エラーがスローされます。

TLS を使用するように gRPC チャネルを構成するには、サーバーアドレスが https で始まることを確認します。たとえば、GrpcChannel.ForAddress("https://localhost:5001") では HTTPS プロトコルが使用されます。 gRPC チャネルでは、TLS によってセキュリティで保護された接続が自動的にネゴシエートされ、安全な接続を使用して gRPC 呼び出しが行われます。

ヒント

gRPC では、TLS 経由のクライアント証明書認証がサポートされています。 gRPC チャンネルを使用したクライアント証明書の構成については、「ASP.NET Core のための gRPC での認証と承認」を参照してください。

セキュリティで保護されていない gRPC サービスを呼び出すには、サーバーアドレスが http で始まることを確認します。たとえば、GrpcChannel.ForAddress("http://localhost:5000") では HTTP プロトコルが使用されます。 .NET Core 3.1 では、.NET クライアントで安全でない gRPC サービスを呼び出す場合、追加の構成が必要です。

クライアントパフォーマンス

チャネルおよびクライアントのパフォーマンスと使用状況:

チャネルの作成は、コストのかかる操作となる場合があります。チャネルを gRPC 呼び出しのために再利用すると、パフォーマンス上のメリットがあります。
チャネルは、サーバーへの接続を管理します。接続が閉じられたり失われたりした場合、チャネルは次回の gRPC 呼び出し時に自動的に再接続します。
gRPC クライアントはチャネルを使用して作成されます。 gRPC クライアントは軽量なオブジェクトであり、キャッシュしたり再利用したりする必要はありません。
異なる種類のクライアントを含め、1 つチャネルから複数の gRPC クライアントを作成できます。
チャネルおよびそのチャネルから作成されたクライアントは、複数のスレッドで安全に使用できます。
チャネルから作成されたクライアントは、複数の同時呼び出しを行えます。

GrpcChannel.ForAddress は、gRPC クライアントを作成する際の唯一のオプションではありません。 ASP.NET Core アプリから gRPC サービスを呼び出そうとしている場合は、gRPC クライアントファクトリの統合を検討してください。 gRPC と HttpClientFactory の統合により、gRPC クライアントを一元的に作成する別の方法が得られます。

Note

現在のところ、Grpc.Net.Client による HTTP/2 を介した gRPC の呼び出しは、Xamarin ではサポートされていません。将来の Xamarin のリリースで HTTP/2 のサポートを向上させるために作業を進めています。 Grpc.Core と gRPC-Web は、現在でも機能する実行可能な代替手段です。

gRPC 呼び出しを行う

gRPC 呼び出しは、クライアントでメソッドを呼び出すことで開始されます。 gRPC クライアントは、メッセージのシリアル化と、gRPC 呼び出しの正しいサービスへのアドレス指定を処理します。

gRPC には、さまざまな種類のメソッドがあります。クライアントを使用して gRPC 呼び出しを行う方法は、呼び出そうとしているメソッドの種類によって異なります。 gRPC のメソッドの種類は次のとおりです。

単項
サーバーストリーミング。
クライアントストリーミング
双方向ストリーミング

Unary 呼び出し

Unary 呼び出しは、要求メッセージを送信するクライアントで始まります。サービスが終了すると応答メッセージが返されます。

var client = new Greet.GreeterClient(channel);
var response = await client.SayHelloAsync(new HelloRequest { Name = "World" });

Console.WriteLine("Greeting: " + response.Message);
// Greeting: Hello World

.proto ファイル内の各 Unary サービスメソッドは、メソッドを呼び出すための具象 gRPC クライアント型に関する 2 つの .NET メソッドとなります。非同期のメソッドとブロックするメソッドです。たとえば GreeterClient に関しては、SayHello を呼び出す方法は 2 つあります。

GreeterClient.SayHelloAsync - Greeter.SayHello サービスを非同期に呼び出します。待機可能です。
GreeterClient.SayHello - Greeter.SayHello サービスを呼び出して、完了するまでブロックします。非同期のコードでは使用しないでください。

サーバーストリーミング呼び出し

サーバーストリーミング呼び出しは、要求メッセージを送信するクライアントで始まります。 ResponseStream.MoveNext() は、サービスからストリーミングされたメッセージを読み取ります。 ResponseStream.MoveNext() が false を返すとサーバーストリーミングの呼び出しが完了します。

var client = new Greet.GreeterClient(channel);
using var call = client.SayHellos(new HelloRequest { Name = "World" });

while (await call.ResponseStream.MoveNext())
{
    Console.WriteLine("Greeting: " + call.ResponseStream.Current.Message);
    // "Greeting: Hello World" is written multiple times
}

C# 8 以降を使用している場合は、await foreach 構文を使用してメッセージを読み取ることができます。 IAsyncStreamReader<T>.ReadAllAsync() 拡張メソッドは、応答ストリームからすべてのメッセージを読み取ります。

var client = new Greet.GreeterClient(channel);
using var call = client.SayHellos(new HelloRequest { Name = "World" });

await foreach (var response in call.ResponseStream.ReadAllAsync())
{
    Console.WriteLine("Greeting: " + response.Message);
    // "Greeting: Hello World" is written multiple times
}

クライアントストリーミング呼び出し

クライアントストリーミング呼び出しは、メッセージを送信するクライアントなしで始まります。クライアントでは、RequestStream.WriteAsync を使用して、メッセージを送信することを選択できます。クライアントがメッセージの送信を完了したら、RequestStream.CompleteAsync() を呼び出してサービスに通知する必要があります。サービスが応答メッセージを返すと呼び出しが完了します。

var client = new Counter.CounterClient(channel);
using var call = client.AccumulateCount();

for (var i = 0; i < 3; i++)
{
    await call.RequestStream.WriteAsync(new CounterRequest { Count = 1 });
}
await call.RequestStream.CompleteAsync();

var response = await call;
Console.WriteLine($"Count: {response.Count}");
// Count: 3

双方向ストリーミング呼び出し

双方向ストリーミング呼び出しは、メッセージを送信するクライアントなしで始まります。クライアントでは、RequestStream.WriteAsync を使用して、メッセージを送信することを選択できます。サービスからストリーミングされたメッセージには、ResponseStream.MoveNext() または ResponseStream.ReadAllAsync() を使用してアクセスできます。双方向ストリーミング呼び出しは、ResponseStream にメッセージがなくなると完了します。

var client = new Echo.EchoClient(channel);
using var call = client.Echo();

Console.WriteLine("Starting background task to receive messages");
var readTask = Task.Run(async () =>
{
    await foreach (var response in call.ResponseStream.ReadAllAsync())
    {
        Console.WriteLine(response.Message);
        // Echo messages sent to the service
    }
});

Console.WriteLine("Starting to send messages");
Console.WriteLine("Type a message to echo then press enter.");
while (true)
{
    var result = Console.ReadLine();
    if (string.IsNullOrEmpty(result))
    {
        break;
    }

    await call.RequestStream.WriteAsync(new EchoMessage { Message = result });
}

Console.WriteLine("Disconnecting");
await call.RequestStream.CompleteAsync();
await readTask;

最適なパフォーマンスを得るため、そしてクライアントとサービスでの不要なエラーを回避するため、双方向のストリーミング呼び出しを正常に完了してみてください。サーバーが要求ストリームの読み取りを完了し、クライアントが応答ストリームの読み取りを完了すると、双方向呼び出しが正常に完了します。上記のサンプル呼び出しは、正常に終了する双方向呼び出しの一例です。この呼び出しでは、クライアントは次を行います。

EchoClient.Echo を呼び出すことによって、新しい双方向ストリーミング呼び出しを開始します。
ResponseStream.ReadAllAsync() を使用してサービスからメッセージを読み取るバックグラウンドタスクを作成します。
RequestStream.WriteAsync を使用してサーバーにメッセージを送信します。
RequestStream.CompleteAsync() によるメッセージの送信が完了したことをサーバーに通知します。
バックグラウンドタスクがすべての受信メッセージを読み取るまで待機します。

双方向ストリーミング呼び出しの間、クライアントとサービスはいつでも相互にメッセージを送信できます。双方向呼び出しの操作に最適なクライアントロジックは、サービスロジックによってさまざまです。

gRPC ヘッダーへのアクセス

gRPC 呼び出しでは応答ヘッダーが返されます。 HTTP 応答ヘッダーは、返されるメッセージに関連付けられていない呼び出しに関する名前と値のメタデータを渡します。

ヘッダーには、ResponseHeadersAsync を使用してアクセスできます。これにより、メタデータのコレクションが返されます。ヘッダーは通常、応答メッセージと共に返されます。そのため、それらを待機する必要があります。

var client = new Greet.GreeterClient(channel);
using var call = client.SayHelloAsync(new HelloRequest { Name = "World" });

var headers = await call.ResponseHeadersAsync;
var myValue = headers.GetValue("my-trailer-name");

var response = await call.ResponseAsync;

ResponseHeadersAsync の使用方法:

ヘッダーコレクションを取得するために ResponseHeadersAsync の結果を待機する必要があります。
ResponseAsync (またはストリーミング時の応答ストリーム) の前にアクセスする必要はありません。応答が返されている場合、ResponseHeadersAsync は、すぐにヘッダーを返します。
接続またはサーバーエラーが発生し、gRPC 呼び出しに対してヘッダーが返されなかった場合、例外がスローされます。

gRPC トレーラーへのアクセス

gRPC の呼び出しによって応答トレーラーが返される場合があります。トレーラーは、呼び出しに関する名前と値のメタデータを提供するために使用されます。トレーラーにより、同様の機能が HTTP ヘッダーに提供されますが、呼び出しの最後で受信されます。

トレーラーには、GetTrailers() を使用してアクセスできます。これにより、メタデータのコレクションが返されます。トレーラーは応答が完了した後に返されます。そのため、トレーラーにアクセスする前に、すべての応答メッセージを待機する必要があります。

単項呼び出しとクライアントストリーミング呼び出しでは、GetTrailers() を呼び出す前に ResponseAsync を待機する必要があります。

var client = new Greet.GreeterClient(channel);
using var call = client.SayHelloAsync(new HelloRequest { Name = "World" });
var response = await call.ResponseAsync;

Console.WriteLine("Greeting: " + response.Message);
// Greeting: Hello World

var trailers = call.GetTrailers();
var myValue = trailers.GetValue("my-trailer-name");

サーバーと双方向のストリーミング呼び出しでは、GetTrailers() を呼び出す前に応答ストリームの待機を完了する必要があります。

var client = new Greet.GreeterClient(channel);
using var call = client.SayHellos(new HelloRequest { Name = "World" });

await foreach (var response in call.ResponseStream.ReadAllAsync())
{
    Console.WriteLine("Greeting: " + response.Message);
    // "Greeting: Hello World" is written multiple times
}

var trailers = call.GetTrailers();
var myValue = trailers.GetValue("my-trailer-name");

トレーラーには、RpcException からもアクセスできます。サービスでは、OK でない gRPC の状態と共にトレーラーが返される場合があります。このような状況では、トレーラーは、gRPC クライアントによってスローされた例外から取得されます。

var client = new Greet.GreeterClient(channel);
string myValue = null;

try
{
    using var call = client.SayHelloAsync(new HelloRequest { Name = "World" });
    var response = await call.ResponseAsync;

    Console.WriteLine("Greeting: " + response.Message);
    // Greeting: Hello World

    var trailers = call.GetTrailers();
    myValue = trailers.GetValue("my-trailer-name");
}
catch (RpcException ex)
{
    var trailers = ex.Trailers;
    myValue = trailers.GetValue("my-trailer-name");
}

期限の構成

呼び出しを実行できる時間の長さに上限を設けることができるため、gRPC 呼び出しの期限を構成することをお勧めします。これにより、誤動作しているサービスが永遠に実行されてサーバーリソースが枯渇するのを防ぐことができます。期限は、信頼性の高いアプリをビルドするための便利なツールです。

gRPC 呼び出しの期限を設定するには、CallOptions.Deadline を構成します。

var client = new Greet.GreeterClient(channel);

try
{
    var response = await client.SayHelloAsync(
        new HelloRequest { Name = "World" },
        deadline: DateTime.UtcNow.AddSeconds(5));
    
    // Greeting: Hello World
    Console.WriteLine("Greeting: " + response.Message);
}
catch (RpcException ex) when (ex.StatusCode == StatusCode.DeadlineExceeded)
{
    Console.WriteLine("Greeting timeout.");
}

詳細については、「期限とキャンセルを使用した信頼性の高い gRPC サービス」を参照してください。

.NET クライアントを使用して gRPC サービスを呼び出す

gRPC クライアントを構成する

TLS の構成

クライアントパフォーマンス

gRPC 呼び出しを行う

Unary 呼び出し

サーバーストリーミング呼び出し

クライアントストリーミング呼び出し

双方向ストリーミング呼び出し

gRPC ヘッダーへのアクセス

gRPC トレーラーへのアクセス

期限の構成

その他のリソース

フィードバック

その他のリソース

.NET クライアントを使用して gRPC サービスを呼び出す

gRPC クライアントを構成する

TLS の構成

クライアント パフォーマンス

gRPC 呼び出しを行う

Unary 呼び出し

サーバー ストリーミング呼び出し

クライアント ストリーミング呼び出し

双方向ストリーミング呼び出し

gRPC ヘッダーへのアクセス

gRPC トレーラーへのアクセス

期限の構成

その他のリソース

フィードバック

その他のリソース

クライアントパフォーマンス

サーバーストリーミング呼び出し

クライアントストリーミング呼び出し