本文档介绍了如何对消息使用并发控制 发布到主题。
并发控制可帮助您覆盖默认的后台数量 (I/O) 线程,供客户端库用于发布消息。 这样,发布者客户端就可以并行发送消息。您还可以 在使用 Cloud Shell 时 一个低级库
对并发控制的支持取决于 客户端库。对于支持并行线程的语言实现, 例如 C++、Go 和 Java,那么客户端库是 线程数。
准备工作
在配置发布工作流之前,请确保您已完成以下任务:
所需的角色
如需获得将消息发布到主题所需的权限,请让您的管理员为您授予主题的 Pub/Sub Publisher (roles/pubsub.publisher
) IAM 角色。
如需详细了解如何授予角色,请参阅管理对项目、文件夹和组织的访问权限。
您需要拥有其他权限才能 创建或更新主题和订阅。
将并发控制功能与消息搭配使用
是否支持并发取决于您使用的编程语言。如需了解详情,请参阅 API 参考文档。
以下示例说明了如何控制发布者并发:
C++
在尝试此示例之前,请按照《快速入门:使用客户端库》中的 C++ 设置说明进行操作。如需了解详情,请参阅 Pub/Sub C++ API 参考文档。
Go
在尝试此示例之前,请按照《快速入门:使用客户端库》中的 Go 设置说明进行操作。 如需了解详情,请参阅 Pub/Sub Go API 参考文档。
Java
在尝试此示例之前,请按照《快速入门:使用客户端库》中的 Java 设置说明进行操作。 如需了解详情,请参阅 Pub/Sub Java API 参考文档。
Ruby
在尝试此示例之前,请按照《快速入门:使用客户端库》中的 Ruby 设置说明进行操作。 如需了解详情,请参阅 Pub/Sub Ruby API 参考文档。
后续步骤
如需限制 Pub/Sub 存储消息数据的位置,请参阅限制 Pub/Sub 资源位置。
如需详细了解如何接收消息,请参阅 选择订阅类型。