.Net Core实现基于Quart.Net的任务管理

之前的实现也是参考了博客园中其他文章实现的思路:

一个任务定义一个实现IJob接口的类,通过单独的dll管理;

通过数据库持久化、维护任务,便于服务重启时任务的恢复;

定义一个管理任务的基础服务,轮询数据库中的任务,根据任务的状态维护任务的执行;

新增任务时,需要在数据库中添加一条记录,并且在任务管理的dll中添加一个实现IJob的类,基础服务通过反射dll来构建任务的实例添加到调度器中

由于业务代码会频繁调整,我们业务代码从任务执行中拆分出来,独立部署成http服务,任务的执行就是调用一个http请求,这样不同的任务就是请求的url不一样,查看官方文档( )发现,我们可以通过只创建一个基础任务类,创建多个该任务类的实例来实现构建多个任务,IJobDetail中可以用JobDataMap对象来存储Job实例的参数,所以我们通过JobDataMap将请求url传递到任务的Execute()方法中,我们只需要在数据库中补充任务请求的url信息就可以了,不需要单独的dll去定义任务。

二、项目结构

根据上面思路,我们只需要一个管理任务的基础服务、一个Web管理平台就可以实现,为了保持项目简单,把任务管理无关的功能合并在一个项目里,并且尽量排除无关的框架和功能点,最终程序包含3个项目:

JobManage.Service:控制台程序,管理任务的基础服务,通过Topshelf部署成windows服务,如何部署参考: https://www.cnblogs.com/podolski/p/10054286.html

JobManage.Web:Web应用程序,管理平台,新增、暂停、恢复、删除任务,查看任务运行日志;

JobManage.Core:类库,提供业务基础服务,如数据库操作等

动态添加任务:

IJobDetail jobDetail = JobBuilder.Create<BaseJob>() .WithIdentity(jobKey) .UsingJobData("RequestUrl", job.RequestUrl) .Build(); ITrigger trigger = TriggerBuilder.Create() .WithIdentity(group, name) .StartNow() .WithCronSchedule(job.CronExpression) .Build(); await context.Scheduler.ScheduleJob(jobDetail, trigger);

基础任务类BaseJob.cs的Execute()方法:

public async Task Execute(IJobExecutionContext context) { var url = context.JobDetail.JobDataMap.GetString("RequestUrl"); var client = _clientFactory.CreateClient(); var request = new HttpRequestMessage(HttpMethod.Post, url); var response = await client.SendAsync(request); if (response.IsSuccessStatusCode) { await response.Content.ReadAsStringAsync(); } } 三、任务状态管理

这里定义7个任务状态:待执行、执行中、待暂停、已暂停、待恢复、待删除、已删除

web管理平台维护任务(新增、暂停、恢复、删除)时将任务状态更新为待处理状态(待执行、待暂停、待恢复、待删除),任务管理基础服务定时遍历业务任务,根据数据库中任务当前的状态修改任务的执行,并且将数据库中待处理任务状态更新为已处理状态(执行中、已暂停、已删除)

四、任务依赖注入服务

在任务类中我们用到了http服务,我们需要在任务类中获取http服务,我们通过.Net Core注入和获取服务的方式来实现,这里主要是要自定义任务类实例的创建和获取,官方文档( )中说明可以通过实现 IJobFactory 接口,并且修改 IScheduler.JobFactory的属性来实现:

//自定义任务实例获取 public class JobFactory : IJobFactory { private readonly IServiceProvider _serviceProvider; public JobFactory(IServiceProvider serviceProvider) { _serviceProvider = serviceProvider; } public virtual IJob NewJob(TriggerFiredBundle bundle, IScheduler scheduler) { IJobDetail jobDetail = bundle.JobDetail; Type jobType = jobDetail.JobType; return _serviceProvider.GetService(jobType) as IJob; } public virtual void ReturnJob(IJob job) { var disposable = job as IDisposable; disposable?.Dispose(); } } //修改IScheduler.JobFactory属性 _scheduler.JobFactory = serviceProvider.GetService<JobFactory>();

官方文档中也提供了依赖注入的示例:

五、任务监听

我们需要记录任务执行的情况,Quartz.Net提供了任务监听功能,我们可以自己实现IJobListener接口,也可以继承Quartz.Net框架中IJobListener的实现类JobListenerSupport来完成任务的监听,继承JobListenerSupport 类时重写对应的方法来实现我们需要的操作,如下实现记录任务上次执行时间、下次执行时间、执行时长、执行异常错误信息

//监听实现 public class JobListener : JobListenerSupport { private readonly JobRepository _jobRepository; private readonly JobRunLogRepository _jobRunLogRepository; public JobListener(JobRepository jobRepository, JobRunLogRepository jobRunLogRepository) { _jobRepository = jobRepository; _jobRunLogRepository = jobRunLogRepository; } public override string Name { get { return "jobListener"; } } public override async Task JobWasExecuted(IJobExecutionContext context, JobExecutionException jobException, CancellationToken cancellationToken = default) { string group = context.JobDetail.Key.Group; string name = context.JobDetail.Key.Name; DateTime fireTimeUtc = TimeZoneInfo.ConvertTimeFromUtc(context.FireTimeUtc.DateTime, TimeZoneInfo.Local); DateTime? nextFireTimeUtc = null; if (context.NextFireTimeUtc != null) { nextFireTimeUtc = TimeZoneInfo.ConvertTimeFromUtc(context.NextFireTimeUtc.Value.DateTime, TimeZoneInfo.Local); } if (!JobHelper.IsBaseJob(group, name)) { //更新任务执行情况 await _jobRepository.UpdateExecuteAsync(group, name, fireTimeUtc, nextFireTimeUtc); //记录运行日志 double totalSeconds = context.JobRunTime.TotalSeconds; bool succ = true; string exception = string.Empty; if (jobException != null) { succ = false; exception = jobException.ToString(); } JobRunLog log = new JobRunLog(group, name, totalSeconds, fireTimeUtc, succ, exception); await _jobRunLogRepository.InsertAsync(log); } } } //注册监听器 JobListener listener = serviceProvider.GetService<JobListener>(); _scheduler.ListenerManager.AddJobListener(listener, GroupMatcher<JobKey>.AnyGroup()); 六、总结

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/wpdyds.html