Quartz.NET - 作业不运行？

Question

我正在尝试将 Quartz.NET 实现为 C# 中的 Windows 服务。当我期望它们触发时，我的工作并没有触发……实际上，据我所知，根本没有？

我的工作计划在下一个偶数分钟开始运行，并“每分钟”运行一次。然而，当下一分钟到来时，我似乎无法判断是否有任何东西真正运行。

我假设当我的作业运行时，在作业执行时会弹出一个 CLI 窗口，并且控制台操作将可见，（我什至在其中放置了一个 Console.ReadKey() 以确保该窗口不可见打开和关闭的速度不是那么快，我看不到它），但据我所知，时间表根本没有执行作业。

我注意到所有时间都是 UTC，并且 StartTimeUtc 将设置为 UTC 时间，距我的本地计算机时间 +6 小时，但我还假设 Quartz 调度程序会处理该时间通过根据我的时区设置计算执行时间，尽管我没有办法确认这一点，或者确认我的日程设置的实际时间。

我想有某种方法可以设置通用日志记录程序集并利用它来帮助我了解我的状态，但我还没有弄清楚如何使用它来启用任何类型的日志以获取来自我的 Windows 服务的反馈从写入我为其创建的事件日志。

我的 Windows 服务的 OnStart 函数

protected override void OnStart(string[] args)
    {
        eventLog.WriteEntry("--- STARTING eLoyalty Scheduler Service ---");

        // construct a scheduler factory
        ISchedulerFactory schedFact = new StdSchedulerFactory();

        // get a scheduler
        IScheduler sched = schedFact.GetScheduler();

        // construct job info
        JobDetail jobDetail = new JobDetail("eLoyaltySchedulerService", null, typeof(PortalSchedulerJob));
        jobDetail.JobDataMap["jobSays"] = "eLoyalty Scheduler Service Executing!";
        jobDetail.JobDataMap["myStateData"] = new ArrayList(); 

        // fire every minute
        Trigger trigger = TriggerUtils.MakeMinutelyTrigger();

        // start on the next even minute
        trigger.StartTimeUtc = TriggerUtils.GetEvenMinuteDate(DateTime.UtcNow);

        // name it
        trigger.Name = "NextEvenMinute";

        // schedule it
        sched.ScheduleJob(jobDetail, trigger);

        // start the schedule
        sched.Start();

        eventLog.WriteEntry("--- STARTED eLoyalty Scheduler Service ---");
    }

我的作业的 Execute() 函数如下：

public void Execute(JobExecutionContext context)
    {
        try
        {
            string instName = context.JobDetail.Name;
            string instGroup = context.JobDetail.Group;
            JobDataMap dataMap = context.MergedJobDataMap;
            string jobSays = dataMap.GetString("jobSays");
            ArrayList state = (ArrayList)dataMap["myStateData"];
            state.Add(DateTime.UtcNow);

            Console.WriteLine("Instance {0} of PortalSchedulerJob says: {1} @ {2}", instName, jobSays, DateTime.UtcNow);
            Console.ReadKey();
        }
        catch (JobExecutionException Ex)
        {
            throw Ex;
        }
    }

如果您能帮助我弄清楚如何对我的实际计划活动进行故障排除，我也许可以自己解决这个问题...？

Answer 1

在 Quartz.NET 任务中，您只能引发 JobExecutionException 异常：
Quartz.net- 第 3 课：

Job.Execute(..) 方法最后，我们
需要通知您一些细节
IJob.Execute(..) 方法。唯一的
允许您的例外类型
从执行方法抛出的是
JobExecutionException。由于
这，你通常应该包裹
执行方法的全部内容
带有“try-catch”块。你应该
也花一些时间看看
的文档
JobExecutionException，因为你的工作可以
用它来提供调度程序
各种指令，如你所愿
要处理的异常。

而不是：

catch (JobExecutionException Ex)
{
   throw Ex;
}

做这样的事情：

catch (Exception err)
{
    // Only allow JobExecutionException exceptions to be thrown...
    throw new Quartz.JobExecutionException(err);
}

然后你可以集中处理异常：

_globalJobListener = new GlobalJobListener();
sched.AddGlobalJobListener(_globalJobListener);


public class GlobalJobListener : Quartz.IJobListener
{
    public GlobalJobListener()
    {
    }

    public virtual string Name
    {
        get { return "MainJobListener"; }
    }

    public virtual void JobToBeExecuted(JobExecutionContext context)
    {       
    }

    public virtual void JobWasExecuted(JobExecutionContext inContext, JobExecutionException inException)
    {
        if (inException != null)
        {
            // Log/handle error here
        }
    }


    public virtual void JobExecutionVetoed(JobExecutionContext inContext)
    {

    }
}

Answer 2

调试时，您始终可以在控制台中运行 Windows 服务：

static class Program
{
    static void Main()
    {
        var servicesToRun = new ServiceBase[] 
            { 
                new CassetteDeckService() 
            };

        if (Environment.UserInteractive)
        {
            var type = typeof(ServiceBase);
            const BindingFlags flags = BindingFlags.Instance | BindingFlags.NonPublic;
            var method = type.GetMethod("OnStart", flags);

            foreach (var service in servicesToRun)
            {
                method.Invoke(service, new object[] { null });
            }

            Console.WriteLine("Service Started!");
            Console.ReadLine();

            method = type.GetMethod("OnStop", flags);

            foreach (var service in servicesToRun)
            {
                method.Invoke(service, null);
            }
            Environment.Exit(0);
        }
        else
        {
            ServiceBase.Run(servicesToRun);
        }
    }
}

只需确保在 Windows 服务项目的属性中将应用程序类型更改为控制台应用程序（这不会影响它作为 Windows 服务运行）不以交互模式运行）。

Answer 3

感谢大家的输入...不幸的是，我无法让这些工作正常工作，但是当我将事件记录器添加到我的作业执行函数中时，我发现它按预期每分钟写入事件日志。

我猜 Console.WriteLine() 和 Console.ReadKey() 函数在 Windows 服务环境中什么也不做？

注意：他们做了一些事情，但在后台作为服务运行而不是在控制台窗口中......

Answer 4

如果你想调试你的作业，请保持 Visual Studio 打开，在你的作业代码中输入：

System.Diagnostics.Debugger.Launch();

这将允许您附加到 Visual Studio 中的调试器，您可以看到发生了什么。

或者，如果您想让通用日志记录正常工作，请给我发一条消息，因为我在我的 Windows 服务中一切正常。

Answer 5

我们遇到了一些触发器失火的问题。我添加了一个全局触发器侦听器来捕获与解雇作业相关的事件，并提供调试问题所需的信息。

我们还通过 Common.Logging 连接 NLog 以捕获 Quartz 的内部日志记录（您可能会注意到我们自己使用 Simple Logging Facade ，因此该组件也在此处配置）。这是我们的应用程序配置，希望可以帮助您入门：

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
    <configSections>
        <section name="quartz" type="System.Configuration.NameValueSectionHandler, System, Version=1.0.5000.0,Culture=neutral, PublicKeyToken=b77a5c561934e089" />
        <section name="slf" type="Slf.Config.SlfConfigurationSection, slf"/>
        <sectionGroup name="common">
            <section name="logging" type="Common.Logging.ConfigurationSectionHandler, Common.Logging" />
        </sectionGroup>
    </configSections>


    <quartz>
        <add key="quartz.threadPool.threadCount" value="20" />
        <add key="quartz.jobStore.misfireThreshold" value="420000" /><!-- 7 minutes -->
    </quartz>


    <slf>
        <factories>
            <factory name="nlog" type="SLF.NLogFacade.NLogLoggerFactory, SLF.NLogFacade"/>
        </factories>

        <loggers>
            <logger factory="nlog"/>
        </loggers>
    </slf>

    <common>
        <logging>
            <factoryAdapter type="Common.Logging.NLog.NLogLoggerFactoryAdapter, Common.Logging.NLog">
                <arg key="configType" value="FILE" />
                <arg key="configFile" value="~/NLog.config" />
            </factoryAdapter>
        </logging>
    </common>

</configuration>