sgcWebSockets 4.3.6 から、Google Cloud Pub/Sub API がサポートされました。
Pub/Sub はエンタープライズのメッセージ指向ミドルウェアの柔軟性と信頼性をクラウドにもたらします。同時に、Pub/Sub はスケーラブルで耐久性のあるイベント取り込み・配信システムであり、最新のストリーム分析パイプラインの基盤として機能します。送信者と受信者を分離する多対多の非同期メッセージングを提供することで、独立して作成されたアプリケーション間の安全で高可用性の通信を実現します。Pub/Sub は低レイテンシで耐久性のあるメッセージングを提供し、開発者が Google Cloud Platform 上およびその外部でホストされているシステムを迅速に統合するのに役立ちます。
一般的なユースケース
- ネットワーククラスターの負荷分散。たとえば、大量のタスクキューを Google Compute Engine インスタンスなどの複数のワーカーに効率的に分散できます。
- 非同期ワークフローの実装。たとえば、注文処理アプリケーションがトピックに注文を配置し、1 つ以上のワーカーがそれを処理できます。
- イベント通知の配信。たとえば、ユーザー登録を受け付けるサービスが新しいユーザーの登録時に通知を送信し、ダウンストリームサービスがそのイベントの通知を購読できます。
- 分散キャッシュの更新。たとえば、アプリケーションが変更されたオブジェクトの ID を更新するために無効化イベントを発行できます。
- 複数のシステムへのロギング。たとえば、Google Compute Engine インスタンスが監視システムや後でクエリするためのデータベースなどにログを書き込めます。
- さまざまなプロセスやデバイスからのデータストリーミング。たとえば、家庭用センサーがクラウドでホストされているバックエンドサーバーにデータをストリーミングできます。
- 信頼性の向上。たとえば、単一ゾーンの Compute Engine サービスが共通トピックを購読することで追加ゾーンでも動作し、ゾーンやリージョンの障害から回復できます。
Delphi / CBuilder コンポーネント
sgcWebSockets Google Cloud Pub/Sub コンポーネントは REST API を使用して Google API に接続します。新しいトピックを作成する方法の例を以下に示します。
//Create a new topic for project with id: pubsub-270909 and topic name topic-1.
oPubSub := TsgcHTTPGoogleCloud_PubSub_Client.Create(nil);
oPubSub.GoogleCloudOptions.OAuth2.ClientId := '... your google client id...';
oPubSub.GoogleCloudOptions.OAuth2.ClientSecret := '... your google client secret...';
oPubSub.CreateTopic('pubsub-270909', 'topic-1');
//Response from Server
{
"name": "projects/pubsub-270909/topics/topic-1"
}