Polly Retry-在重试成功之前，通过所有执行

Question

目前，Polly Retry策略会独立退出所有失败的请求。因此，如果有10个请求失败，并且我已经设置了重试永远策略，那么每次重试发生时，它将发送10个以上的请求，服务器将永远不会愈合。

如何异步传递所有失败的请求，只重试一个请求，如果重试成功，恢复正常流程？

我不能（不想）使用断路器，因为我的服务是后台工作者服务，断路器破坏了整个后台服务逻辑。

// Current code with only retry policy
var retry = HttpPolicyExtensions.HandleTransientHttpError().WaitAndRetryForeverAsync(retryNo => new TimeSpan(0, retryNo > 3 ? 10 : (retryNo * 2), 0));
builder.Services.AddHttpClient<TestClient>().AddPolicyHandler(retry);

用例：我编写了一个后台服务，并不断地浏览一个包含30000页的网站。为了防止站点过载，我使用了信号量lim（或隔板）来限制在某个时间点发送到服务器的请求数量。

尽管如此，服务器还是有可能拒绝我的请求。此时，我只需要重试一个失败的请求单元，服务器就会再次开始接受我的请求。由于我同时发送多个请求，Polly正在重试所有失败的请求，这使服务器不满意。

期望：

10请求失败-

Answer 1

据我所知，您有一个HttpClient，用于针对同一下游系统发出N个速率有限的并发请求。

您希望处理以下故障场景：

• 如果存在瞬时网络问题，您希望重试单个请求
• 如果下游系统过载（因此大多数并发请求失败），那么您希望后退并仅使用单个请求来探测其健康状况

断路器策略充当代理。它会跟踪传出的通信，如果连续出现太多故障，则会阻止进一步的请求。它通过抛出一个brokencircuiitexception来缩短请求。

在一段时间后，CB将允许单个请求针对下游系统发出，如果成功，则允许所有传出通信，但如果失败，则将缩短它们。这里我详细介绍了CB是如何工作的。

您可以调整重试策略以了解此异常。这意味着您的重试请求仍将发出，但不会离开您的应用程序域。幸运的是，在Polly中，您可以为策略定义多个触发器：

HttpPolicyExtensions
   .HandleTransientHttpError()
   .Or<BrokenCircuitException>()
   .WaitAndRetryForeverAsync(retryNo => new TimeSpan(0, retryNo > 3 ? 10 : (retryNo * 2), 0));

因此，它将触发一个HttpRequestException或brokencircuiiteexception。如果HttpStatusCode为408或5xx，它也会触发。

现在剩下的就是将重试和断路策略组合成一个弹性策略。您可以使用以下方法之一来实现这一点：

.AddPolicyHandler(retryPolicy.Wrap(cbPolicy))
//OR
.AddPolicyHandler(Policy.Wrap(retryPolicy, cbPolicy))

请注意订购。重要的是将cb注册为内部策略，重试注册为外部策略，以便能够依赖升级。这里我已经详细描述了这个确切的场景。

注：如果你想，你可以在断路器断开时使用不同的延时。我在这里详细介绍了如何使用上下文对象来实现这一点。

如果应用程序没有崩溃，上述解决方案可以正常工作。如果是这样，那么你必须从头开始整个过程。

如果需要避免这种情况，那么需要将工作项（待处理的URL）存储在某个位置。

我建议采用以下架构：

• 您的主要工作人员不会对下游系统发出http请求，而是创建作业/工作项
  • 它可以将工作项存储在数据库或持久队列中
  • 如果请求成功，则会从持久存储中删除工作项
  • 如果CB关闭，那么它将获得N个工作
  • 如果它是打开的，那么它只取一个

  使用这种体系结构，您不需要显式的重试策略，因为队列/数据库会保留那些未成功的项目。因此，获取逻辑将检索相同的作业，直到它最终完成。

  您可以通过创建死信队列来进一步扩展这个概念，您可以在其中存储失败N次的工作项。这样你的队列就不会被“永久”工作项污染。