码迷,mamicode.com
首页 > Windows程序 > 详细

采用Windows服务任务调度Quartz.NET

时间:2016-07-12 23:27:54      阅读:479      评论:0      收藏:0      [点我收藏+]

标签:

     Windows服务使用标准的Csharp编写,任务调度框架采用开源的Quartz.NET。
    首先创建Windows服务-JobService
    技术分享

    其次创建类库项目-JobLibrary
    整体解决方案架构图如下:
    技术分享

    在JobLibary中添加Quartz.NET的Nuget包引用,添加之后,vs会自动添加一系列的依赖项,这些依赖项是必须的,别手抖删掉了。
    技术分享
    
    其次再添加Common.Logging.Log4Net1211的Nuget包,他是Log4net的另外一种实现,会自动添加log4net的依赖
    所有添加的包如下图:
    
技术分享

  下面开始添加任务,在libary中添加一个job类继承IJob,并实现其接口

  

using System;
using Quartz;

namespace JobLibrary
{
    public class Job : IJob
    {
        private static readonly Common.Logging.ILog logger = Common.Logging.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
        public void Execute(IJobExecutionContext context)
        {
            try
            {
                logger.Info("job开始");
                using (System.IO.StreamWriter sw = new System.IO.StreamWriter("E:\\log.txt", true))
                {
                    sw.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ") + " 吃饭---睡觉");

                }
                logger.Info("job结束"); 
            }
            catch (Exception e)
            {
                logger.Error(e.Message);
            }
        }
    }   
    
}

这个类就是你需要做的任务。我的任务是吃饭和睡觉。

然后再在JobService中添加JobLibrary的引用,并且添加如下代码(需要同样添加Nuget引用)

using Common.Logging;
using Quartz;
using Quartz.Impl;
using System.ServiceProcess;

namespace JobService
{
    public partial class Service1 : ServiceBase
    {
        private IScheduler scheduler;
        private readonly ILog logger;
        public Service1()
        {
            InitializeComponent();
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();
            scheduler = schedulerFactory.GetScheduler();
            logger = LogManager.GetLogger(GetType());
        }

        protected override void OnStart(string[] args)
        {
            logger.Info("Quartz服务成功启动");
            scheduler.Start();
        }

        protected override void OnStop()
        {
            scheduler.Shutdown(false);
        }
    }
}

  

代码完成之后,需要配置quartz_jobs.xml,在JobService项目添加xml配置文件“quartz_jobs.xml”,并添加任务配置。

<?xml version="1.0" encoding="UTF-8"?>
<!-- This file contains job definitions in schema version 2.0 format -->
<job-scheduling-data xmlns="http://quartznet.sourceforge.net/JobSchedulingData" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.0">
  <processing-directives>
    <overwrite-existing-data>true</overwrite-existing-data>
  </processing-directives>
  <schedule>
    <!--定义示例任务1 Job-->
    <job>
      <name>DemoJob1</name>
      <group>DeomJobGroup</group>
      <description>Quartz.Net示例任务1</description>
      <job-type>JobLibrary.Job,JobLibrary</job-type>
      <durable>true</durable>
      <recover>false</recover>
    </job>
 

    <!--定义示例任务1 触发器 每10秒执行一次DemoJob1任务-->
    <trigger>
      <cron>
        <name>DemoJob1Trigger</name>
        <group>DeomJobTriggerGroup</group>
        <job-name>DemoJob1</job-name>
        <job-group>DeomJobGroup</job-group>
        <cron-expression>0/10 * * * * ?</cron-expression>
      </cron>
    </trigger>
  </schedule>
</job-scheduling-data>

  这个配置文件有个莫名其妙的bug,就是最上面那几行不能有空行,不知道是什么情况,有知道伙计望告知。被这个坑了半天。

  其次,在添加quartz.config配置文件

  

# 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

# 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

然后就是app.config的quartz的配置了

  

 <configSections>
    <section name="quartz" type="System.Configuration.NameValueSectionHandler, System, Version=1.0.5000.0,Culture=neutral, PublicKeyToken=b77a5c561934e089"/>
    <section name="log4net" type="log4net.Config.Log4NetConfigurationSectionHandler, log4net"/>
    <sectionGroup name="common">
      <section name="logging" type="Common.Logging.ConfigurationSectionHandler, Common.Logging"/>
    </sectionGroup>
  </configSections>

  然后就是编译,记住quartz_jobs.xml和quartz.config这两个文件一定要编译输出,要不然读取不到。

 

技术分享

技术分享

  

启动之后,就可以看到写到文件中的内容了。
技术分享

如果一台机器上跑任务,那么如果这太机器挂掉了怎么办?如果是多台机器上跑任务,那么任务重复执行怎么办?

 

采用Windows服务任务调度Quartz.NET

标签:

原文地址:http://www.cnblogs.com/yangkangIT/p/5665102.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!