什么是 Pub/Sub？

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

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

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

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

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

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

常见使用场景

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

后续步骤