TsgcGRPCClient

TsgcGRPCClient는 HTTP/2 위에서 gRPC 클라이언트를 구현하며(TsgcHTTP2Client를 전송으로 사용), 네 가지 gRPC RPC 패턴을 지원합니다.

소개

    TsgcHTTP2Client *oHTTP2 = new TsgcHTTP2Client();
    oHTTP2->Host = "grpc.example.com";
    oHTTP2->Port = 443;
    oHTTP2->TLS = true;

    TsgcGRPCClient *oGRPC = new TsgcGRPCClient();
    oGRPC->Client = oHTTP2;
    oGRPC->OnGRPCResponse = OnGRPCResponseEvent;
    oGRPC->CallAsync("helloworld.Greeter", "SayHello", vRequestBytes);

    void OnGRPCResponseEvent(TObject *Sender, const TsgcGRPCResponse *aResponse)
    {
      if (aResponse->StatusCode == grpcOK)
        ShowMessage(aResponse->DataString);
    }

RPC 패턴

gRPC는 네 가지 RPC 패턴을 정의합니다. TsgcGRPCClient는 각 패턴에 대한 멤버 집합을 제공합니다.

• 단항: TsgcGRPCResponse를 반환하는 동기 호출에는 Call을 사용하고, OnGRPCResponse 이벤트를 통해 응답을 비동기적으로 수신하려면 CallAsync를 사용하십시오.
• 서버 스트리밍: ServerStreamingCall을 사용합니다. 서버가 보낸 각 메시지는 OnGRPCStreamMessage에 도착하고 스트림은 OnGRPCStreamEnd에서 완료됩니다.
• 클라이언트 스트리밍: OpenClientStream을 사용한 다음, 하나 이상의 메시지에 대해 SendStreamMessage를 사용하고, CloseClientStream 또는 CloseClientStreamAsync로 종료합니다.
• 양방향 스트리밍: OpenBidiStream을 사용하고, SendBidiMessage로 메시지를 보내며, CloseBidiStream으로 종료합니다. 수신 메시지는 OnGRPCStreamMessage에 도착합니다.

다음 예제는 서버 스트리밍 호출을 수행하고 서버가 전달한 모든 메시지를 읽습니다.

    oGRPC->OnGRPCStreamMessage = OnGRPCStreamMessageEvent;
    oGRPC->ServerStreamingCall("routeguide.RouteGuide", "ListFeatures", vRequestBytes);

    void OnGRPCStreamMessageEvent(TObject *Sender, const TsgcGRPCStreamMessage *aMessage)
    {
      ShowMessage(aMessage->DataString);
    }

Features

Channel Options

ChannelOptions 속성은 메시지 Compression, ContentType, 최대 송수신 메시지 크기 및 HTTP/2 keep-alive 핑과 같은 채널 수준 동작을 구성합니다.

Metadata

DefaultMetadata를 사용하여 모든 호출에 사용자 지정 헤더를 첨부하거나, 호출 메서드 중 하나에 호출별 메타데이터를 전달하십시오. 이것이 Bearer 토큰과 같은 authorization 헤더가 서버로 전송되는 방식입니다.

데드라인 및 재시도

각 호출은 데드라인을 허용하므로 서버가 느릴 때 빠르게 실패합니다. RetryPolicy는 자동 재시도를 제어합니다: MaxAttempts, 지수 백오프 및 재시도 가능한 상태 코드 집합.

Load Balancing

TsgcGRPCLoadBalancer는 Pick First 또는 Round Robin 정책을 사용하여 여러 백엔드에 호출을 분산하고, DNS 이름 리졸버를 통해 백엔드 주소를 확인합니다.

Health Checking

TsgcGRPCHealthClient는 표준 grpc.health.v1.Health 서비스를 구현하며, 일회성 상태 쿼리를 위한 Check와 상태 변경을 스트림으로 수신하기 위한 Watch를 제공합니다.

Server Reflection

TsgcGRPCReflectionClient는 gRPC Server Reflection 서비스를 사용하여 서버가 제공하는 서비스를 나열하고 런타임에 파일 디스크립터를 가져옵니다.

Interceptors

인터셉터는 Interceptors 속성을 통해 체인으로 연결할 수 있습니다. 라이브러리에는 TsgcGRPCLoggingInterceptor, TsgcGRPCTimeoutInterceptor 및 TsgcGRPCMetadataInterceptor가 포함되어 있습니다.

텔레메트리

MetricsCollector는 호출 수, 성공률 및 지연 시간을 포함한 메서드별 텔레메트리를 제공하며, 모니터링 및 진단에 유용합니다.

Protocol Buffers

gRPC 요청과 응답은 Protocol Buffers(protobuf)로 인코딩됩니다. 라이브러리에는 필드 번호별로 메시지를 작성하고 파싱하기 위한 TsgcProtobufWriter와 TsgcProtobufMessage가 포함되어 있습니다. Google Cloud 인터페이스는 형식화된 요청 및 응답 클래스를 제공하므로, 이러한 서비스를 호출할 때 protobuf를 직접 인코딩할 필요가 없습니다.

참조

Properties

Methods

Events

참조

• Google Cloud gRPC 서비스
• TsgcHTTP2Client