单元测试中验证Polly HttpClient超时/重试次数及TimeoutPolicy委托触发次数

我来针对你的疑问逐一解答，结合Polly的实际行为和测试经验来说明：

1. HttpClient超时触发时，TimeoutPolicy的onTimeoutAsync是否会被调用？ #

这里要明确Polly的TimeoutPolicy和HttpClient自带的超时是两个独立的机制：

• HttpClient的超时是通过自身的HttpClient.Timeout属性设置，内部通过独立的CancellationToken实现超时，超时后抛出TaskCanceledException（或OperationCanceledException）。
• Polly的TimeoutPolicy默认是乐观超时模式：它会向被包裹的操作传入一个受控的CancellationToken，当超时时间到达时，Polly会取消这个令牌，进而触发操作的取消逻辑，此时onTimeoutAsync才会被触发。

所以结论是：

• 如果你的HttpClient调用没有使用Polly超时策略提供的CancellationToken（比如直接调用client.GetAsync(url)而不是client.GetAsync(url, cancellationToken)），那么HttpClient自身超时抛出异常时，Polly的onTimeoutAsync不会被触发——因为Polly没有办法感知到HttpClient内部的超时操作。
• 如果你的HttpClient调用传入了Polly超时策略提供的CancellationToken，那么当Polly的超时时间先于HttpClient的超时时间到达时，Polly会主动取消令牌，此时onTimeoutAsync会被触发；反之，如果HttpClient的超时先触发，Polly的onTimeoutAsync依然不会被触发。

2. 与RetryPolicy组合时，onTimeoutAsync的触发次数 #

触发次数完全取决于策略的包裹顺序和每次重试是否触发了Polly的超时：

情况A：RetryPolicy包裹TimeoutPolicy（每次重试都应用超时） #

这是最常见的组合方式，代码类似：

var combinedPolicy = Policy.WrapAsync(retryPolicy, timeoutPolicy);

这种情况下，每次重试都会重新应用一次TimeoutPolicy：

• 如果初始调用触发Polly超时，onTimeoutAsync触发1次，然后RetryPolicy执行重试；
• 如果重试过程中每次都触发Polly超时，那么每次重试都会触发一次onTimeoutAsync；
• 总触发次数 = 触发超时的调用次数（初始调用 + 重试中触发超时的次数）。

比如RetryPolicy设置重试2次，每次调用都触发Polly超时，那么onTimeoutAsync会触发3次。

情况B：TimeoutPolicy包裹RetryPolicy（整个重试流程应用一次超时） #

代码类似：

var combinedPolicy = Policy.WrapAsync(timeoutPolicy, retryPolicy);

这种情况下，TimeoutPolicy控制的是整个重试流程的总时间：

• 只有当整个重试流程（初始调用 + 所有重试）的总时间超过TimeoutPolicy设置的超时时间时，onTimeoutAsync才会触发1次；
• 即使重试过程中单个调用的时间没超时，但总时间超了，依然会触发一次onTimeoutAsync；
• 如果单个调用触发HttpClient自身超时，不会触发onTimeoutAsync。

测试建议 #

你可以通过以下方式快速验证：

1. 用Task.Delay模拟一个慢请求，控制延迟时间超过Polly的超时时间；
2. 在onTimeoutAsync中加入日志或计数器，观察触发次数；
3. 分别测试两种策略组合的情况，对比结果。

示例测试代码片段：

// 定义超时策略，加入计数器
int timeoutCount = 0;
var timeoutPolicy = Policy.TimeoutAsync<HttpResponseMessage>(
    TimeSpan.FromSeconds(1),
    onTimeoutAsync: (context, timespan, task) =>
    {
        timeoutCount++;
        Console.WriteLine($"Timeout triggered! Count: {timeoutCount}");
        return Task.CompletedTask;
    });

// 定义重试策略，重试2次
var retryPolicy = Policy.Handle<TaskCanceledException>()
    .WaitAndRetryAsync(2, retryAttempt => TimeSpan.FromMilliseconds(500));

// 组合策略（Retry包裹Timeout）
var combinedPolicy = Policy.WrapAsync(retryPolicy, timeoutPolicy);

// 模拟慢请求
await combinedPolicy.ExecuteAsync(async ct =>
{
    await Task.Delay(TimeSpan.FromSeconds(2), ct); // 延迟超过超时时间
    return new HttpResponseMessage(HttpStatusCode.OK);
});

// 输出timeoutCount，应该是3（初始+2次重试）
Console.WriteLine($"Total timeout triggers: {timeoutCount}");

内容的提问来源于stack exchange，提问作者Kal