本文档介绍了如何对发布到主题的消息使用并发控制。
并发控制可帮助您替换客户端库用于发布消息的后台 (I/O) 线程的默认数量。这样,发布者客户端就可以并行发送消息。使用低级别库时,您还可以实现自己的并发控制。
是否支持并发控制取决于客户端库的编程语言。对于支持并行线程的语言实现(例如 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 资源位置。
如需详细了解如何接收消息,请参阅选择订阅类型。