Asp.Net Core 基于QuartzNet任务管理系统
之前一直想搞个后台任务管理系统，零零散散的搞到现在，也算完成了。
这里发布出来，请园里的dalao批评指导！
废话不多说，进入正题。
github地址：https://github.com/YANGKANG01/QuartzNetJob
一、项目结构
项目结构如下：
ORM使用的是SqlSugar版本是4.6.4.3
QuartzNet使用的版本是3.0.2
Asp.Net Core 版本为2.0
类库使用的是 .Net Standard
类库 QuartzNet2.Core是.Net Framework 的类库，使用的QuartzNet版本是2.6，这里把它也放入了当前项目，方便不是Core的项目使用。
后台运行效果如下：
任务执行如下：
Linux执行如下：
二、项目源码
数据库表可使用SqlSugar生成，如下图：
项目中主要的类SchedulerCenter任务调度管理中心，源码如下：
using QuartzNet.Entity; using Quartz; using Quartz.Impl; using System; using System.Collections.Specialized; using System.Threading.Tasks; using Five.QuartzNetJob.Utils.Tool; using System.Reflection; using System.Collections.Generic; namespace QuartzNet3.Core { /// <summary> /// 任务调度中心 /// </summary> public class SchedulerCenter { /// <summary> /// 任务调度对象 /// </summary> public static readonly SchedulerCenter Instance; static SchedulerCenter() { Instance = new SchedulerCenter(); } private Task<IScheduler> _scheduler; /// <summary> /// 返回任务计划（调度器） /// </summary> /// <returns></returns> private Task<IScheduler> Scheduler { get { if (this._scheduler != null) { return this._scheduler; } // 从Factory中获取Scheduler实例 NameValueCollection props = new NameValueCollection { { "quartz.serializer.type", "binary" }, //以下配置需要数据库表配合使用，表结构sql地址：https://github.com/quartznet/quartznet/tree/master/database/tables //{ "quartz.jobStore.type","Quartz.Impl.AdoJobStore.JobStoreTX, Quartz"}, //{ "quartz.jobStore.driverDelegateType","Quartz.Impl.AdoJobStore.StdAdoDelegate, Quartz"}, //{ "quartz.jobStore.tablePrefix","QRTZ_"}, //{ "quartz.jobStore.dataSource","myDS"}, //{ "quartz.dataSource.myDS.connectionString",AppSettingHelper.MysqlConnection},//连接字符串 //{ "quartz.dataSource.myDS.provider","MySql"}, //{ "quartz.jobStore.useProperties","true"} }; StdSchedulerFactory factory = new StdSchedulerFactory(props); return this._scheduler = factory.GetScheduler(); } } /// <summary> /// 运行指定的计划(泛型指定IJob实现类) /// </summary> /// <param name="jobGroup">任务分组</param> /// <param name="jobName">任务名称</param> /// <returns></returns> public async Task<BaseQuartzNetResult> RunScheduleJob<T, V>(string jobGroup, string jobName) where T : ScheduleManage, new() where V : IJob { BaseQuartzNetResult result; //开启调度器 await this.Scheduler.Result.Start(); //创建指定泛型类型参数指定的类型实例 T t = Activator.CreateInstance<T>(); //获取任务实例 ScheduleEntity scheduleModel = t.GetScheduleModel(jobGroup, jobName); //添加任务 var addResult = AddScheduleJob<V>(scheduleModel).Result; if (addResult.Code == 1000) { scheduleModel.Status = EnumType.JobStatus.已启用; t.UpdateScheduleStatus(scheduleModel); //用给定的密钥恢复（取消暂停）IJobDetail await this.Scheduler.Result.ResumeJob(new JobKey(jobName, jobGroup)); result = new BaseQuartzNetResult { Code = 1000, Msg = "启动成功" }; } else { result = new BaseQuartzNetResult { Code = -1 }; } return result; } /// <summary> /// 运行指定的计划(映射处理IJob实现类) /// </summary> /// <param name="jobGroup">任务分组</param> /// <param name="jobName">任务名称</param> /// <returns></returns> public async Task<BaseQuartzNetResult> RunScheduleJob<T>(string jobGroup, string jobName) where T : ScheduleManage { BaseQuartzNetResult result; //开启调度器 await this.Scheduler.Result.Start(); //创建指定泛型类型参数指定的类型实例 T t = Activator.CreateInstance<T>(); //获取任务实例 ScheduleEntity scheduleModel = t.GetScheduleModel(jobGroup, jobName); //添加任务 var addResult = AddScheduleJob(scheduleModel).Result; if (addResult.Code == 1000) { scheduleModel.Status = EnumType.JobStatus.已启用; t.UpdateScheduleStatus(scheduleModel); //用给定的密钥恢复（取消暂停）IJobDetail await this.Scheduler.Result.ResumeJob(new JobKey(jobName, jobGroup)); result = new BaseQuartzNetResult { Code = 1000, Msg = "启动成功" }; } else { result = new BaseQuartzNetResult { Code = -1 }; } return result; } /// <summary> /// 添加一个工作调度（映射程序集指定IJob实现类） /// </summary> /// <param name="m"></param> /// <returns></returns> private async Task<BaseQuartzNetResult> AddScheduleJob(ScheduleEntity m) { var result = new BaseQuartzNetResult(); try { //检查任务是否已存在 var jk = new JobKey(m.JobName, m.JobGroup); if (await this.Scheduler.Result.CheckExists(jk)) { //删除已经存在任务 await this.Scheduler.Result.DeleteJob(jk); } //反射获取任务执行类 var jobType = FileHelper.GetAbsolutePath(m.AssemblyName, m.AssemblyName + "." + m.ClassName); // 定义这个工作，并将其绑定到我们的IJob实现类 IJobDetail job = new JobDetailImpl(m.JobName, m.JobGroup, jobType); //IJobDetail job = JobBuilder.CreateForAsync<T>().WithIdentity(m.JobName, m.JobGroup).Build(); // 创建触发器 ITrigger trigger; //校验是否正确的执行周期表达式 if (!string.IsNullOrEmpty(m.Cron) && CronExpression.IsValidExpression(m.Cron)) { trigger = CreateCronTrigger(m); } else { trigger = CreateSimpleTrigger(m); } // 告诉Quartz使用我们的触发器来安排作业 await this.Scheduler.Result.ScheduleJob(job, trigger); result.Code = 1000; } catch (Exception ex) { await Console.Out.WriteLineAsync(string.Format("添加任务出错{0}", ex.Message)); result.Code = 1001; result.Msg = ex.Message; } return result; } /// <summary> /// 添加任务调度（指定IJob实现类） /// </summary> /// <typeparam name="T"></typeparam> /// <param name="m"></param> /// <returns></returns> private async Task<BaseQuartzNetResult> AddScheduleJob<T>(ScheduleEntity m) where T : IJob { var result = new BaseQuartzNetResult(); try { //检查任务是否已存在 var jk = new JobKey(m.JobName, m.JobGroup); if (await this.Scheduler.Result.CheckExists(jk)) { //删除已经存在任务 await this.Scheduler.Result.DeleteJob(jk); } //反射获取任务执行类 // var jobType = FileHelper.GetAbsolutePath(m.AssemblyName, m.AssemblyName + "." + m.ClassName); // 定义这个工作，并将其绑定到我们的IJob实现类 //IJobDetail job = new JobDetailImpl(m.JobName, m.JobGroup, jobType); IJobDetail job = JobBuilder.CreateForAsync<T>().WithIdentity(m.JobName, m.JobGroup).Build(); // 创建触发器 ITrigger trigger; //校验是否正确的执行周期表达式 if (!string.IsNullOrEmpty(m.Cron) && CronExpression.IsValidExpression(m.Cron)) { trigger = CreateCronTrigger(m); } else { trigger = CreateSimpleTrigger(m); } // 告诉Quartz使用我们的触发器来安排作业 await this.Scheduler.Result.ScheduleJob(job, trigger); result.Code = 1000; } catch (Exception ex) { await Console.Out.WriteLineAsync(string.Format("添加任务出错", ex.Message)); result.Code = 1001; result.Msg = ex.Message; } return result; } /// <summary> /// 暂停指定的计划 /// </summary> /// <param name="jobGroup">任务分组</param> /// <param name="jobName">任务名称</param> /// <param name="isDelete">停止并删除任务</param> /// <returns></returns> public BaseQuartzNetResult StopScheduleJob<T>(string jobGroup, string jobName, bool isDelete = false) where T : ScheduleManage, new() { BaseQuartzNetResult result; try { this.Scheduler.Result.PauseJob(new JobKey(jobName, jobGroup)); if (isDelete) { Activator.CreateInstance<T>().RemoveScheduleModel(jobGroup, jobName); } result = new BaseQuartzNetResult { Code = 1000, Msg = "停止任务计划成功！" }; } catch (Exception ex) { result = new BaseQuartzNetResult { Code = -1, Msg = "停止任务计划失败" }; } return result; } /// <summary> /// 恢复运行暂停的任务 /// </summary> /// <param name="jobName">任务名称</param> /// <param name="jobGroup">任务分组</param> public async void ResumeJob(string jobName, string jobGroup) { try { //检查任务是否存在 var jk = new JobKey(jobName, jobGroup); if (await this.Scheduler.Result.CheckExists(jk)) { //任务已经存在则暂停任务 await this.Scheduler.Result.ResumeJob(jk); await Console.Out.WriteLineAsync(string.Format("任务“{0}”恢复运行", jobName)); } } catch (Exception ex) { await Console.Out.WriteLineAsync(string.Format("恢复任务失败！{0}", ex)); } } /// <summary> /// 停止任务调度 /// </summary> public async void StopScheduleAsync() { try { //判断调度是否已经关闭 if (!this.Scheduler.Result.IsShutdown) { //等待任务运行完成 await this.Scheduler.Result.Shutdown(); await Console.Out.WriteLineAsync("任务调度停止！"); } } catch (Exception ex) { await Console.Out.WriteLineAsync(string.Format("任务调度停止失败！", ex)); } } /// <summary> /// 创建类型Simple的触发器 /// </summary> /// <param name="m"></param> /// <returns></returns> private ITrigger CreateSimpleTrigger(ScheduleEntity m) { //作业触发器 if (m.RunTimes > 0) { return TriggerBuilder.Create() .WithIdentity(m.JobName, m.JobGroup) .StartAt(m.BeginTime)//开始时间 .EndAt(m.EndTime)//结束数据 .WithSimpleSchedule(x => x .WithIntervalInSeconds(m.IntervalSecond)//执行时间间隔，单位秒 .WithRepeatCount(m.RunTimes))//执行次数、默认从0开始 .ForJob(m.JobName, m.JobGroup)//作业名称 .Build(); } else { return TriggerBuilder.Create() .WithIdentity(m.JobName, m.JobGroup) .StartAt(m.BeginTime)//开始时间 .EndAt(m.EndTime)//结束数据 .WithSimpleSchedule(x => x .WithIntervalInSeconds(m.IntervalSecond)//执行时间间隔，单位秒 .RepeatForever())//无限循环 .ForJob(m.JobName, m.JobGroup)//作业名称 .Build(); } } /// <summary> /// 创建类型Cron的触发器 /// </summary> /// <param name="m"></param> /// <returns></returns> private ITrigger CreateCronTrigger(ScheduleEntity m) { // 作业触发器 return TriggerBuilder.Create() .WithIdentity(m.JobName, m.JobGroup) .StartAt(m.BeginTime)//开始时间 .EndAt(m.EndTime)//结束数据 .WithCronSchedule(m.Cron)//指定cron表达式 .ForJob(m.JobName, m.JobGroup)//作业名称 .Build(); } } }
想了解项目整体信息的可以下载源码看看，欢迎dalao批评指导！
版权声明：本文为miskis原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。