RetryPolicies 中的指数退避
Google Pub/Sub 的 RetryPolicy 中引入的指数退避功能反映了 github 定义的 ExponentialBackOff 中描述的概念。您提到的 com/cenkalti/backoff。
最小和最大退避
是的,您是对的。 pubsub.RetryPolicy中的MinimumBackoff和MaximumBackoff参数分别对应github.com/cenkalti/backoff中的InitialInterval和MaxInterval:
随机化
Cloud Pub/Sub 使用与 github.com 相同的公式来随机化间隔/cenkalti/backoff:
randomized interval = RetryInterval * (random value in range [1 - RandomizationFactor, 1 + RandomizationFactor])
pubsub.RetryPolicy 中的 RandomizationFactor 默认设置为 0.15。
Multiplier 和 MaxElapsedTime
与 github 不同.com/cenkalti/backoff,pubsub.RetryPolicy 没有相当于 Multiplier 的功能,它在每次失败后将 RetryInterval 加倍。相反,Pub/Sub 重试延迟以 RandomizationFactor 确定的固定速率呈指数增长。
此外,pubsub.RetryPolicy 中没有明确的 MaxElapsedTime。然而,Pub/Sub 实现了基于 go-routine 的重试机制,其中重试实际上受到处理订阅的 go-routine 的生命周期的限制。
示例
您的实验准确地演示了指数退避行为。较长的退避间隔(5 秒到 60 秒)会导致重试频率降低,而较短的间隔(1 秒到 2 秒)会导致重试频率更高。间隔的差异是由于随机化因素造成的。
以上是与 github.com/cenkalti/backoff 相比,Google Pub/Sub 如何在 RetryPolicies 中实现指数退避?的详细内容。更多信息请关注PHP中文网其他相关文章!