程序地带

.NET/C#程序开发中如何更优美地实现失败任务重试的逻辑?


背景

 在.NET中,异常是指成员没有完成它的名称宣称可以完成的行动。在异常的机制中,异常和某件事情的发生频率无关。有时候需要对一些失败的任务进行多次的重试,如果重试的次数达到我们设定的阀值,则再放弃任务。


解决方案

使用一个静态类和静态的泛型方法来处理,创建通用的任务重试机制,我们可以使用Action作为参数。


实现方法
using BQoolCommon.Service.ExtensionMethod;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Security.Cryptography;
using System.Text;
using System.Threading.Tasks;
namespace BQoolCommon.Service.Common
{
public static class CommonTools
{
static NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger();
static int sleepMillisecondsTimeout = 1000;
/// <summary>
/// 若發生 Exception (資料庫查詢逾時),重複執行相同動作
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="handler"></param>
/// <param name="retryTimes">預設重試 3次,傳入 0直接 return default(T)</param>
/// <returns></returns>
public static T Retry<T>(Func<T> handler, int retryTimes = 3)
{
if (retryTimes <= 0)
{
return default(T);
}
try
{
return handler();
}
catch (Exception e)
{
retryTimes--;
logger.Error($"剩餘重試次數: {retryTimes}, retry error: {e.Message}, Exception detail: {e.ToJsonString()}");
System.Threading.Thread.Sleep(sleepMillisecondsTimeout);
return Retry(handler, retryTimes);
}
}
/// <summary>
/// 傳入多個動作,遇到 Exception依序執行 (資料庫查詢逾時,改用不同條件查詢)
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="handlers"></param>
/// <returns></returns>
public static T Retry<T>(params Func<T>[] handlers)
{
for (int i = 0; i < handlers.Length; i++)
{
var handler = handlers[i];
try
{
return handler();
}
catch (Exception e)
{
logger.Error($"第 {i}次執行錯誤(start from 0): retry error: {e.Message}, Exception detail: {e.ToJsonString()}");
System.Threading.Thread.Sleep(sleepMillisecondsTimeout);
}
}
return default(T);
}
/// <summary>
/// 若發生 Exception (資料庫查詢逾時),重複執行相同動作
/// </summary>
/// <param name="handler"></param>
/// <param name="retryTimes">預設重試 3次,傳入 0直接 return</param>
public static void Retry(Action handler, int retryTimes = 3)
{
if (retryTimes <= 0)
{
return;
}
try
{
handler();
}
catch (Exception e)
{
retryTimes--;
logger.Error($"剩餘重試次數: {retryTimes}, retry error: {e.Message}, Exception detail: {e.ToJsonString()}");
System.Threading.Thread.Sleep(sleepMillisecondsTimeout);
Retry(handler, retryTimes);
}
}
}
}
调用方法

调用方法如下:


public List<SystemMailModel> GetSendMailList(SystemMailSearchModel mailSearchModel)
{
return Common.CommonTools.Retry(() => _spSystemSettingsDapperRep.GetSendMailList(mailSearchModel));
}

当然,你也可以自己重载一个async的异步方法。



 


版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/lyl6796910/p/14236900.html

随机推荐

总结Houdini中各方面数据的传递方式

总结Houdini中各方面数据的传递方式

Houdini中“数据”的“传递”在我看来,Houdini中有多处存在着“数据”,并且他们可以相互“传递”。明面上的“数据”有:几何体的属性(G...

YakSue 阅读(154)

匹配手机号

匹配手机号2020/12/14functionIsPhone(phone){letreg=/^1[0-9]{10}$/;if(reg.test(phone)){returntrue;}else...

巴博尔 阅读(532)

【大数据】Hive

HiveHive概念Hive语法hive基本语法hive的DDL操作对hive库的操作:hive的表连接Hive概念Hive是基于Hadoop的一个数据仓库工具,可以将结构...

张茂祯 阅读(1000)