什么是 Pub/Sub？

Pub/Sub 是一种异步且可伸缩的通讯服务，可将生成消息的服务与处理这些消息的服务分离开来。

Pub/Sub 允许服务异步通信，延迟时间通常大约为 100 毫秒。

Pub/Sub 用于流式分析和数据集成流水线，以加载和分发数据。它同样适合用作服务集成的面向消息传递的中间件，或者并行执行任务的队列。

借助 Pub/Sub，您可以创建由事件提供方和使用方（称为发布者和订阅者）组成的系统。发布者通过广播事件而不是同步远程过程调用 (RPC) 与订阅者异步通信。

发布者将事件发送到 Pub/Sub 服务，而不考虑这些事件的处理方式或处理时间。然后，Pub/Sub 会将事件传送给做出响应的所有服务。在通过 RPC 通信的系统中，发布者必须等待订阅者接收数据。但是，Pub/Sub 中的异步集成提高了整个系统的灵活性和稳健性。

如需开始使用 Pub/Sub，请查看快速入门：使用 Cloud de Confiance 控制台。如需更全面的介绍，请参阅构建 Pub/Sub 消息传递系统。

常见使用场景

  • 注入用户互动和服务器事件。如需使用最终用户应用中的用户互动事件或系统中的服务器事件，您可以将其转发到 Pub/Sub。然后，您可以使用流处理工具将事件传递到数据库。 通过 Pub/Sub 可同时从许多客户端收集事件。
  • 实时事件分布。事件（原始数据或已处理的数据）可以提供给团队和组织中的多个应用进行实时处理。Pub/Sub 支持“企业事件总线”和事件驱动型应用设计模式。Pub/Sub 可让您与许多将事件导出到 Pub/Sub 的系统集成。
  • 在数据库之间复制数据。Pub/Sub 通常用于从数据库分发更改事件。这些事件可用于构建数据库状态和状态历史记录的视图。
  • 并行处理和工作流。您可以使用 Pub/Sub 消息与工作器通信，从而高效地在多个工作器之间分配许多任务。此类任务的示例包括压缩文本文件、发送电子邮件通知、评估 AI 模型和重新设置图片格式。
  • 企业事件总线。您可以创建企业范围的实时数据共享总线，并在整个组织中分发业务事件、数据库更新和分析事件。
  • 来自应用和服务的数据流。 例如，SaaS 应用可以发布实时事件 Feed。或者，住宅传感器可以将数据流式传输到 Pub/Sub，以便通过数据处理流水线在其他 Cloud de Confiance by S3NS 产品中使用。
  • 刷新分布式缓存。例如，应用可以发布无效化事件以更新发生更改的对象的 ID。
  • 进行负载均衡来实现可靠性。 例如，服务的实例可以部署在多个地区的 Compute Engine 上，但订阅一个常见主题。如果服务在任何可用区发生故障，其他可用区可以自动获取负载。

后续步骤