Quartz.Net スケジューリング フレームワークの構成例の詳細な紹介

この記事では主に Quartz.Net スケジューリング フレームワークの設定方法を詳しく紹介します。興味のある方は参考にしてください。スケジュールされたポーリングデータベース同期、スケジュールされた電子メール通知など。誰もが Windows のスケジュールされたタスク、Windows サービスなどを通じてそのようなタスクを実装し、独自にカスタマイズした構成フレームワークを実装することもありました。そこで今日は、オープンソースのスケジューリングフレームワークである Quartz.Net を紹介します（友人からそのような質問があったため、主に設定の実装を紹介します）。スケジューリングの実装コードは非常に単純です。ソース コードには多くのデモがありますが、ここでは省略します。

Quartz.Netの最新バージョンはQuartz.NET 2.0 beta 1リリースです

1.ファイルベースの設定

まず簡単な実装コードを見てみましょう

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using Quartz;
using Quartz.Impl;
using Common.Logging;

namespace Demo
{
 class Program
 {
  static void Main(string[] args)
  {
   
   // First we must get a reference to a scheduler
   ISchedulerFactory sf = new StdSchedulerFactory();
   IScheduler sched = sf.GetScheduler();
   
   sched.Start();   
   sched.Shutdown(true);
   
  }
 }
}

コードは非常にシンプルです、構成ファイル内の Quartz の基本構成、およびジョブとトリガーの情報はどのようにロードされますか?このプロセスは IScheduler sched = sf.GetScheduler(); で発生し、これは主にソース コードに反映されます。上記のコード分析を通じて、初期化ではまずシステム構成に 9b4c701a111f87c1cd1643746af7699b 構成セクション ノードがあるかどうかを確認します。 app.config、web.config に)。システム構成に Quartz ノードがある場合、ここの構成情報が直接ロードされます。システム構成に Quartz の基本構成情報がない場合は、quartz.config/Quartz.quartz.config の 2 つの構成ファイルの存在を探し続けます。存在する場合は、構成情報がロードされます。初期化構成例外がスローされます。

そしてjobs.xmlのプラグイン設定(スケジュールされたタスクとトリガープラグインノード設定ファイル)

app.config/web.config

 public void Initialize()
  {
   // short-circuit if already initialized
   if (cfg != null)
   {
    return;
   }
   if (initException != null)
   {
    throw initException;
   }

   NameValueCollection props = (NameValueCollection) ConfigurationManager.GetSection("quartz");

   string requestedFile = Environment.GetEnvironmentVariable(PropertiesFile);
   string propFileName = requestedFile != null && requestedFile.Trim().Length > 0 ? requestedFile : "~/quartz.config";

   // check for specials
   propFileName = FileUtil.ResolveFile(propFileName);

   if (props == null && File.Exists(propFileName))
   {
    // file system
    try
    {
     PropertiesParser pp = PropertiesParser.ReadFromFileResource(propFileName);
     props = pp.UnderlyingProperties;
     Log.Info(string.Format("Quartz.NET properties loaded from configuration file '{0}'", propFileName));
    }
    catch (Exception ex)
    {
     Log.Error("Could not load properties for Quartz from file {0}: {1}".FormatInvariant(propFileName, ex.Message), ex);
    }

   }
   if (props == null)
   {
    // read from assembly
    try
    {
     PropertiesParser pp = PropertiesParser.ReadFromEmbeddedAssemblyResource("Quartz.quartz.config");
     props = pp.UnderlyingProperties;
     Log.Info("Default Quartz.NET properties loaded from embedded resource file");
    }
    catch (Exception ex)
    {
     Log.Error("Could not load default properties for Quartz from Quartz assembly: {0}".FormatInvariant(ex.Message), ex);
    }
   }
   if (props == null)
   {
    throw new SchedulerConfigException(
     @"Could not find <quartz> configuration section from your application config or load default configuration from assembly.
Please add configuration to your application config file to correctly initialize Quartz.");
   }
   Initialize(OverrideWithSysProps(props));
  }

quartz.configは(quartz.plugin.xml.type/quartzを指します) .plugin.xml.fileNames)

 <quartz>
  <add key="quartz.scheduler.instanceName" value="ExampleDefaultQuartzScheduler"/>
  <add key="quartz.threadPool.type" value="Quartz.Simpl.SimpleThreadPool, Quartz"/>
  <add key="quartz.threadPool.threadCount" value="10"/>
  <add key="quartz.threadPool.threadPriority" value="2"/>
  <add key="quartz.jobStore.misfireThreshold" value="60000"/>
  <add key="quartz.jobStore.type" value="Quartz.Simpl.RAMJobStore, Quartz"/>
 <!--******************************Plugin配置********************************************* -->
 <add key="quartz.plugin.xml.type" value="Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz" />
 <add key="quartz.plugin.xml.fileNames" value="quartz_jobs.xml"/> 
 </quartz>

2 番目のコードベースのアプローチ

この状況はコードを通じて直接実現されます。多くの公式デモはこのようなものです。例を挙げてみましょう

# You can configure your scheduler in either <quartz> configuration section
# or in quartz properties file
# Configuration section has precedence

quartz.scheduler.instanceName = ServerScheduler

# configure thread pool info
quartz.threadPool.type = Quartz.Simpl.SimpleThreadPool, Quartz
quartz.threadPool.threadCount = 10
quartz.threadPool.threadPriority = Normal

#--------------------------------*************plugin配置------------------------------------
# job initialization plugin handles our xml reading, without it defaults are used
quartz.plugin.xml.type = Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz
quartz.plugin.xml.fileNames = ~/quartz_jobs.xml

# export this server to remoting context
quartz.scheduler.exporter.type = Quartz.Simpl.RemotingSchedulerExporter, Quartz
quartz.scheduler.exporter.port = 555
quartz.scheduler.exporter.bindName = QuartzScheduler
quartz.scheduler.exporter.channelType = tcp
quartz.scheduler.exporter.channelName = httpQuartz

実際、コードメソッドが構成ファイルと混合されています。ただし、この方法では、ジョブをロードし、設定の関連付けを通じて設定をトリガーします。また、ジョブをロードし、設定ファイルを自分でトリガーするという 3 番目の方法もあります。

3. 設定ファイルを手動でロードします

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text; using Quartz;
using Quartz.Impl;
using System.Threading;
using Common.Logging;

namespace Demo
{
 class Program
 {
  static void Main(string[] args)
  {
   ILog log = LogManager.GetLogger(typeof(Demo.HelloJob));

   log.Info("------- Initializing ----------------------");

   // First we must get a reference to a scheduler
   ISchedulerFactory sf = new StdSchedulerFactory();
   IScheduler sched = sf.GetScheduler();

   log.Info("------- Initialization Complete -----------");


   //---------------------------------------代码添加job和trigger
   // computer a time that is on the next round minute
   DateTimeOffset runTime = DateBuilder.EvenMinuteDate(DateTimeOffset.UtcNow);

   log.Info("------- Scheduling Job -------------------");

   // define the job and tie it to our HelloJob class
   IJobDetail job = JobBuilder.Create<HelloJob>()
    .WithIdentity("job1", "group1")
    .Build();

   // Trigger the job to run on the next round minute
   ITrigger trigger = TriggerBuilder.Create()
    .WithIdentity("trigger1", "group1")
    .StartAt(runTime)
    .Build();

   // Tell quartz to schedule the job using our trigger
   sched.ScheduleJob(job, trigger);
   log.Info(string.Format("{0} will run at: {1}", job.Key, runTime.ToString("r")));

   // Start up the scheduler (nothing can actually run until the 
   // scheduler has been started)
   sched.Start();
   log.Info("------- Started Scheduler -----------------");

   // wait long enough so that the scheduler as an opportunity to 
   // run the job!
   log.Info("------- Waiting 65 seconds... -------------");

   // wait 65 seconds to show jobs
   Thread.Sleep(TimeSpan.FromSeconds(65));

   // shut down the scheduler
   log.Info("------- Shutting Down ---------------------");
   sched.Shutdown(true);
   log.Info("------- Shutdown Complete -----------------");
  }
 }
}

、またはこれ

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text; 
using Quartz;
using Quartz.Xml;
using Quartz.Impl;
using Quartz.Simpl;
using System.Threading;
using Common.Logging;
using System.IO;

namespace Demo
{
 class Program
 {
  static void Main(string[] args)
  {    
   XMLSchedulingDataProcessor processor = new XMLSchedulingDataProcessor(new SimpleTypeLoadHelper());
   ISchedulerFactory sf = new StdSchedulerFactory();
   IScheduler scheduler = sf.GetScheduler();

   Stream s = new StreamReader("~/quartz.xml").BaseStream;
   processor.ProcessStream(s, null);
   processor.ScheduleJobs(scheduler);

   scheduler.Start();
   scheduler.Shutdown();
   
  }
 }
}

現在、ソースコード分析に基づいて、大まかに次の設定方法があり、非常に柔軟で任意に組み合わせることができます。方法。 クォーツを使用するためのソースコードは非常に詳細であり、庭には多くの学習記事があります。

quartz の最初の app.config/web.config ---->quartz.config/Quartz.quartz.config ---->quartz_jobs.xml の設定読み取り方法を覚えておいてください。

コードを変更して使用できます。 quartz_jobs.xml のポイントを新しく名前を付けた xml ファイルに追加します

(デフォルトのquartz_jobs.xmlはXMLSchedulingDataProcessor.QuartzXmlFileName = "quartz_jobs.xml"で指定されます)

方法1、quartzノード/quartz.configポインタ・ジョブを通じて指定します。 xml。

方法 2、XMLSchedulingDataProcessor を通じて指定された jobs.xml をロードします

以上がQuartz.Net スケジューリング フレームワークの構成例の詳細な紹介の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。