Google Cloud Pub/Sub

Google Cloud Pub/Sub 是一种完全托管的消息传递服务，用于在独立应用程序之间发送和接收消息。该 gRPC API 通过 google.pubsub.v1.Publisher 服务（主题与发布）和 google.pubsub.v1.Subscriber 服务（订阅与消息投递）公开，在 pubsub.googleapis.com:443 上通过 TLS 访问。

请求和响应通过类型化类构建，例如 TsgcGRPCPubSubListTopicsRequest / TsgcGRPCPubSubListTopicsResponse、TsgcGRPCPubSubTopic、TsgcGRPCPubSubPublishRequest / TsgcGRPCPubSubPublishResponse、TsgcGRPCPubSubSubscription、TsgcGRPCPubSubPullRequest / TsgcGRPCPubSubPullResponse 和 TsgcGRPCPubSubAcknowledgeRequest，因此您无需手动编码 Protocol Buffers。

下面的示例使用服务账户 JWT 进行身份验证，通过 TsgcHTTP2Client 将 TsgcGRPCClient 连接到 Pub/Sub 主机，设置授权 Bearer 元数据，并为某个项目调用 ListTopics：

    oHTTP2 := TsgcHTTP2Client.Create(nil);
    oHTTP2.Host := 'pubsub.googleapis.com';
    oHTTP2.Port := 443;
    oHTTP2.TLS := True;

    oGRPC := TsgcGRPCClient.Create(nil);
    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
    oRequest := TsgcGRPCPubSubListTopicsRequest.Create;
    try
      oRequest.Project := 'projects/my-project-id';
      oResponse := oGRPC.Call('google.pubsub.v1.Publisher', 'ListTopics', oRequest.ToBytes);
      ShowMessage(oResponse.DataString);
    finally
      oRequest.Free;
    end;