Go Academy · 강의

서버 및 클라이언트 스트리밍

양방향 스트리밍과 백프레셔

서버 및 클라이언트 스트리밍은(는) CoddyKit의 무료 Go Academy 강의입니다. 이것은 4개 중 3번째 강의입니다. 아래에서 전체 강의를 무료로 읽을 수 있으며, 내장 코드 에디터와 24/7 AI 튜터와 함께 브라우저에서 직접 실습할 수 있습니다. 이 강의는 Go Academy 학습 경로의 일부이며, 진행 상황이 웹과 CoddyKit 앱에 동기화됩니다. Go Academy 강의에는 총 4개의 강의가 포함되어 있습니다.

gRPC 스트리밍 유형

gRPC는 단항 방식 외에도 세 가지 스트리밍 모드를 지원합니다. 서버 스트리밍(서버가 여러 개를 전송), 클라이언트 스트리밍(클라이언트가 여러 개를 전송), 양방향 스트리밍(양쪽 모두 스트리밍)입니다.

서버 스트리밍을 .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/7 AI 튜터), CoddyKit PRO로 업그레이드하면 Go Academy 강의 전체를 잠금 해제할 수 있습니다. Go Academy 강의에는 총 4개의 강의가 포함되어 있습니다.

“서버 및 클라이언트 스트리밍”에서 뭘 배우나요?

양방향 스트리밍과 백프레셔 브라우저에서 직접 실행하는 실습 코드로 Go Academy을(를) 배우며, 24/7 AI 튜터가 강의를 진행하면서 질문에 답변해줍니다.

Go Academy을(를) 시작하는 데 경험이 필요한가요?

사전 경험은 필요하지 않습니다. CoddyKit의 Go Academy은(는) 초급자부터 고급 학습자까지를 위해 구성되어 있으므로, 여기서 시작하거나 처음부터 시작할 수 있으며 자신의 속도대로 진행할 수 있습니다. 이것은 4개 중 3번째 강의입니다.

“서버 및 클라이언트 스트리밍” 강의는 얼마나 걸리나요?

대부분의 CoddyKit 강의는 약 5~10분이 소요됩니다. 각 강의는 간결하고 인터랙티브하여 꾸준한 진행이 가능하며, 웹과 앱에서 중단한 부분부터 바로 시작할 수 있습니다.

이 Go Academy 강의에서 코드를 작성하고 실행할 수 있나요?

네. 모든 Go Academy 강의에는 내장 코드 에디터가 포함되어 있으므로, 브라우저에서 바로 실제 코드를 작성하고 실행한 후 즉시 AI 피드백을 받을 수 있습니다 — 로컬 설정이 필요 없습니다.

이 강의의 모든 강의

← Go Academy(으)로 돌아가기