.Net Core使用Coravel实现任务调度

前言

前段时间需要在一个新项目里添加两个后台任务，去定时请求两个供应商的API来同步数据；由于项目本身只是一个很小的服务，不太希望引入太重的框架，同时也没持久化要求；于是我开始寻找在Quartz.Net、Hangfire之外，是否还有更为轻量级的框架满足我的要求，最终我选择了Coravel.
简介

Coravel是一个专为.NET Core设计的.NET Standard库，除了任务调度，还提供了像队列、缓存、邮件等其它高级功能。特点就是对开发者十分友好，接入十分简单、优雅、流畅，接近于零配置。
作为一个生于2018年的年轻项目，后发优势明显，一开始就是基于.Net Standard 2.0实现，没有历史负担，同时又可以利用很多.Net Core新特性。
用法

首先安装Coravel包

1. dotnet add package coravel

复制代码

下面演示在.Net 6 Minimal API项目中接入Coravel并设置两个定时任务，是不是非常简单：）

1. using Coravel;
3. var builder = WebApplication.CreateBuilder(args);
5. //只使用Coravel的任务调度功能
6. builder.Services.AddScheduler();
8. //注册你自己的调度任务
9. builder.Services.AddTransient<YourCoravelJob1>();
10. builder.Services.AddTransient<YourCoravelJob2>();
12. var app = builder.Build();
14. //配置任务
15. app.Services.UseScheduler(scheduler =>
16.     {
17.         scheduler.Schedule<YourCoravelJob1>().EveryFiveMinutes(); //每5分钟执行一次Job1
18.         scheduler.Schedule<YourCoravelJob2>().Hourly().Monday(); // 每周一每小时执行一次
19.     });

复制代码

Coravel预先定义好了很多常用的间隔频率，非常的全面，像上面用到的 EveryFiveMinutes() 和  Hourly()，是不是非常的简单优雅；当然Coravel也支持Cron表达式。
Invocable 是Coravel中的核心概念，代表一个独立的任务，上面的YourCoravelJob1和YourCoravelJob2就是 Invocable，Coravel直接调度这些Invocable。
要创建你自己的Invocable，只需实现 IInvocable接口，在 Invoke方法中编码你的任务。

1. public class YourCoravelJob1 : IInvocable
2.     {
3.         private readonly ILogger _logger;
5.         public YourCoravelJob1(ILogger<YourCoravelJob1> logger)
6.         {
7.             _logger = logger;
8.         }
10.         public async Task Invoke()
11.         {
12.              _logger.LogInformation("start..");
13.         }
14.     }
15. }

复制代码

原理

Coravel使用是的.Net Core 2.0引入的IHostedService来实现后台定时任务。（因此只有.Net Core 2.0以上的项目才能使用Coravel）

1. public interface IHostedService
2. {
3.     Task StartAsync(CancellationToken cancellationToken);
4.     Task StopAsync(CancellationToken cancellationToken);
5. }

复制代码

SchedulerHost即实现了IHostedService接口，在 其StartAsync方法中，当程序完全启动时，注册了一个的Timer

1. public Task StartAsync(CancellationToken cancellationToken)
2. {
3.     this._lifetime.ApplicationStarted.Register(InitializeAfterAppStarted);
4.     return Task.CompletedTask;
5. }
7. private void InitializeAfterAppStarted()
8. {
9.     this._timer = new Timer(this.RunSchedulerPerSecondAsync, null, TimeSpan.Zero, TimeSpan.FromSeconds(1));
10. }
12. private async void RunSchedulerPerSecondAsync(object state)
13. {
14. if (this._schedulerEnabled)
15. {
16.    await this._scheduler.RunSchedulerAsync();
17.   }
18. }

复制代码

每秒调用 RunSchedulerAsync 激活到点的Invocable，同时会根据情况将任务分组，在单独的线程分开执行。从这里可以看到Coravel是支持秒级任务的。
在 StopAsync 方法中，会先等待正在执行的任务完成才会关闭，这个功能还是比较重要。

1. public async Task StopAsync(CancellationToken cancellationToken)
2. {
3.     this._schedulerEnabled = false; // Prevents changing the timer from firing scheduled tasks.
4.     this._timer?.Change(Timeout.Infinite, 0);
6.     this._scheduler.CancelAllCancellableTasks();
8.     // If a previous scheduler execution is still running (due to some long-running scheduled task[s])
9.     // we don't want to shutdown while they are still running.
10.     if (this._scheduler.IsRunning)
11.     {
12.         this._logger.LogWarning(ScheduledTasksRunningMessage);
13.     }
15.     while (this._scheduler.IsRunning)
16.     {
17.         await Task.Delay(50);
18.     }
19. }

复制代码

总结

本文介绍一个对开发者友好的、轻量级、零配置的.Net Standard库Coravel，并演示了如何使用Coravel在.Net 6 Minimal API中创建定时任务，最后浅析了的实现原理。作为一个年轻的框架，Coravel站在了巨人的肩膀上，相比Quartz.Net、Hangfire，也拥有很多亮点特性，很值得尝试。
任何问题或者建议，欢迎评论区留言讨论~
参考链接

• https://github.com/jamesmh/coravel
  
• https://docs.coravel.net
  
• https://docs.microsoft.com/en-us/dotnet/core/extensions/generic-host
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！