从 sgcWebSockets 4.3.6 起，支持 Google Cloud Pub/Sub API。
Pub/Sub 为云端带来了企业级消息中间件的灵活性与可靠性。同时，Pub/Sub 是一个可扩展、持久化的事件摄取和交付系统，是现代流式分析管道的基础。通过提供多对多、异步消息传递来解耦发送方和接收方，它实现了独立开发的应用程序之间安全且高可用的通信。Pub/Sub 提供低延迟、持久化的消息传递，帮助开发者快速集成托管在 Google Cloud Platform 上及外部的系统。
常见使用场景
- 均衡网络集群的工作负载。例如，可将大量任务队列高效分配给多个工作节点（如 Google Compute Engine 实例）。
- 实现异步工作流。例如，订单处理应用可将订单发布到主题，由一个或多个工作节点进行处理。
- 分发事件通知。例如，接受用户注册的服务可在每次新用户注册时发送通知，下游服务可订阅以接收事件通知。
- 刷新分布式缓存。例如，应用可发布失效事件，以更新已变更对象的 ID。
- 向多个系统记录日志。例如，Google Compute Engine 实例可将日志写入监控系统、数据库以供后续查询等。
- 来自各种进程或设备的数据流。例如，住宅传感器可将数据流式传输到云端托管的后端服务器。
- 提高可靠性。例如，单区 Compute Engine 服务可通过订阅公共主题在其他区域运行，以从某个区域或地区的故障中恢复。
Delphi / C++Builder 组件
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"
}