Google Cloud Pub/Sub (TsgcHTTPGoogleCloud_PubSub_Client) — sgcWebSockets | eSeGeCe

Google Cloud Pub/Sub

Veröffentliche und rufe Nachrichten aus Google-Cloud-Pub/Sub-Topics aus Delphi ab. Service-Account-JWT-Signierung und typisierte Publish- / Pull- / Acknowledge-Methoden.

TsgcHTTPGoogleCloud_PubSub_Client

Google-Cloud-Pub/Sub-REST-Client — erstelle Topics, veröffentliche Nachrichten, rufe aus Subscriptions ab, bestätige oder ändere Ack-Fristen aus einer typisierten Delphi-Komponente.

Komponentenklasse

TsgcHTTPGoogleCloud_PubSub_Client

Protokoll

Pub/Sub REST API

Plattformen

Windows, macOS, Linux, iOS, Android

Edition

Standard / Professional / Enterprise

Service-Account laden, veröffentlichen, abrufen

Lade dein Service-Account-JSON, setze die Projekt-ID und rufe dann Publish auf, um eine Nachricht zu senden, und Pull, um aus einer Subscription zu verbrauchen.

uses
  sgcHTTP;

var
  PubSub: TsgcHTTPGoogleCloud_PubSub_Client;
begin
  PubSub := TsgcHTTPGoogleCloud_PubSub_Client.Create(nil);
  PubSub.GoogleCloudOptions.ServiceAccountJSON.LoadFromFile('service-account.json');

  // veröffentlichen
  PubSub.Publish('projects/your-project/topics/topic-id',
    '{"event":"order_created","id":42}');

  // abrufen
  Memo1.Text := PubSub.Pull('projects/your-project/subscriptions/sub-id', 10);
end;
// uses: sgcHTTP
TsgcHTTPGoogleCloud_PubSub_Client *PubSub = new TsgcHTTPGoogleCloud_PubSub_Client(this);
PubSub->GoogleCloudOptions->ServiceAccountJSON->LoadFromFile("service-account.json");

PubSub->Publish("projects/p/topics/t", payload);
Memo1->Text = PubSub->Pull("projects/p/subscriptions/s", 10);

Was steckt drin

Kapselt die Pub/Sub-REST-Oberfläche mit dem üblichen Google-Service-Account-Authentifizierungsfluss.

Topic-Verwaltung

CreateTopic, DeleteTopic, GetTopic, ListTopics sprechen die Endpunktfamilie /projects/<id>/topics an.

Publish

Publish sendet einen oder mehrere PubsubMessage-Einträge mit optionalen Attributen und Ordering-Keys und gibt die zugewiesenen messageIds zurück.

Pull / Acknowledge

Pull(subscription, maxMessages) gibt empfangene Nachrichten mit ihrer ackId zurück; Acknowledge(subscription, ackIds) schließt sie ab, ModifyAckDeadline verlängert die Verarbeitungszeit.

Service-Account-JWT

Derselbe Authentifizierungsfluss wie bei den FCM- und Calendar-Geschwistern — lädt den JSON-Schlüssel, signiert ein RS256-JWT, tauscht es gegen ein OAuth-Token und erneuert es bei Bedarf.

Subscription-Verwaltung

CreateSubscription, DeleteSubscription, UpdateSubscription, ListSubscriptions verwalten die Subscription-Seite von Pub/Sub.

Push oder Pull

Pull-Subscriptions werden mit Pull gelesen; Push-Subscriptions werden so konfiguriert, dass sie deinen Endpunkt aufrufen — typischerweise eine TsgcWebSocketHTTPServer-Instanz hinter einer öffentlichen URL.

Spezifikationen und Referenzen

Maßgebliche Quellen für die API, die diese Komponente implementiert.

Dokumentation & Demos

Springe direkt zur Komponentenreferenz, lade das einsatzbereite Demo-Projekt herunter und teste die Testversion.

Online-Hilfe — Google Pub/Sub Client Vollständige Eigenschaften-, Methoden- und Ereignisreferenz für diese Komponente.
Demo-Projekt — Demos\20.HTTP_Protocol\03.Google Einsatzbereites Beispielprojekt. Im sgcWebSockets-Paket enthalten — lade unten die Testversion herunter.
Technisches Dokument (PDF) Funktionen, Schnellstart, Codebeispiele für Delphi & C++ Builder und Primärquellenreferenzen — nur für diese Komponente.
Benutzerhandbuch (PDF) Umfassendes Handbuch zu jeder Komponente der Bibliothek.

Bereit, Cloud Pub/Sub aus Delphi zu nutzen?

Lade die kostenlose Testversion herunter und integriere Google Cloud Pub/Sub in deine Delphi-Anwendungen.