Asp.net 如何使用任务调度

首先需要再 Global文件中，创建调度器，哎呀，直接上代码吧

public class MvcApplication : System.Web.HttpApplication
{private static IScheduler _scheduler;private ScheduleJobsManager  _jobMana;protected void Application_Start(){var factory = new StdSchedulerFactory();_scheduler = factory.GetScheduler();_scheduler.Start();_jobMana = new ScheduleJobsManager(_scheduler);RegisterJobs();}//在网站启动的时候，将数据库中正在运行状态的任务，启动起来private  void RegisterJobs(){var list = _jobMana.GetList(s => s.JobStatus == "Running");foreach (var job in list){_jobMana.AddJob(job);}}//这个方法，是在其他地方使用的，相当于 单例模式，全局只有这一个调度器public static IScheduler GetScheduler(){return _scheduler;}}

接下来说下，管理任务调度的控制器和界面

控制器这样写：

 private  IScheduler _scheduler = MvcApplication.GetScheduler();//这个就是Global中的那个静态方法private ScheduleJobsManager _scheduleJobsManager; //这个是对任务调度的一个封装，也是操作数据的操作类，后面会给代码private JobLogsManager _jobLog = new JobLogsManager();  //这个是与数据库对用的Job日志操作类//初始化控制器，需要给调度管理进行初始化public JobController(){_scheduleJobsManager = new ScheduleJobsManager(_scheduler);}public ActionResult Add(ScheduleJobs job){job.JobStatus = "Running";job.CreateTime = DateTime.Now;_scheduleJobsManager.Insert(job);_scheduleJobsManager.AddJob(job);return Json(new { code = 0, msg = "添加成功" });}public ActionResult Pause(int id){try{if( _scheduleJobsManager.PauseJob(id)){return Json(new { code = 0, msg = "暂停成功" });}else{return Json(new { code = 500, msg = "暂停失败" });}}catch (Exception ex){return Json(new { code = 500, msg = "暂停失败：" + ex.Message });}}[HttpPost]public ActionResult Resume(int id){try{if(_scheduleJobsManager.ResumeJob(id)){return Json(new { code = 0, msg = "恢复成功" });}return Json(new { code = 500, msg = "恢复失败"  });}catch (Exception ex){return Json(new { code = 500, msg = "恢复失败：" + ex.Message });}}[HttpPost]public ActionResult Delete(int Id){var info = _scheduleJobsManager.GetById(Id);if (_scheduleJobsManager.Delete(s => s.Id == Id)){_scheduleJobsManager.DeleteJob(info);return Json(new { code = 0, msg = "删除成功" });}else{return Json(new { code = -1, msg = "删除失败" });}}[HttpPost]public ActionResult Edit(ScheduleJobs job){var existingJob =_scheduleJobsManager.GetById(job.Id);if (existingJob == null)throw new Exception("任务不存在");try{// 删除旧的任务_scheduler.DeleteJob(new JobKey(existingJob.JobName, existingJob.JobGroup));// 创建新的任务_scheduleJobsManager.AddJob(job);existingJob.JobName = job.JobName;existingJob.JobGroup = job.JobGroup;existingJob.JobClassName = job.JobClassName;existingJob.AssemblyName = job.AssemblyName;existingJob.CronExpression = job.CronExpression;existingJob.Description = job.Description;_scheduleJobsManager.Update(existingJob);return Json(new { code = 0, msg = "更新成功" });}catch (Exception ex){return Json(new { code = 500, msg = "更新失败：" + ex.Message });}}

ScheduleJobsManager.cs

public class ScheduleJobsManager : DbContext<ScheduleJobs>
{//当前类已经继承了 DbContext增、删、查、改的方法private readonly IScheduler _scheduler ;public ScheduleJobsManager(IScheduler scheduler) {_scheduler = scheduler ;}public void RunJobOnce(int id){var job = GetById(id);if (job == null)throw new Exception("任务不存在");var jobKey = new JobKey(job.JobName, job.JobGroup);_scheduler.TriggerJob(jobKey);}private IJobDetail CreateJobDetail(ScheduleJobs jobInfo){// 获取任务类型Type jobType;if (string.IsNullOrEmpty(jobInfo.AssemblyName)){// 从当前程序集获取类型jobType = Type.GetType(jobInfo.JobClassName);}else{// 从指定程序集加载类型var assembly = Assembly.Load(jobInfo.AssemblyName);jobType = assembly.GetType(jobInfo.JobClassName);}if (jobType == null){throw new Exception($"找不到任务类型：{jobInfo.JobClassName}");}// 验证类型是否实现IJob接口if (!typeof(IJob).IsAssignableFrom(jobType)){throw new Exception($"任务类型 {jobInfo.JobClassName} 必须实现IJob接口");}// 创建任务详情return JobBuilder.Create(jobType).WithIdentity(jobInfo.JobName, jobInfo.JobGroup).WithDescription(jobInfo.Description).UsingJobData("jobId", jobInfo.Id)  // 传递任务ID.Build();}public void AddJob(ScheduleJobs job){try{// 创建任务var jobDetail = CreateJobDetail(job);var trigger = TriggerBuilder.Create().WithIdentity($"{job.JobName}_trigger", job.JobGroup).WithCronSchedule(job.CronExpression).Build();// 添加到调度器_scheduler.ScheduleJob(jobDetail, trigger);}catch (Exception ex){throw new Exception($"添加任务失败: {ex.Message}", ex);}}public bool PauseJob(int id){var job = GetById(id);_scheduler.PauseJob(new JobKey(job.JobName, job.JobGroup));job.JobStatus = "Paused";return Update(job);}public bool ResumeJob(int id){var job = GetById(id);_scheduler.ResumeJob(new JobKey(job.JobName, job.JobGroup));job.JobStatus = "Running";return Update(job);}public void DeleteJob(ScheduleJobs job){_scheduler.DeleteJob(new JobKey(job.JobName, job.JobGroup));}}

View界面就是简单的添加修改删除，用的layui框架做的，这个就做代码了，自己用自己的框架做吧