Google Pub/Sub 的 cloud.google.com/go/pubsub 库中的 RetryPolicy 提供指数退避作为可配置的功能,以增强 Pub/Sub 与其客户端之间通信的可靠性。
指数退避涉及以指数方式增加重试之间的延迟。这可以防止过度重试导致服务器不堪重负,并确保更加渐进的重新连接。
在 RetryPolicy 配置中,MinimumBackoff 相当于中的 InitialInterval github.com/cenkalti/backoff 库,MaximumBackoff 对应 MaxInterval。
MinimumBackoff 设置第一次重试之前的初始等待时间,而 MaximumBackoff 表示重试之间允许的最大延迟。默认情况下,MinimumBackoff 为 10 秒,MaximumBackoff 为 10 分钟。
Pub/Sub 根据随机指数计算重试之间的等待间隔退避公式:
`
随机间隔 =<pre class="brush:php;toolbar:false">RetryInterval * (random value in range [1 - RandomizationFactor, 1 + RandomizationFactor])
`
其中 RetryInterval 是当前重试间隔,初始为 MaximumBackoff,并且受 MaximumBackoff 限制。
与 github.com/cenkalti/backoff 库的 MaxElapsedTime 功能不同,Pub/Sub RetryPolicy 不有一个等效的选项来限制重试尝试。相反,它建议在应限制重试的情况下使用死信队列 (DLQ)。
Pub/Sub RetryPolicy 使用随机组件来在重试间隔中引入差异,确保具有相同配置的多个客户端不会以完全相同的间隔重试。
您的实验观察结果反映指数退避行为。使用 1 秒的最小退避和 2 秒的最大退避,您注意到 nack 之间有相对一致的约 3 秒延迟,表示最大退避 2 秒。
重试之间没有加倍间隔表明没有应用显式乘数。此外,您没有观察到重试次数有任何硬性限制,支持使用 DLQ 来限制重试尝试的建议。
以上是Google Pub/Sub 的 RetryPolicy 如何实现指数退避,它与其他退避库有何不同?的详细内容。更多信息请关注PHP中文网其他相关文章!