您现在的位置是：网站首页> 编程资料编程资料

.Net弹性和瞬态故障处理库Polly实现执行策略_实用技巧_

2023-05-24 324人已围观

简介 .Net弹性和瞬态故障处理库Polly实现执行策略_实用技巧_

执行策略

执行策略的常见方式是调用策略的Execute函数

var policy = Policy.Handle().Retry(); policy.Execute(DoSomething);

返回值：

如果有返回值，它也是可以获取其返回值的：

var result = policy.Execute(DoSomething);

捕获异常：

如果在策略的执行过程中出现了异常，也会在该函数中同步抛出来，和直接执行该委托行为一致。可以直接通过try-catch处理。

try { policy.Execute(DoSomething); } catch (Exception e) { throw; }

也可以通过ExecuteAndCapture函数捕获异常。

var result = policy.ExecuteAndCapture(DoSomething); if (result.FaultType == null) { Console.WriteLine(result.Result); }

策略上下文

在策略的处理过程中，有一个上下文对象，可以在回调函数中使用：

public static RetryPolicy Retry(this PolicyBuilder policyBuilder, int retryCount, Action onRetry);

它是一个IDictionary类型的对象，它在Policy的执行过程中都可以使用，如：

Policy.Handle().Retry(3, (err, countDown, context) => { var method = context["method"]; ConsoleLogger.WriteLine(method); })

这个上下文对象可以在应用策略的时候带入：

policy.Execute(DoSomething, new Context("context") { ["method"] = "PolicyTest" });

依赖注入

Polly也自带了一个简单的DI框架，方便复用Policy，使用方式如下：

var registry = new PolicyRegistry(); registry.Add("timeout & retry", Policy.Handle().Retry(3)); var policy = registry.Get("timeout & retry"); policy.Execute(DoSomething);

当然，也可以使用Autofac等自己喜欢的方式。

线程安全

Policy本身是线程安全的，可以并发使用同一个Policy，但如果Policy中执行的委托有多线程问题，仍然会出现异常。

异步的支持

Policy对异步操作也提供了良好的支持，只需要使用相应以Async结尾的函数即可。

var policy = Policy.Handle().RetryAsync(3); await policy.ExecuteAsync(DoSomethingAsync);

PS：有的不需要（也没有）以Async的函数，如Handle

同步上下文

对于有的异常处理，如果需要同步上下文，则需要在ExecuteAsync函数中设置continueOnCapturedContext参数为false。

var policy = Policy.Handle().RetryAsync(3); await policy.ExecuteAsync(DoSomethingAsync, CancellationToken.None, continueOnCapturedContext: true);

Cancellation的支持

Polly也支持系统的co-operative cancellation框架，在重试，超时，bulkhead等策略中通知执行的委托，从而影响其行为。要使用Cancellation，需要在Excute的时候传入CancellationToken。

policy.Execute(ct => { ct.ThrowIfCancellationRequested(); }, cts.Token);

具体示例在介绍弹性策略的超时策略时有介绍到。

到此这篇关于Polly实现执行策略的文章就介绍到这了。希望对大家的学习有所帮助，也希望大家多多支持。

您可能感兴趣的文章:

上一篇：.Net弹性和瞬态故障处理库Polly实现弹性策略_实用技巧_

下一篇：使用.NET Core创建exe应用程序_实用技巧_