博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
.NET/C#程序开发中如何更优美地实现失败任务重试的逻辑?
阅读量:4035 次
发布时间:2019-05-24

本文共 3145 字,大约阅读时间需要 10 分钟。

背景

 在.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;        ///         /// 若發生 Exception (資料庫查詢逾時),重複執行相同動作        ///         /// 
/// /// 預設重試 3次,傳入 0直接 return default(T) ///
public static T Retry
(Func
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); } } ///
/// 傳入多個動作,遇到 Exception依序執行 (資料庫查詢逾時,改用不同條件查詢) /// ///
///
///
public static T Retry
(params Func
[] 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); } ///
/// 若發生 Exception (資料庫查詢逾時),重複執行相同動作 /// ///
///
預設重試 3次,傳入 0直接 return 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
GetSendMailList(SystemMailSearchModel mailSearchModel) { return Common.CommonTools.Retry(() => _spSystemSettingsDapperRep.GetSendMailList(mailSearchModel)); }

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

转载地址:http://guudi.baihongyu.com/

你可能感兴趣的文章
Android所有权限说明
查看>>
Git入门
查看>>
Android去掉标题栏
查看>>
如何把App放在服务器上供用户下载
查看>>
Android widget之PopupWindow
查看>>
SQLPlus常用操作
查看>>
Android四大组件之Activity
查看>>
Markdown语法介绍
查看>>
Android之AsyncTask的使用
查看>>
Android之WebView
查看>>
IMSI与IMEI的区别
查看>>
Android SDK代理资源收集
查看>>
收起虚拟键盘
查看>>
AndroidStudio常用快捷键(持续更新,用一个记一个)
查看>>
Android获取本地图片、视频缩略图
查看>>
Android实现沉浸式状态栏
查看>>
AbAndroidStudio报错“unable to create debug bridge:ubable to start adb server”
查看>>
AAPT err... ERROR: Unable to open PNG file的解决方案
查看>>
Android ToolBar使用
查看>>
Android MediaPlayer --播放音频
查看>>