Google Cloud Pub/Sub

Google Cloud Pub/Sub은 독립적인 애플리케이션 간에 메시지를 보내고 받기 위한 완전 관리형 메시징 서비스입니다. gRPC API는 google.pubsub.v1.Publisher 서비스(토픽 및 게시)와 google.pubsub.v1.Subscriber 서비스(구독 및 메시지 전달)를 통해 제공되며, TLS를 통해 pubsub.googleapis.com:443에서 접근합니다.

요청과 응답은 TsgcGRPCPubSubListTopicsRequest / TsgcGRPCPubSubListTopicsResponse, TsgcGRPCPubSubTopic, TsgcGRPCPubSubPublishRequest / TsgcGRPCPubSubPublishResponse, TsgcGRPCPubSubSubscription, TsgcGRPCPubSubPullRequest / TsgcGRPCPubSubPullResponse 및 TsgcGRPCPubSubAcknowledgeRequest와 같은 형식화된 클래스로 작성되므로, Protocol Buffers를 직접 인코딩할 필요가 없습니다.

아래 예제는 서비스 계정 JWT로 인증하고, Pub/Sub 호스트에 대해 TsgcHTTP2Client 위에 TsgcGRPCClient를 연결하고, authorization Bearer 메타데이터를 설정한 후, 프로젝트에 대해 ListTopics를 호출합니다.

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

    TsgcGRPCClient *oGRPC = new TsgcGRPCClient();
    oGRPC->Client = oHTTP2;

    // service-account JWT authentication
    oGRPC->GoogleCloudOptions->JWT->KeyFile = "service-account.json";
    oGRPC->GoogleCloudOptions->JWT->API_Endpoint = "https://pubsub.googleapis.com/";
    oGRPC->DefaultMetadata->AddValue("authorization", "Bearer " + oGRPC->GoogleCloudOptions->JWT->Token);

    // build the typed request and call the method
    TsgcGRPCPubSubListTopicsRequest *oRequest = new TsgcGRPCPubSubListTopicsRequest();
    oRequest->Project = "projects/my-project-id";
    TsgcGRPCResponse *oResponse = oGRPC->Call("google.pubsub.v1.Publisher", "ListTopics", oRequest->ToBytes());
    ShowMessage(oResponse->DataString);
    delete oRequest;