任務調度~Quartz.net實現簡單的任務調試

任務調度類似於sqlserver中的作業，即按周期性執行某個程序，代碼段，或者某種服務，在JAVA環境中出現了Quartz，它可以簡單的實現任務的調試，而像lucene一樣，它會有對於的.net版本，Quartz.net，今天我們來做一個簡單的實驗，其時很簡單的實驗：

環境:.net4.0+mvc3

功能：每1分鍾去向一個文件里寫日志（當然，如果你要調用某個服務，只要讓它實現IJob接口即可。

所需要的程序集

首先在WEB.Config的configuration節點里做一些必要的配置

  <configSections>
    <section name="quartz" type="System.Configuration.NameValueSectionHandler, System, Version=1.0.5000.0,Culture=neutral, PublicKeyToken=b77a5c561934e089"/>
    <sectionGroup name="common">
      <section name="logging" type="Common.Logging.ConfigurationSectionHandler, Common.Logging"/>
    </sectionGroup>
  </configSections>
  <common>
    <logging>
      <factoryAdapter type="Common.Logging.Simple.ConsoleOutLoggerFactoryAdapter, Common.Logging">
        <arg key="showLogName" value="true"/>
        <arg key="showDataTime" value="true"/>
        <arg key="level" value="INFO"/>
        <arg key="dateTimeFormat" value="HH:mm:ss:fff"/>
      </factoryAdapter>
    </logging>
  </common>

  <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"/>
  </quartz>

在global.asax.cs里添加調用和取消調用的代碼

        protected void Application_Start()
        {
           WriteLogScheduler.Instance.Start();
        }

        protected void Application_End(object sender, EventArgs e)
        {
            WriteLogScheduler.Instance.Stop();
        }

所要調用的任務，它需要實現IJob接口

    /// <summary>
    /// 要調度的功能模塊
    /// </summary>
    public class WriteLogJob : IJob
    {
        public void Execute(IJobExecutionContext context)
        {
            string fileLogPath = AppDomain.CurrentDomain.BaseDirectory;
            string fileLogName = "TestQuartz_" + DateTime.Now.ToLongDateString() + "_log.txt";
            FileInfo finfo = new FileInfo(fileLogPath + fileLogName);
            using (FileStream fs = finfo.OpenWrite())
            {
                //根據上面創建的文件流創建寫數據流 
                StreamWriter strwriter = new StreamWriter(fs);
                //設置寫數據流的起始位置為文件流的末尾 
                strwriter.BaseStream.Seek(0, SeekOrigin.End);
                //寫入相關記錄信息
                strwriter.WriteLine("發生時間: " + DateTime.Now.ToString());
                strwriter.WriteLine("---------------------------------------------");
                strwriter.WriteLine();
                //清空緩沖區內容，並把緩沖區內容寫入基礎流 
                strwriter.Flush();
                strwriter.Close();
                fs.Close();
            }
        }

    }

添加調用任務的代碼，Quartz服務核心代碼

 public class WriteLogScheduler
    {

        static ISchedulerFactory _sf = new StdSchedulerFactory();
        static IScheduler _sched = _sf.GetScheduler();
        static WriteLogScheduler _instance = null;
        static object lockObj = new object();

        /// <summary>
        /// 線程安全的單例對象
        /// </summary>
        public static WriteLogScheduler Instance
        {
            get
            {
                if (_instance == null)
                {
                    lock (lockObj)
                    {
                        if (_instance == null)
                        {
                            _instance = new WriteLogScheduler();
                        }
                    }
                }
                return _instance;
            }
        }

        public void Start()
        {
            ILog log = LogManager.GetLogger(typeof(WriteLogScheduler));
            DateTimeOffset runTime = DateBuilder.EvenMinuteDate(DateTimeOffset.UtcNow);
            // define the job and tie it to our HelloJob class
            IJobDetail job = JobBuilder.Create<WriteLogJob>()
                .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);
            _sched.Start();
        }
        public void Stop()
        {
            _sched.Shutdown(true);
        }

    }

運行程序，即可看到結果了，下一講，我將把XML配置信息加進來，以減少程序的松耦性。