Quartz Scheduler:如何将自定义对象作为JobParameter传递

本文关键字：对象 JobParameter 传递 自定义 Scheduler Quartz | 更新日期: 2023-09-27 18:06:20

我计划写一个ASP。. NET页按需触发作业。目前，我正在使用SimpleTrigger类来触发作业，但__Trigger类都不支持对象类型作为JobParameters中的值，并且据我所知，钩子下使用WCF Tcp绑定将参数传递给作业调度引擎。我想知道如何传递自定义对象(可序列化)作为工作参数。谢谢你的建议!

Quartz Scheduler:如何将自定义对象作为JobParameter传递

有两种方法可以传递在Quartz作业执行时可以检索的对象:

传递数据映射中的实例。设置作业时，使用如下键将实例添加到映射中:

// Create job etc...
var MyClass _myInstance;
statusJob.JobDataMap.Put("myKey", _myInstance);
// Schedule job...

像这样在作业的Execute()方法中检索实例:

public void Execute(IJobExecutionContext context)
        {
            var dataMap = context.MergedJobDataMap;
            var myInstance = (MyClass)dataMap["myKey"];

或

在设置作业时将实例添加到调度器上下文，如下所示:

  ISchedulerFactory schedFact = new StdSchedulerFactory();
  _sched = schedFact.GetScheduler();
  _sched.Start();
  // Create job etc...
  var MyClass _myInstance;
  _sched.Context.Put("myKey", myInstance);
  // Schedule job...

像这样在作业的Execute()方法中检索实例:

public void Execute(IJobExecutionContext context)
        {
            var schedulerContext = context.Scheduler.Context;
            var myInstance = (MyClass)schedulerContext.Get("myKey");

调度作业时，可以在JobDetail对象上设置JobDataMap并将其传递给调度程序，但在quartz.net教程中描述了一些限制。作业可以通过以下方式访问数据:

JobDataMap dataMap = context.JobDetail.JobDataMap;

然而，我更喜欢通过注入到作业中的存储库来访问我的作业配置。

我在多线程环境中使用hillstuk的答案得到了意想不到的结果。这是我使用Newtonsoft的解决方案…

public void InitJob() {
    MyClass data = new MyClass {Foo = “Foo fighters”}; 
    /* a unique identifier for demonstration purposes.. Use your own concoction here. */
    int uniqueIdentifier = new Random().Next(int.MinValue, int.MaxValue); 
    IJobDetail newJob = JobBuilder.Create<MyAwesomeJob>()
    .UsingJobData("JobData", JsonConvert.SerializeObject(data))
    .WithIdentity($"job-{uniqueIdentifier}", "main")                
    .Build();
}
/* the execute method */
public class MyAwesomeJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {                   
        var jobData = JsonConvert.DeserializeObject<MyClass>(context.JobDetail.JobDataMap.GetString("JobData"));    
    }
}
/* for completeness */
public class MyClass {
    string Foo { get; set; } 
}

可以将实例/对象放在IJobDetail中。

 JobDataMap m = new JobDataMap();
  m.Put("Class1", new Class1(){name="xxx"});

  IJobDetail job = JobBuilder.Create<Job>()
            .WithIdentity("myJob", "group1")
            .UsingJobData(m)//class object
            .UsingJobData("name2", "Hello World!")
            .Build();
使用

  public void Execute(IJobExecutionContext context)
        {
 JobDataMap dataMap = context.JobDetail.JobDataMap;
            Class1 class1 = (Class1)dataMap.Get("Class1");
string x = class1.name;
}

我通过以下方式传递对象

JobDetail job1 = JobBuilder.newJob(JobAutomation.class)
                .usingJobData("path", path)
                .withIdentity("job2", "group2").build();
        CronTrigger trigger1 = TriggerBuilder.newTrigger()
                .withIdentity("cronTrigger2", "group2")
                .withSchedule(CronScheduleBuilder.cronSchedule("40 27 11 * * ?"))
                .build();

通过以下代码行获取jobdatamap 

JobDataMap dataMap = context.getJobDetail().getJobDataMap();
String path =dataMap.getString("path");
相关文章：