棘手的Quartz.NET场景

Question

好的,这里有一点背景.我有一个大型的Web应用程序(MVC3),它可以完成各种不重要的工作.我需要这个Web应用程序才能在Oracle数据库中安排特定的Quartz.NET作业.然后,我希望稍后通过Windows服务执行作业.理想情况下,我想安排它们以均匀的间隔运行,但可以选择通过Web应用程序添加作业.

基本上,所需的架构是这方面的一些变化:

Web应用程序< - > Quartz.NET < - >数据库< - > Quartz.NET < - > Windows服务

到目前为止我编写的内容:

• 一个Windows服务(现在)调度并运行作业.从长远来看,这显然不会是这种情况,但我想知道我是否可以保留这个并修改它以使它基本上代表上图中的"Quartz.NET".
• 网络应用程序(我猜这里的细节不是很重要)
• 这些工作(实际上只是另一个 Windows服务)

还有几个重要的注意事项:

• 它必须从Windows服务运行,并且它必须通过Web应用程序进行安排(以减少IIS上的负载)
• 假设上述子弹仍然适用,上面的架构可以稍微重新排列.

现在,几个问题:

1. 这甚至可能吗？
2. 假设(1)通过,你认为最好的架构是什么？请参阅我编码的第一个项目符号.
3. 有人可能会给我一些Quartz方法,这些方法可以帮助我查询数据库,以便在计划完成后执行作业吗？

只要符合条件,这个问题就会得到赏金.如果在此之前以令人满意的方式回答问题,我仍然会将奖励奖励给答案的海报.所以,无论如何,如果你在这里给出一个好的答案,你将获得赏金.

Answer 1

我会按照你的顺序回答你的问题.

1. 是的,可以这样做.这实际上是使用Quartz.Net的常用方法.实际上,您还可以编写一个管理Quartz.Net调度程序的ASP.Net MVC应用程序.

2. 建筑.理想情况下,您的MVC应用程序将使用Quartz.Net API与某个安装为Windows服务的Quartz.Net服务器进行通信.Quartz.Net使用远程处理进行远程通信,因此使用远程处理的任何限制都适用(如Silverlight不支持,等等).Quartz.Net提供了一种方法来安装它作为Windows服务开箱即用,所以真的没有在这里做了很多工作,不是配置服务本身使用(你的情况)的AdoJobStore,也使其他远程处理.如何正确安装服务需要注意,所以如果你还没有这样做,请看看这篇文章.

在内部,在MVC应用程序中,您将希望获得对调度程序的引用并将其存储为单例.然后在您的代码中,您将通过此唯一实例调度作业并获取有关调度程序的信息.你可以使用这样的东西:

public class QuartzScheduler
{
    public QuartzScheduler(string server, int port, string scheduler)
    {
        Address = string.Format("tcp://{0}:{1}/{2}", server, port, scheduler);
        _schedulerFactory = new StdSchedulerFactory(getProperties(Address));

        try
        {
            _scheduler = _schedulerFactory.GetScheduler();
        }
        catch (SchedulerException)
        {
            MessageBox.Show("Unable to connect to the specified server", "Connection Error", MessageBoxButtons.OK, MessageBoxIcon.Exclamation);
        }
    }
    public string Address { get; private set; }
    private NameValueCollection getProperties(string address)
    {
        NameValueCollection properties = new NameValueCollection();
        properties["quartz.scheduler.instanceName"] = "RemoteClient";
        properties["quartz.scheduler.proxy"] = "true";
        properties["quartz.threadPool.threadCount"] = "0";
        properties["quartz.scheduler.proxy.address"] = address;
        return properties;
    }
    public IScheduler GetScheduler()
    {
        return _scheduler;
    }
}

此代码设置Quart.Net客户端.然后要访问远程调度程序,只需调用即可

GetScheduler()

1. 查询以下是从调度程序获取所有作业的示例代码:

   public DataTable GetJobs()
   {
       DataTable table = new DataTable();
       table.Columns.Add("GroupName");
       table.Columns.Add("JobName");
       table.Columns.Add("JobDescription");
       table.Columns.Add("TriggerName");
       table.Columns.Add("TriggerGroupName");
       table.Columns.Add("TriggerType");
       table.Columns.Add("TriggerState");
       table.Columns.Add("NextFireTime");
       table.Columns.Add("PreviousFireTime");
       var jobGroups = GetScheduler().GetJobGroupNames();
       foreach (string group in jobGroups)
       {
           var groupMatcher = GroupMatcher<JobKey>.GroupContains(group);
           var jobKeys = GetScheduler().GetJobKeys(groupMatcher);
           foreach (var jobKey in jobKeys)
           {
               var detail = GetScheduler().GetJobDetail(jobKey);
               var triggers = GetScheduler().GetTriggersOfJob(jobKey);
               foreach (ITrigger trigger in triggers)
               {
                   DataRow row = table.NewRow();
                   row["GroupName"] = group;
                   row["JobName"] = jobKey.Name;
                   row["JobDescription"] = detail.Description;
                   row["TriggerName"] = trigger.Key.Name;
                   row["TriggerGroupName"] = trigger.Key.Group;
                   row["TriggerType"] = trigger.GetType().Name;
                   row["TriggerState"] = GetScheduler().GetTriggerState(trigger.Key);
                   DateTimeOffset? nextFireTime = trigger.GetNextFireTimeUtc();
                   if (nextFireTime.HasValue)
                   {
                       row["NextFireTime"] = TimeZone.CurrentTimeZone.ToLocalTime(nextFireTime.Value.DateTime);
                   }
   
                   DateTimeOffset? previousFireTime = trigger.GetPreviousFireTimeUtc();
                   if (previousFireTime.HasValue)
                   {
                       row["PreviousFireTime"] = TimeZone.CurrentTimeZone.ToLocalTime(previousFireTime.Value.DateTime);
                   }
   
                   table.Rows.Add(row);
               }
           }
       }
       return table;
   }
   

您可以在Github上查看此代码