2

我想用 Polly 来做以下事情： 尝试一个超时时间很短的请求。如果失败，请使用更长的超时时间重试。

我看到Retry可以这样访问retryCount：

Policy
.Handle<SomeExceptionType>()
.Retry(3, (exception, retryCount, context) =>
{
    // do something 
});

我看到Timeout可以指定一个intor TimeSpan，如下所示：

Policy.Timeout(TimeSpan.FromMilliseconds(2500))

我什至看到您可以将函数传递给超时，如下所示：

Policy.Timeout(() => myTimeoutProvider)) // Func<TimeSpan> myTimeoutProvider

该Func选项似乎最有希望，但它可以在哪里访问重试计数？将状态保留在策略之外是很诱人的，但是如果我想以线程安全的方式共享策略，那是很危险的。

有什么建议吗？

4

2 回答 2

6

您可以使用 PollyContext在执行所涉及的不同策略之间传递状态数据。每次执行 Polly 都会产生一个独特的 Polly 实例Context，因此这完全是线程安全的。

此博客文章中有关此技术的更多详细信息。

例如：

const string RetryCountKey = "RetryCount";

RetryPolicy retryStoringRetryCount = Policy
    .Handle<Exception>()
    .Retry(3, (exception, retryCount, context) =>
    {
        Console.WriteLine("Storing retry count of " + retryCount + " in execution context.");
        context[RetryCountKey] = retryCount;
    });

TimeoutPolicy timeoutBasedOnRetryCount = Policy
    .Timeout(context =>
    {
        int tryCount;
        try
        {
            tryCount = (int) context[RetryCountKey];
        }
        catch
        {
            tryCount = 0; // choose your own default for when it is not set; also applies to first try, before any retries
        }

        int timeoutMs = 25 * (tryCount + 1);
        Console.WriteLine("Obtained retry count of " + tryCount + " from context, thus timeout is " + timeoutMs + " ms.");
        return TimeSpan.FromMilliseconds(timeoutMs);
    });

PolicyWrap policiesTogether = retryStoringRetryCount.Wrap(timeoutBasedOnRetryCount);

（注意：当然这个 ^ 可以更简洁。为了最清楚起见，请在此处列出。）

这是一个现场 dotnetfiddle 示例。

于 2018-03-18T09:26:09.557 回答
1

来自：https ://github.com/App-vNext/Polly/wiki/Timeout

int retryCount_ = 0;

Func<TimeSpan> myTimeoutProvider = () => 
    TimeSpan.FromMilliseconds(25*retryCount_);

// Configure variable timeout via a func provider.
Policy
    .Timeout(() => myTimeoutProvider)) // Func<TimeSpan> myTimeoutProvider
    .Retry(3, (exception, retryCount, context) =>
    {
        retryCount_ = retryCount;
        // do something 
    })

或设置类似于如下所示方式的超时：

Policy
    .Handle<SomeExceptionType>()
    .WaitAndRetry(5, retryAttempt => 
        TimeSpan.FromSeconds(Math.Pow(2, retryAttempt)) 
    );

更新

您还可以挂钩回调并不断增加所依赖onTimeoutAsync的局部变量。myTimeoutProvider

于 2018-03-18T07:07:46.737 回答