サーバーストリーミングとクライアントストリーミング
双方向ストリーミングとバックプレッシャー
「サーバーストリーミングとクライアントストリーミング」はCoddyKit上の無料Go Academyレッスンです。 これはレッスン3/4です。 下記で完全なレッスンを無料で読むことができます。その後、ブラウザ内の組み込みコードエディタと24時間対応のAIチューターでハンズオン演習できます。 これはGo Academy学習パスの一部であり、ウェブとCoddyKitアプリ全体で進捗が同期されます。 Go Academyコースには全4レッスンが含まれています。
gRPCのストリーミング方式
gRPCにはunary以外に3つのストリーミング方式があります。サーバーストリーミング（サーバーが複数のメッセージを送信）、クライアントストリーミング（クライアントが複数のメッセージを送信）、双方向ストリーミング（双方がストリーミング）です。
.protoでのサーバーストリーミング
レスポンスの型の前にstreamキーワードを付けます：
service EventService {
rpc ListEvents (ListEventsRequest) returns (stream Event);
}サーバーストリーミングの実装
サーバーはstream.Send()を呼び出して複数のメッセージを送信し、完了したらnilを返します：
func (s *server) ListEvents(req *pb.ListEventsRequest, stream pb.EventService_ListEventsServer) error {
for _, event := range s.events {
if err := stream.Send(event); err != nil { return err }
}
return nil
}サーバーストリームの受信（クライアント）
クライアントはio.EOFになるまでループ内でRecv()を呼び出します：
stream, err := client.ListEvents(ctx, &pb.ListEventsRequest{})
for {
event, err := stream.Recv()
if err == io.EOF { break }
if err != nil { log.Fatal(err) }
fmt.Println(event)
}.protoでのクライアントストリーミング
リクエストの型の前にstreamを付けます：
service UploadService {
rpc Upload (stream Chunk) returns (UploadResponse);
}クライアントストリーミングの実装
クライアントは複数のメッセージを送信した後、CloseAndRecvでストリームを閉じます：
stream, _ := client.Upload(ctx)
for _, chunk := range chunks {
stream.Send(chunk)
}
resp, err := stream.CloseAndRecv()クライアントストリームの受信（サーバー）
io.EOFになるまでループ内でstream.Recv()を呼び出し、その後、最終レスポンスを返します：
func (s *server) Upload(stream pb.UploadService_UploadServer) error {
for {
chunk, err := stream.Recv()
if err == io.EOF {
return stream.SendAndClose(&pb.UploadResponse{Received: total})
}
if err != nil { return err }
total += len(chunk.Data)
}
}双方向ストリーミング
クライアントとサーバーは、それぞれ独立して送受信できます。.protoでは、両方の側にstreamを指定して宣言します。
service ChatService {
rpc Chat (stream Message) returns (stream Message);
}双方向ストリーミングのサーバー実装
サーバーはゴルーチンで受信し、独立して送信します：
func (s *server) Chat(stream pb.ChatService_ChatServer) error {
for {
msg, err := stream.Recv()
if err == io.EOF { return nil }
if err != nil { return err }
stream.Send(&pb.Message{Text: "echo: " + msg.Text})
}
}フロー制御
gRPCはHTTP/2のフロー制御を使用して、送信が速い側によって受信が遅い側が圧迫されるのを防ぎます。Recv()を呼び出すことで自然にバックプレッシャーが適用され、受信側が読み取っていない間は送信がブロックされます。
コンテキストのキャンセル
すべてのストリーミング呼び出しに、デッドラインまたはキャンセルを設定したコンテキストを渡します。コンテキストが完了するとストリームがキャンセルされ、Recv/Sendはエラーを返します。
クイックチェック
サーバーストリーミングRPCのサーバーは、送信が完了したことをどのように示しますか？
復習：gRPCストリーミング
重要なポイント：
- サーバーストリーム：レスポンスにstreamキーワードを指定し、サーバーがSend()を呼び出します
- クライアントストリーム：リクエストにstreamキーワードを指定し、クライアントがSend()を呼び出してからCloseAndRecv()を呼び出します
- 双方向ストリーム：両方にstreamを指定し、SendとRecvを独立したゴルーチンで実行します
- コンテキストのキャンセルはすべてのストリーミング呼び出しに適用されます
よくある質問
「サーバーストリーミングとクライアントストリーミング」レッスンは無料ですか？
はい。「サーバーストリーミングとクライアントストリーミング」の完全なテキストはこのウェブで無料で読めます。インタラクティブに演習し（組み込みコードエディタと24時間対応のAIチューター）、Go Academyコースの残りをアンロックするには、CoddyKit PROにアップグレードしてください。 Go Academyコースには全4レッスンが含まれています。
「サーバーストリーミングとクライアントストリーミング」で何を学びますか？
双方向ストリーミングとバックプレッシャー ブラウザで直接実行するハンズオンコードでGo Academyを演習し、24時間対応のAIチューターがレッスンを進める中での質問に答えます。
Go Academyを始めるのに経験は必要ですか？
事前経験は必要ありません。CoddyKitのGo Academyは初級者から上級者向けに構成されているため、ここから始めるか最初から始めて、自分のペースで進むことができます。 これはレッスン3/4です。
「サーバーストリーミングとクライアントストリーミング」レッスンにはどのくらい時間がかかりますか？
ほとんどのCoddyKitレッスンは約5～10分かかります。各レッスンはコンパクトでインタラクティブなので、着実に進歩し、ウェブとアプリ全体で正確に前回の場所から再開できます。
このGo Academyレッスンでコードを書いて実行できますか？
はい。すべてのGo Academyレッスンに組み込みコードエディタが含まれているため、ブラウザでリアルコードを書いて実行し、即座のAIフィードバックを取得できます。ローカル設定は不要です。
このコースのすべてのレッスン
- Protocol Buffersと.protoファイル
- Unary gRPCサービスの実装
- サーバーストリーミングとクライアントストリーミング
- gRPCインターセプターとメタデータ