前言:
最近做一个项目,需要用到定时任务,第一就想到了Quartz,然后很开心的就实现了功能,但是后来发现一个问题,如果需要开启多个定时任务,需要写多个辅助类,而辅助类里面的功能基本差不多,这是我就想
能不能用一个类开启多个定时任务,通过参数设定不同的参数,定时任务做不同的事情。说干就干。
1. 构建统一的创建Job的方法,代码如下
private static void GenerateJob<T>(string subkey, DateTimeOffset startTimeUtc, string id, string cronExpression) where T : IJob
{
Type t = typeof(T);
string name = t.Name + "-" + subkey;
IJobDetail job = JobBuilder.Create<T>()
.WithIdentity(name, "group_Job")
.StoreDurably(true)
.RequestRecovery(true)
.Build();
job.JobDataMap.Put(job.Key.Name.ToString(), id);
ICronTrigger trigger = (ICronTrigger)TriggerBuilder.Create()
.WithIdentity(name, "group_trigger")
.StartNow()
.WithCronSchedule(cronExpression, x => x.InTimeZone(TimeZoneInfo.Local))
.Build();
IJobListener jobListener = new JobTaskListener(name);
IMatcher<JobKey> matcher = KeyMatcher<JobKey>.KeyEquals(job.Key);
sched.ListenerManager.AddJobListener(jobListener, matcher);
sched.ScheduleJob(job, trigger);
}
通过不同的key构间和开启不同的Job,然后通过 job.JobDataMap.Put("id", id); 向定时任务传递参数,指定单独需要做的事情,
2.循环创建 定时任务
string ConsumerJobTime = "0/1 * * * * ?";//每秒执行一次
ISchedulerFactory sf = new StdSchedulerFactory(Config);
sched = await sf.GetScheduler(cts.Token);
DateTimeOffset startTimeUtc = DateBuilder.NextGivenSecondDate(null, 15);
JobStoreModel storeModel = new JobStoreModel();
for (int id = 0; id <= 3; id++)
{
GenerateJob<ConsumerJob>("ConsumerJob"+ id.ToString(), startTimeUtc, id.ToString(), ConsumerJobTime);
await sched.Start(cts.Token);
}
await sched.Start(cts.Token);
3.复用的辅助类,接收特定参数,执行特定任务。
public Task Execute(IJobExecutionContext context)
{
return System.Threading.Tasks.Task.Factory.StartNew(() =>
{
string id = context.JobDetail.JobDataMap.GetString("id");
Job(id);
});
}
public void Job(string id)
{
Console.WriteLine(id + ":时间" + DateTime.Now.ToString());
}
结果输出:
完美解决,不用傻兮兮的构建重复的辅助类,这就是典型的面向对象思维了。