日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學(xué)無先后，達(dá)者為師

網(wǎng)站首頁 編程語言 正文

.Net彈性和瞬態(tài)故障處理庫Polly實(shí)現(xiàn)執(zhí)行策略_實(shí)用技巧

作者：天方 ? 更新時(shí)間： 2022-08-22 編程語言

執(zhí)行策略

執(zhí)行策略的常見方式是調(diào)用策略的Execute函數(shù)

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

返回值：

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

var result = policy.Execute(DoSomething);

捕獲異常：

如果在策略的執(zhí)行過程中出現(xiàn)了異常，也會(huì)在該函數(shù)中同步拋出來，和直接執(zhí)行該委托行為一致。可以直接通過try-catch處理。

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

也可以通過ExecuteAndCapture函數(shù)捕獲異常。

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

策略上下文

在策略的處理過程中，有一個(gè)上下文對象，可以在回調(diào)函數(shù)中使用：

public static RetryPolicy Retry(this PolicyBuilder policyBuilder, int retryCount, Action<Exception, int, Context> onRetry);

它是一個(gè)IDictionary<string,?object>類型的對象，它在Policy的執(zhí)行過程中都可以使用，如：

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

這個(gè)上下文對象可以在應(yīng)用策略的時(shí)候帶入：

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

依賴注入

Polly也自帶了一個(gè)簡單的DI框架，方便復(fù)用Policy，使用方式如下：

var registry = new PolicyRegistry();
registry.Add("timeout & retry", Policy.Handle<TimeoutException>().Retry(3));

var policy = registry.Get<ISyncPolicy>("timeout & retry");
policy.Execute(DoSomething);

當(dāng)然，也可以使用Autofac等自己喜歡的方式。

線程安全

Policy本身是線程安全的，可以并發(fā)使用同一個(gè)Policy，但如果Policy中執(zhí)行的委托有多線程問題，仍然會(huì)出現(xiàn)異常。

異步的支持

Policy對異步操作也提供了良好的支持，只需要使用相應(yīng)以Async結(jié)尾的函數(shù)即可。

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

PS：有的不需要（也沒有）以Async的函數(shù)，如Handle

同步上下文

對于有的異常處理，如果需要同步上下文，則需要在ExecuteAsync函數(shù)中設(shè)置continueOnCapturedContext參數(shù)為false。

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

Cancellation的支持

Polly也支持系統(tǒng)的co-operative cancellation框架，在重試，超時(shí)，bulkhead等策略中通知執(zhí)行的委托，從而影響其行為。要使用Cancellation，需要在Excute的時(shí)候傳入CancellationToken。

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

具體示例在介紹彈性策略的超時(shí)策略時(shí)有介紹到。

原文鏈接：https://www.cnblogs.com/TianFang/p/8215736.html

欄目分類
最近更新