最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

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

 更新時(shí)間:2022年06月29日 16:16:38   作者:天方  
這篇文章介紹了.Net彈性和瞬態(tài)故障處理庫(kù)Polly實(shí)現(xiàn)執(zhí)行策略的方法,文中通過示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下

執(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è)上下文對(duì)象,可以在回調(diào)函數(shù)中使用:

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

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

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

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

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

依賴注入

Polly也自帶了一個(gè)簡(jiǎn)單的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對(duì)異步操作也提供了良好的支持,只需要使用相應(yīng)以Async結(jié)尾的函數(shù)即可。

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

PS:有的不需要(也沒有)以Async的函數(shù),如Handle

同步上下文

對(duì)于有的異常處理,如果需要同步上下文,則需要在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í)有介紹到。

到此這篇關(guān)于Polly實(shí)現(xiàn)執(zhí)行策略的文章就介紹到這了。希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。

相關(guān)文章

最新評(píng)論

临泉县| 张家界市| 钦州市| 双辽市| 稷山县| 赤峰市| 普兰店市| 通化市| 河津市| 怀安县| 澳门| 岗巴县| 信阳市| 上饶县| 芮城县| 绥德县| 乐至县| 杨浦区| 桐乡市| 伊宁市| 嘉黎县| 应城市| 饶平县| 岱山县| 雷波县| 克山县| 乐山市| 灵寿县| 莲花县| 雅江县| 大城县| 泰和县| 井研县| 乐亭县| 长垣县| 西贡区| 柞水县| 大宁县| 鹤壁市| 施秉县| 马公市|