C#调用Polly库实现捕捉异常处理的操作代码

//捕捉到错误，自动重试三次
Policy.Handle<Exception>()
 .Retry(3, (exception, retryCount) =>
 {
     Console.WriteLine(DateTime.Now + $"代码异常: {exception},开始第 {retryCount} 次重试。");
 });

//捕捉到同一个异常两次时，就停下来，等待 1 分钟后再继续
Policy.Handle<SomeException>()    
.CircuitBreaker(2, TimeSpan.FromMinutes(1));

//这里设置了超时时间不能超过 30 秒，否则就认为是错误的结果，并执行回调
Policy.Timeout(30, onTimeout: (context, timespan, task) => 
{   
    Console.WriteLine("30秒无响应，需要执行的逻辑");
});

//这个策略是最多允许 10 个线程并发执行，如果执行被拒绝，则执行回调
Policy.Bulkhead(10, context => 
{   
     Console.WriteLine("当前线程超过10个，需要执行的逻辑");
});

//当用户没有填写名称时，我们就给他一个默认名称，这种策略可以这样定义：
Policy.Handle<Whatever>()   
.Fallback<User>(() => User.GetDefaultName())

//这是官方的一个使用示例用法，
//它定义了缓存 5 分钟过期的策略，然后把这个策略应用在指定的 Key（即 `FooKey`）上。
var memoryCacheProvider = new MemoryCacheProvider(myMemoryCache); 
var cachePolicy = Policy.Cache(memoryCacheProvider, TimeSpan.FromMinutes(5)); 
TResult result = cachePolicy.Execute(context => getFoo(), new Context("FooKey"));

//先是把预先定义好的多种不同的策略包在一起，作为一个整体策略，然后应用在同一个操作上。
var policyWrap = Policy  
.Wrap(fallback, cache, retry, breaker, timeout, bulkhead); 
policyWrap.Execute(() =>
{
    Console.WriteLine("多种策略共同执行的逻辑");
});

 //创建一个策略，用于处理异常,并进行重试
 public static Policy policy = Policy.Handle<Exception>()
 .Retry(3, (exception, retryCount) =>
 {
     Console.WriteLine(DateTime.Now + $"代码异常: {exception},开始第 {retryCount} 次重试。");
 });
 
 
  public async Task Execute()
  {
     //重试机制
     policy.Execute(() =>  //这里接收一个委托方法，也就是捕捉到异常之后要执行的业务逻辑
     {
         Console.WriteLine("重试");
     });
  }