C#编写一个在asp.net core 3.1下的简单的corn模式的计划任务和一个更简单的定时器类_其他

asp.net core 下,新增了一个BackgroundService用来实现能在后台跑一个长久运行的任务,因此,也可以用来替换掉原来使用的static的Timer组件,

Timer组件主要有以下几个麻烦的地方

1.如果是需要长时间跑的定时任务,需要定义为static,,在asp.net core下,无法利用到DI,无法从DI中获取DbContext之类的

2.启动定时器的时候,需要在start.cs自己手动启动

3.Timer是传入处理函数的方式,如果有好几个定时器,拼在一起,代码会看起来比较乱

4.使用Timer也无法实现corn表达式

5.Timer中也无法使用async异步处理

首先,我们来实现一个简单的定时器功能,用来替换掉Timer类:

1.TimerHostedService 定时器的基类

 1 /// <summary>
 2     /// 用于在后台执行一个定时任务,用于取代TimeEx,在asp.net core的环境下使用,继承该类后,使用 services.AddHostedService<当前类类型>();后,自动在后台启动当前定时任务
 3     /// </summary>
 4     public abstract class TimerHostedService : BackgroundService
 5     {
 6         private IServiceProvider _provider = null;
 7 
 8         protected TimerHostedService(IServiceProvider provider)
 9         {
10             _provider = provider;
11         }
12 
13         protected override async Task ExecuteAsync(CancellationToken stoppingToken)
14         {
15             if (Enabled && Internal>0)  //如果启动服务的时候,Enabled为false或者不设置间隔时间,则该定时器永久不启动
16             {
17                 while (!stoppingToken.IsCancellationRequested)  //如果站点触发停止,则会使用stoppingToken的IsCancellactionRequest判断是否由IIS之类的停止应用 18                 {
19                     await Task.Delay(Internal, stoppingToken);
20 
21                     if (!stoppingToken.IsCancellationRequested)
22                     {
23                         using (var scope = _provider.CreateScope())
24                         {
25                             try
26                             {
27                                 await Run(scope.ServiceProvider, stoppingToken);
28                             }
29                             catch (Exception e)
30                             {
31 
32                             }
33                         }
34                     }
35 
36                     
37                 }
38             }
39 
40             
41 
42             return;
43         }
44 
45         /// <summary>
46         /// 实际执行的定时器处理函数
47         /// </summary>
48         /// <param name="serviceScope">当次的Ioc容器,可获取当前程序中用于注入的容器内的类</param>
49         /// <param name="stoppingToken">是否暂停</param>
50         /// <returns></returns>
51         protected abstract Task Run(IServiceProvider serviceProvider, CancellationToken stoppingToken);
52 
53         /// <summary>
54         /// 定时器间隔触发时间,单位是ms
55         /// </summary>
56         protected abstract int Internal {  get; }
57 
58         /// <summary>
59         /// 当前定时器是否启用,true为定时器有效,false为停用
60         /// </summary>
61         public virtual bool Enabled { set; get; } = true;
62     }

2.实现一个定时器:

 1 /// <summary>
 2     /// 检查订单是否完成的后台任务
 3     /// </summary>
 4     public class CheckOrderCompleteTask:TimerHostedService
 5     {
 6         public CheckOrderCompleteTask(IServiceProvider provider) : base(provider)
 7         {
 8             this.Enabled = CustomConfigManager.Default["Timer:CheckBlessCompleted"].ToBool();
 9         }
10 
11         protected override async Task Run(IServiceProvider serviceProvider, CancellationToken stoppingToken)
12         {
13             var s = (XXXService) serviceProvider.GetService(typeof(XXXService)); //可以从DI容器中获取service或者dbcontext
17             await s.CheckXXX(stoppingToken);  //此处为实际执行的定时任务处理函数
18         }
19 
20         protected override int Internal { get; } = 1000 * 60 * 5;
21     }

在Start.cs中,注册该任务:

1 public void ConfigureServices(IServiceCollection services)
2 {
3     //.....其他代码
4     services.AddHostedService<CheckOrderCompleteTask>(); //此处将服务注册后,即由asp.net core在启动后,自动启动该服务
5 }

这样,就会有asp.net core自动启动该任务

由于上面定义的是一个定时器,有时候需要比如半夜12点,或者中午12点运行,这种场景下,就需要使用到计划任务的组件了,,.net下,常用的,一般有hangfire跟Quartz.Net,,这两个组件功能比较完善,而且也带有管理功能,but,..就是有时候复杂了点,通常有些不复杂的计划任务,比如又不想直接引入那么复杂的组件,那么可以根据上面的定时组件,变化出一个简单的计划任务组件:

    /// <summary>
    /// 一个简单的corn模式的计划任务<br/>用于在一些已知的计划时间执行某些任务的情况下使用,Cron属性在服务启动后,变无法修改,如需配置运行时可修改,请使用Hangfire之类的其他第三方框架
    /// </summary>
    public abstract class SimpleScheduledTaskService : BackgroundService
    {
        private IServiceProvider _provider = null;
        private CrontabSchedule _crontab = null;
        private string _cron;
        private bool _enabled=true;
        private bool _isInited = false;

        protected SimpleScheduledTaskService(IServiceProvider provider)
        {
            _provider = provider;
        }

        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
        {
            try
            {
                _crontab = CrontabSchedule.Parse(_cron);  //解析cron字符串
            }
            catch (Exception e)
            {
                throw;
            }

            while (Enabled && _crontab != null && !stoppingToken.IsCancellationRequested)
            {

                var nextDt = _crontab.GetNextOccurrence(DateTime.Now.AddSeconds(2));

                var interval = (nextDt - DateTime.Now);

                await Task.Delay(interval, stoppingToken);

                var logger = (ILogger)_provider.GetService(typeof(ILogger));

                try
                {
                    logger?.Log(LogLevel.Trace, $"启动计划任务:{this.GetType().Name}");

                    await Run(_provider, stoppingToken);

                    logger?.Log(LogLevel.Trace, $"完成计划任务:{this.GetType().Name}");
                }
                catch (Exception e)
                {
                    logger?.Log(LogLevel.Error, e, $"计划任务执行异常:{e.Message}");
                }
            }
        }

        protected abstract Task Run(IServiceProvider provider, CancellationToken stoppingToken);

        /// <summary>
        /// 计划任务的Cron配置字符串,可使用在线生成器生成后,填入
        /// </summary>
        public virtual string Cron
        {
            get => _cron;
        }

        /// <summary>
        /// 计划任务是否启动
        /// </summary>
        public virtual bool Enabled
        {
            set => _enabled = value;
            get => _enabled;
        }
    }