您可以使用 Google Pub Sub 批量拉取消息吗？

Question

尝试优化我们的应用程序，但进行批量拉取。Pub Sub 似乎允许使用不同的客户端节点一次异步拉取一条消息，但是单个节点没有办法从 pub sub 批量拉取吗？

Streaming Pull 和 Pull RPC 都只允许订阅者一次消费一条消息。现在，看起来我们必须一次提取一条消息并进行应用程序级批处理。

任何见解都会有所帮助。总的来说，这个 GCP 还很新。

Answer 1

底层拉取和流式拉取操作可以在同一响应中接收批量消息。使用流式拉取的Cloud Pub/Sub 客户端库将这些批次分开，并将它们一次一个地交给所提供的用户回调。因此，您无需担心底层消息接收的优化问题。

如果您关心的是在应用程序级别优化订阅者代码，例如，您想要批量写入数据库，那么您有几个选择：

1. 直接使用Pull，可以一次处理一批中的所有消息。请注意，有效使用拉取需要许多同时未完成的拉取请求，并用新请求立即替换返回的请求。

2. 在您的用户回调中，重新批处理消息，一旦批处理达到所需大小（或者您已经等待足够的时间来填充批处理），一起处理所有消息，然后确认它们。