使用Quartz.NET处理链接作业的失败

本文关键字：作业 失败 链接 处理 Quartz NET 使用 | 更新日期: 2023-09-27 18:05:21

我可以使用Quartz.NET调度3个链式作业。这个策略运行良好:

var j1 = new TestJob1();
var j2 = new TestJob2();
var j3 = new TestJob3();
var jd1 = j1.Build();
var jd2 = j2.Build();
var jd3 = j3.Build();

var chain = new JobChainingJobListener("jobchain");
chain.AddJobChainLink(jd1.Key, jd2.Key);
chain.AddJobChainLink(jd2.Key, jd3.Key);

Scheduler.ListenerManager.AddJobListener(chain, GroupMatcher<JobKey>.AnyGroup());
Scheduler.ScheduleJob(jd1, j1.JobTrigger());
Scheduler.AddJob(jd2, true);
Scheduler.AddJob(jd3, true);

Scheduler.Start();

每个作业的代码如下:

public class TestJob1 : BaseJob, IJob
    {
        public override ITrigger JobTrigger()
        {
             return TriggerBuilder.Create()
                 .WithSimpleSchedule(
                     ssb =>
                     ssb.WithInterval(new TimeSpan(0, 0, 0, 10)).RepeatForever().WithMisfireHandlingInstructionFireNow())
                 .Build();
        }
        public void Execute(IJobExecutionContext context)
        {
            Debug.WriteLine($"Running Job 1 at {DateTime.Now.ToString("O")}");
        }
    }
    public class TestJob2 : BaseJob, IJob
    {
        public override ITrigger JobTrigger()
        {
            throw new System.NotImplementedException();
        }
        public void Execute(IJobExecutionContext context)
        {
            Debug.WriteLine($"Running Job 2 at {DateTime.Now.ToString("O")}");
            throw new Exception("forced error");
        }
    }
    public class TestJob3 : BaseJob, IJob
    {
        public override ITrigger JobTrigger()
        {
            throw new System.NotImplementedException();
        }
        public void Execute(IJobExecutionContext context)
        {
            Debug.WriteLine($"Running Job 3 at {DateTime.Now.ToString("O")}");
        }
    }

如果您看到，TestJob2在运行时抛出异常。即使在这种情况下，也会触发TestJob3。我的业务需求是，如果TestJob2失败，不应该触发TestJob3。注意，实际上我不需要实现job2和job3的触发器，因为我将这些没有触发器的作业添加到调度器中。

如何做到这一点?

提前感谢，马里奥

使用Quartz.NET处理链接作业的失败

子类JobChainingJobListener，并使用JobChainingJobListenerFailOnError代替JobChainingJobListener:

/// <summary>
/// JobChainingJobListener that doesn't run subsequent jobs when one fails.
/// </summary>
public class JobChainingJobListenerFailOnError : JobChainingJobListener
{
    public JobChainingJobListenerFailOnError(String name) : base(name) { }
    public override void JobWasExecuted(IJobExecutionContext context, JobExecutionException jobException)
    {
        //Only call the base method if jobException is null.  Otherwise, an
        //error has occurred & we don't want to continue chaining
        if (jobException == null)
            base.JobWasExecuted(context, jobException);
    }
}

虽然JobChain对我来说是新的，但我仍然会使用基本clr api调用，并通过链接任务(https://msdn.microsoft.com/en-us/library/ee372288(v=vs.110).aspx)来利用任务并行库(tpl)。

这个特殊的代码将四个不同的任务链接在一起，并且没有先前的完成就不能启动。我想让Quartz做的就是安排和调用我的工作。如果我偏离了quartz api，我很抱歉，但我只是想提供一种处理多个任务的方法。

在我的作业中，我输入作业Execute和Execute调用Process()

private async Task<Boolean> Process()
{   
   Task<bool> t1 = Task<bool>.Factory.StartNew(() =>
   {
      return processThis();
   });

   Task<bool> t2 = t1.ContinueWith((ProcessMore) =>
   {
      return processMoreStuff();
   });
   Task<bool> t3 = t2.ContinueWith((ProcessEvenMore) =>
   {
      return processEvenMoreStuff();
   });
   Task<bool> t4 = t3.ContinueWith((ProcessStillSomeMore) =>
   {
      return processStillMoreStuff();
   });

    var result = await t4;
   try
   {
      Task.WaitAll(t1, t2, t3, t4);
   }
   catch (Exception ex)
   {
      System.Diagnostics.Trace.WriteLine(ex.Message);
   }
   return result;
}

过去我必须链接作业，但我没有使用JobChainingJobListener。我要做的就是在(n)个任务完成时添加并调度(n+1)个任务。例如，当下一个要执行的作业依赖于当前作业的结果时(就像您的情况一样)，这很有帮助。

要继续使用JobChainingJobListener，我认为您可以获得TestJob3并在其数据映射中设置一个标志，当TestJob2成功结束时。当TestJob2出现异常时，TestJob3仍然会被执行，但你只需要检查你的标志，看看它是否需要继续执行。

相关文章：