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

执行策略

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

var policy = Policy.Handle<TimeoutException>().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<Exception, int, Context> onRetry);

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

Policy.Handle<TimeoutException>().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<TimeoutException>().Retry(3));

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

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

线程安全

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

异步的支持

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

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

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

同步上下文

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

var policy = Policy.Handle<TimeoutException>().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实现执行策略的文章就介绍到这了。希望对大家的学习有所帮助，也希望大家多多支持我们。

赞 (0)

相关推荐

  • .NET 开源项目Polly的简单介绍

    .NET 开源项目Polly的简单介绍

    目录 Polly 介绍 官方对 Polly 的介绍是这样的: Polly is a .NET resilience and transient-fault-handling library that allows developers to express policies such as Retry, Circuit Breaker, Timeout, Bulkhead Isolation, and Fallback in a fluent and thread-safe manner. 翻译

  • .Net弹性和瞬态故障处理库Polly介绍

    Polly 是 .Net 下的一套瞬时故障处理及恢复的函式库,可让开发者以fluent及线程安全的方式来应用诸如Retry.Circuit Breaker.Timeout.Bulkhead Isolation及Fallback等策略. 安装 可以通过Nuget实现快速安装:Install-Package Polly 基本用法 一个简单的示例如下: var policy = Policy .Handle<DivideByZeroException>() //定义所处理的故障 .Retry();

  • .Net弹性和瞬态故障处理库Polly实现弹性策略

    和故障处理策略不同的是,弹性策略并不是针对委托执行过程中的异常进行处理,而是改变委托本身的行为,因此弹性策略并没有故障定义这一过程,它的处理流程为: 定义策略 应用策略 Polly对弹性策略也做了不少支持,本文这里就简单的介绍一下. 弹性策略:超时(Timeout) 超时策略用于控制委托的运行时间,如果达到指定时间还没有运行,则触发超时异常. Policy.Timeout(TimeSpan.FromSeconds(3), TimeoutStrategy.Pessimistic); 超时策略常见的

  • c# 如何更简单的使用Polly

    Polly是一个C#实现的弹性瞬时错误处理库 它可以帮助我们做一些容错模式处理,比如: 超时与重试(Timeout and Retry) 熔断器(Circuit Breaker) 舱壁隔离(Bulkhead Isolation) 回退(Fallback) 使用也是非常简单的,比如: // Retry multiple times, calling an action on each retry // with the current exception and retry count Polic

  • .Net弹性和瞬态故障处理库Polly实现执行策略

    执行策略 执行策略的常见方式是调用策略的Execute函数 var policy = Policy.Handle<TimeoutException>().Retry(); policy.Execute(DoSomething); 返回值: 如果有返回值,它也是可以获取其返回值的: var result = policy.Execute(DoSomething); 捕获异常: 如果在策略的执行过程中出现了异常,也会在该函数中同步抛出来,和直接执行该委托行为一致.可以直接通过try-catch处理

  • Linux下为PHP添加扩展库的方法

    加上会出什么问题,不加会报什么错:所以在编译PHP的时候除了必要的目录指定,好多参数都没有加--等我在安装web程序的时候,才发现,很多参数是要加上的,但是我lnmp已经搭建好了,也不想重新编译,重新安装..于是就在网上找到了此文 一.添加FTP扩展 1.找到原来的源码包解压一下如:php-5.2.13进入到到FTP的扩展目录/root/lnmp/php-5.3.0/ext/ftp 2.调用phpize程序生成编译配置文件 复制代码 代码如下: root@dns ftp]# /usr/local

  • JavaScript的jQuery库中ready方法的学习教程

    学习 jQuery 有许多途径,我们今天从 jQuery 的 ready 函数开始.本例中的代码都来自于 jQuery 脚本库. 如果你使用过 jQuery , 就必然使用过 ready 函数,它用来注册当页面准备好之后可以执行的函数. 问题来啦,我们的页面什么时候准备好了呢? onload 事件 最基本的处理方式就是页面的 onload 事件,我们在处理这个事件的时候,可以有多种方式,即可以通过 HTML 方式,直接写在 body 元素的开始标记中,也可以使用事件注册的方式来使用,这又可以分为

  • 快速解决jQuery与其他库冲突的方法介绍

    通常,当在同一个页面上使用jQuery和其他库时,全局名称$的定义是最大的争论和冲突的焦点.众所周知,jQuery使用$作为jQuery名称的别名,并将其用于jQuery公开的每一个功能,但是其他库,最著名的就是Prototype,也使用$名称. 1. jQuery提供了$.noConflict()实用函数用来放弃对$标识符的占用,以便其他库使用它. 该函数的语法如下:$.noConflict(jqueryToo) 将标识符$的控制权归还给其他库,允许在页面上混合使用jQuery与其他库.一旦执

  • Linux程序运行时加载动态库失败的解决方法

    Linux下不能加载动态库问题 当出现下边异常情况 ./test: error while loading shared libraries: libmfs_open.so: cannot open shared object file: No such file or directory 若动态库的路径在(/usr/cluster/.share/lib) 解决办法: 方法一.在/etc/ld.so.conf文件中添加路径,vi /etc/ld.so.conf 添加下边内容 include ld

  • MySQL大库搭建主从的一种思路分享

    这个周忙的就像打仗一样,感觉有点被别人牵着鼻子走了,每天都是早出晚归,干不完的活儿,有时候感觉DBA这碗饭真的不好吃,要有强大的抗压能力和心理承受能力.今天下午吃饭的时候,真的感觉整个人快要垮掉了,吃完饭就依然决然的下班了,走在路上,看着下班的人群,心想这不就是正常的下班时间么,为什么我还有种早走惭愧的感觉?可能整个人都被洗脑了吧. 这个周的公众号内容更新也是耽搁了两天,周二那天实在是太累了,就直接休息了. 昨晚要走的时候,大概九点多,工作了一天比较累,然后就大脑不听使唤,弄了一个故障,把线上一

  • Docker 彻底删除私有库镜像的操作

    Docker 彻底删除私有库镜像的操作

    首先看看网上一般的做法 私有库默认是不支持删除镜像的,需要修改config.yml配置文件,在storage节点下加入 delete: enabled: true ,然后重启私有库. docker 提供的镜像删除api为: DELETE ip:端口/v2/<repository>/manifests/<reference> repository 为镜像的repository reference 为镜像push成功后生成的 digest:sha256 值 获取 digest : cu

随机推荐