google-cloud-platform - GCloud 发布/订阅推送订阅 : Limit max outstanding messages

Question

有没有办法在推送订阅配置中限制未完成消息的最大数量。在高级订阅者文档 ( https://cloud.google.com/pubsub/docs/push ) 中，它说“在慢启动的情况下，Google Cloud Pub/Sub 通过一次发送一条消息开始，并随着每次成功交付而加倍，直到达到最大并发数未完成的消息。”我希望能够限制正在处理的最大消息数，这可以通过发布/订阅配置完成吗？

我还想到了许多其他方法来有效地实现这一目标，但似乎都不是很好:

是否在我的推送端点中实现了一些信号量类型系统，一旦达到我的最大并发级别就会返回 429？

类似，但让它注销推送端点(将其转换为拉订阅)，直到处理完当前消息

我的推送端点都在 gae 上，所以 gae 配置中也可能有一些东西来限制同时推送订阅请求？

Answer 1

推送订阅不提供任何方式来限制未完成消息的数量。如果想要这种级别的控制，则必须使用 pull subscriptions和 flow control .

返回 429 错误作为限制未完成消息的一种方式可能会产生不良副作用。出现错误时，Cloud Pub/Sub 将降低向推送订阅者发送消息的速度。如果返回了足够多的 429 错误，则订阅者完全有可能在一段时间内收到的消息数量少于其处理能力，同时 Cloud Pub/Sub 将交付率回升。

从推到拉切换是可能的，但仍然可能不是一个好的解决方案。这实际上取决于推送订阅者超过所需未完成消息数量的频率。推送和拉回之间的转换可能不会立即发生，这意味着订阅者可能仍会在一段时间内超出所需的限制，并且在切换回推送订阅者时也可能会延迟接收新消息。