如何使作业在Quartz.Net中引发EventHandler

本文关键字:EventHandler Net Quartz 何使 作业 | 更新日期: 2023-09-27 18:20:07

我有一个控制台应用程序,它实例化了Quartz调度器
我想要一个引发事件处理程序的作业,以便"母亲应用程序"调用特定的方法
问题是,Job类似乎与外部类非常孤立
我确信有一个好方法可以做到这一点,但我还没有偶然发现。

public class RestartJob : IJob
{        
    public RestartJob()
    {
    }
    public virtual void Execute(IJobExecutionContext context)
    {
        //Send Restart EventHandler Subscription to Console.            
    }
}

如何使作业在Quartz.Net中引发EventHandler

我通过在包含Scheduler Logic的类上实现一个singleton解决了我的问题。很有魅力。希望这能帮助其他人解决在我看来"必备"的功能。

public class Skeduler
{
    private static Skeduler instance;
    public static Skeduler Instance
    {
        get
        {
            if (instance == null)
            {
                instance = new Skeduler();
            }
            return instance;
        }
    }
    public delegate void SendRestartX();
    public event SendRestartX SendRestart;
    public void doSendRestart()
    {
        if (SendRestart!=null)
            SendRestart();
    }
    //(Job Methods & Logics Goes Here)
 }
public class RestartJob : IJob
{
    //Required
    public RestartJob()
    {
    }
    public virtual void Execute(IJobExecutionContext context)
    {
        Skeduler.Instance.doSendRestart();
    }
}

用法:

    public MainClass
    {   
        public void Run()
        {
          skeduler = Skeduler.Instance;
          skeduler.SendRestart += new Skeduler.SendRestartX(MethodToCall);
        }
    }

您可以在JobDataMap中传递事件处理程序,然后使用作业中的事件处理程序。

创建作业时

IJobDetail job = JobBuilder.Create<RestartJob>().WithIdentity("job"), "group")
        .SetJobData(new JobDataMap{{"event-handler", YourEventHandler}});

在你的工作类:

public class RestartJob : IJob
{        
    public RestartJob()
    {
    }
    public virtual void Execute(IJobExecutionContext context)
    {
        var @event = context.JobDetail.JobData["event-handler"];
        @event?.Invoke(YourEventParameters); 
    }
}

您可以尝试以下操作:创建IJobDetail:

IJobDetail job = JobBuilder.Create<LogJob>().WithIdentity("job"), "group")
        .UsingJobData("id", 123).Build();
job.JobDataMap["SOMENAME"] = this;

用法:

public void Execute(IJobExecutionContext context) {
    JobDataMap dataMap = context.JobDetail.JobDataMap;
    CLASSNAME SOMENAME = dataMap["SOMENAME"] as MediaPlaylistsAds;
    int id = (int)dataMap["id"];
    SOMENAME.SOMEFUNC(id);
}