并发控制是 Pub/Sub 高级客户端库中的一项可用功能。使用低级别库时,您还可以实现自己的并发控制。
是否支持并发控制取决于客户端库的编程语言。对于支持并行线程的语言实现(例如 C++、Go 和 Java),客户端库会默认选择线程数。
此选择可能不是您的应用的最佳选择。例如,如果您的订阅者应用无法跟上传入消息量,并且不受 CPU 限制,您必须增加线程数。对于 CPU 密集型消息处理操作,减少线程数可能是合适的做法。
并发控制配置
并发控制变量的默认值和变量名称可能因客户端库而异。例如,在 Java 客户端库中,配置并发控制的方法包括 setSystemExecutorProvider()
、setExecutorProvider()
和 setParallelPullCount()
。
setParallelPullCount() 用于决定要打开的流的数量。如果订阅者客户端处理的数据量超过单个数据流(10 MBps)所发送的数据量,则您可以打开更多数据流。
借助 setExecutorProvider(),您可以自定义用于处理消息的执行器提供程序。例如,您可以将执行器提供程序更改为返回单个共享执行器(跨多个订阅者客户端具有有限数量的线程)。此配置有助于限制创建的线程数。
借助 setSystemExecutorProvider(),您可以自定义用于租期管理的执行器提供程序。通常,除非您要在
setExecutorProvider
和setSystemExecutorProvider
中使用相同的执行器提供程序,否则请勿配置此值。例如,如果您有多个低吞吐量订阅,则可以使用同一执行器提供程序。使用相同的值会限制客户端中的线程数。
用于并发控制的线程总数取决于客户端库中传递的执行器提供程序和并行拉取计数。
并发控制代码示例
C++
在尝试此示例之前,请按照《快速入门:使用客户端库》中的 C++ 设置说明进行操作。如需了解详情,请参阅 Pub/Sub C++ API 参考文档。
Go
在尝试此示例之前,请按照《快速入门:使用客户端库》中的 Go 设置说明进行操作。 如需了解详情,请参阅 Pub/Sub Go API 参考文档。
Java
在尝试此示例之前,请按照《快速入门:使用客户端库》中的 Java 设置说明进行操作。 如需了解详情,请参阅 Pub/Sub Java API 参考文档。
Ruby
在尝试此示例之前,请按照《快速入门:使用客户端库》中的 Ruby 设置说明进行操作。 如需了解详情,请参阅 Pub/Sub Ruby API 参考文档。
后续步骤
了解您可为订阅配置的其他传送选项: