Asp.net 怎样使用任务调治

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

1. public class MvcApplication : System.Web.HttpApplication
2. {
3.     private static IScheduler _scheduler;
4.     private ScheduleJobsManager  _jobMana;
5.     protected void Application_Start()
6.     {
7.         
9.         var factory = new StdSchedulerFactory();
10.       
11.         _scheduler = factory.GetScheduler();
12.         _scheduler.Start();
13.         _jobMana = new ScheduleJobsManager(_scheduler);
14.       
15.         RegisterJobs();
20.       
23.     }
25. //在网站启动的时候，将数据库中正在运行状态的任务，启动起来
26. private  void RegisterJobs()
27. {
28.      var list = _jobMana.GetList(s => s.JobStatus == "Running");
29.      foreach (var job in list)
30.      {
31.          _jobMana.AddJob(job);
33.      }
35. }
37. //这个方法，是在其他地方使用的，相当于 单例模式，全局只有这一个调度器
38. public static IScheduler GetScheduler()
39. {
40.      return _scheduler;
41. }
43. }

复制代码

接下来说下，管理任务调治的控制器和界面
控制器这样写：

1. private  IScheduler _scheduler = MvcApplication.GetScheduler();//这个就是Global中的那个静态方法
2. private ScheduleJobsManager _scheduleJobsManager; //这个是对任务调度的一个封装，也是操作数据的操作类，后面会给代码
3. private JobLogsManager _jobLog = new JobLogsManager();  //这个是与数据库对用的Job日志操作类
5. //初始化控制器，需要给调度管理进行初始化
6. public JobController()
7. {
8.      _scheduleJobsManager = new ScheduleJobsManager(_scheduler);
9. }
12. public ActionResult Add(ScheduleJobs job)
13. {
14.      job.JobStatus = "Running";
15.      job.CreateTime = DateTime.Now;
16.      _scheduleJobsManager.Insert(job);
18.      _scheduleJobsManager.AddJob(job);
22.      return Json(new { code = 0, msg = "添加成功" });
23. }
25. public ActionResult Pause(int id)
26. {
27.      try
28.      {
29.         if( _scheduleJobsManager.PauseJob(id))
30.          {
31.              return Json(new { code = 0, msg = "暂停成功" });
32.          }
33.          else
34.          {
35.              return Json(new { code = 500, msg = "暂停失败" });
36.          }
37.         
38.      }
39.      catch (Exception ex)
40.      {
41.          return Json(new { code = 500, msg = "暂停失败：" + ex.Message });
42.      }
43. }
47. [HttpPost]
48. public ActionResult Resume(int id)
49. {
50.      try
51.      {
52.          if(_scheduleJobsManager.ResumeJob(id))
53.          {
54.              return Json(new { code = 0, msg = "恢复成功" });
55.          }
56.          return Json(new { code = 500, msg = "恢复失败"  });
57.      }
58.      catch (Exception ex)
59.      {
60.          return Json(new { code = 500, msg = "恢复失败：" + ex.Message });
61.      }
62. }
66. [HttpPost]
67. public ActionResult Delete(int Id)
68. {
69.      var info = _scheduleJobsManager.GetById(Id);
70.      if (_scheduleJobsManager.Delete(s => s.Id == Id))
71.      {
72.          _scheduleJobsManager.DeleteJob(info);
73.          return Json(new { code = 0, msg = "删除成功" });
74.      }
75.      else
76.      {
77.          return Json(new { code = -1, msg = "删除失败" });
78.      }
79. }
82. [HttpPost]
83. public ActionResult Edit(ScheduleJobs job)
84. {
85.      var existingJob =_scheduleJobsManager.GetById(job.Id);
86.      if (existingJob == null)
87.          throw new Exception("任务不存在");
89.      try
90.      {
91.          // 删除旧的任务
92.           _scheduler.DeleteJob(new JobKey(existingJob.JobName, existingJob.JobGroup));
94.          // 创建新的任务
95.          _scheduleJobsManager.AddJob(job);
96.          existingJob.JobName = job.JobName;
97.          existingJob.JobGroup = job.JobGroup;
98.          existingJob.JobClassName = job.JobClassName;
99.          existingJob.AssemblyName = job.AssemblyName;
100.          existingJob.CronExpression = job.CronExpression;
101.          existingJob.Description = job.Description;
102.          
103.          _scheduleJobsManager.Update(existingJob);
104.          return Json(new { code = 0, msg = "更新成功" });
105.      }
106.      catch (Exception ex)
107.      {
108.          return Json(new { code = 500, msg = "更新失败：" + ex.Message });
109.      }
110. }

复制代码

ScheduleJobsManager.cs

1. public class ScheduleJobsManager : DbContext<ScheduleJobs>
2. {
4.     //当前类已经继承了 DbContext增、删、查、改的方法
5.     private readonly IScheduler _scheduler ;
6.     public ScheduleJobsManager(IScheduler scheduler) {
7.         _scheduler = scheduler ;
8.     }
10.     public void RunJobOnce(int id)
11.     {
12.         var job = GetById(id);
13.         if (job == null)
14.             throw new Exception("任务不存在");
16.         var jobKey = new JobKey(job.JobName, job.JobGroup);
17.         _scheduler.TriggerJob(jobKey);
18.     }
20.     private IJobDetail CreateJobDetail(ScheduleJobs jobInfo)
21.     {
22.         // 获取任务类型
23.         Type jobType;
24.         if (string.IsNullOrEmpty(jobInfo.AssemblyName))
25.         {
26.             // 从当前程序集获取类型
27.             jobType = Type.GetType(jobInfo.JobClassName);
28.         }
29.         else
30.         {
31.             // 从指定程序集加载类型
32.             var assembly = Assembly.Load(jobInfo.AssemblyName);
33.             jobType = assembly.GetType(jobInfo.JobClassName);
34.         }
36.         if (jobType == null)
37.         {
38.             throw new Exception($"找不到任务类型：{jobInfo.JobClassName}");
39.         }
41.         // 验证类型是否实现IJob接口
42.         if (!typeof(IJob).IsAssignableFrom(jobType))
43.         {
44.             throw new Exception($"任务类型 {jobInfo.JobClassName} 必须实现IJob接口");
45.         }
47.         // 创建任务详情
48.         return JobBuilder.Create(jobType)
49.             .WithIdentity(jobInfo.JobName, jobInfo.JobGroup)
50.             .WithDescription(jobInfo.Description)
51.             .UsingJobData("jobId", jobInfo.Id)  // 传递任务ID
52.             .Build();
53.     }
55.     public void AddJob(ScheduleJobs job)
56.     {
57.         try
58.         {
59.             // 创建任务
60.             var jobDetail = CreateJobDetail(job);
62.             var trigger = TriggerBuilder.Create()
63.                 .WithIdentity($"{job.JobName}_trigger", job.JobGroup)
64.                 .WithCronSchedule(job.CronExpression)
65.                 .Build();
67.             // 添加到调度器
68.             _scheduler.ScheduleJob(jobDetail, trigger);
70.         }
71.         catch (Exception ex)
72.         {
73.             throw new Exception($"添加任务失败: {ex.Message}", ex);
74.         }
75.     }
77.     public bool PauseJob(int id)
78.     {
79.         
80.         var job = GetById(id);
81.          _scheduler.PauseJob(new JobKey(job.JobName, job.JobGroup));
82.         job.JobStatus = "Paused";
83.         return Update(job);
87.     }
89.     public bool ResumeJob(int id)
90.     {
91.       
92.         
93.             var job = GetById(id);
94.             _scheduler.ResumeJob(new JobKey(job.JobName, job.JobGroup));
95.             job.JobStatus = "Running";
96.             return Update(job);
97.            
98.          
99.         
100.     }
102.     public void DeleteJob(ScheduleJobs job)
103.     {
104.         
105.       
106.              _scheduler.DeleteJob(new JobKey(job.JobName, job.JobGroup));
107.            
108.         
109.     }
112.   
114. }

复制代码

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

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。