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

Posted UP技术控

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了.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的异步方法。

以上是关于.NET/C#程序开发中如何更优美地实现失败任务重试的逻辑?的主要内容,如果未能解决你的问题,请参考以下文章

如何在 Django-Celery 失败的情况下设置重试任务

如何修复“[Lp002]:IAR ARM 工具重定位失败?

处理失败的内存分配

重试丢失或失败的任务(Celery、Django 和 RabbitMQ)

springboot使用RabbitMQ实现延时任务

消息队列或调度程序