谷歌发布订阅流控制

Question

我正在尝试实施一项服务，该服务以自己的节奏使用 google pubsub 订阅。这样，我的意思是我需要对何时需要使用消息进行精细控制，即获取一批消息，暂停一段时间，不要收到超过 X 条消息...

使用谷歌客户端库我没有找到方法，因为 MessageReceiver 在它自己的线程中运行，我无法控制到底发生了什么。

基本上，能够以同步方式使用消息应该可以解决我的问题。

你知道如何同步使用谷歌客户端库吗？还是我错过了 API 中的另一种方式？

Answer 1

您可以在构建订阅者时尝试使用setFlowControlSettings。特别是，您可以使用setMaxOutstandingElementCount 或setMaxOutstandingRequestBytes 来限制发送到您的MessageReceiver 的消息。当您有足够的未处理消息（即您尚未调用 Ack() 或 Nack() 的消息以超出这些限制时，则在消息被确认或确认之前不会调用您的 MessageReceiver。