.netWindows服务采用Quartz.NET实现任务调度

xiaoxiao2021-02-28  127

Quartz.net: 它是一个简单的执行任务计划的框架,基本包括这三部分:Job(作业)、Trigger(触发器)、scheduler(调度器)。

1.Job 作业:需要在任务计划中执行的具体逻辑操作;

2.Trigger 触发器:需要什么时间什么规则来去执行Job作业;

3.scheduler 调度器:将Job Trigger注册到 scheduler调度器中,主要负责协调JobTrigger的运行;

Windows服务使用标准的C#编写,任务调度框架采用开源的Quartz.NET。     首先创建Windows服务-JobService         其次创建类库项目-JobLibrary

    整体解决方案架构图如下:          在JobLibary中添加Quartz.NET的Nuget包引用,添加之后,vs会自动添加一系列的依赖项,这些依赖项是必须的,别手抖删掉了。

             其次再添加Common.Logging.Log4Net1211的Nuget包,他是Log4net的另外一种实现,会自动添加log4net的依赖     所有添加的包如下图:     

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

using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; 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("d:\\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 log4net; using Quartz; using Quartz.Impl; using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Diagnostics; using System.Linq; using System.ServiceProcess; using System.Text; using System.Threading.Tasks; 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 触发器 每3秒执行一次DemoJob1任务-->     <trigger>       <cron>         <name>DemoJob1Trigger</name>         <group>DeomJobTriggerGroup</group>         <job-name>DemoJob1</job-name>         <job-group>DeomJobGroup</job-group>         <cron-expression>0/3 * * * * ?</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 = 8092 quartz.scheduler.exporter.bindName = QuartzScheduler quartz.scheduler.exporter.channelType = tcp quartz.scheduler.exporter.channelName = httpQuartz  

然后就是app.config文件:

<?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="log4net" type="log4net.Config.Log4NetConfigurationSectionHandler, log4net"/>     <sectionGroup name="common">       <section name="logging" type="Common.Logging.ConfigurationSectionHandler, Common.Logging"/>     </sectionGroup>   </configSections>     <startup>         <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5" />     </startup>   <runtime>     <assemblyBinding xmlns="urn:schemas-microsoft-com:asm.v1">       <dependentAssembly>         <assemblyIdentity name="Common.Logging.Core" publicKeyToken="af08829b84f0328e" culture="neutral" />         <bindingRedirect oldVersion="0.0.0.0-3.4.1.0" newVersion="3.4.1.0" />       </dependentAssembly>       <dependentAssembly>         <assemblyIdentity name="Common.Logging" publicKeyToken="af08829b84f0328e" culture="neutral" />         <bindingRedirect oldVersion="0.0.0.0-3.4.1.0" newVersion="3.4.1.0" />       </dependentAssembly>     </assemblyBinding>   </runtime> </configuration>

然后就是编译,记住App.config,quartz_jobs.xml和quartz.config这3个文件全选中,点击右键-》复制到输出目录-》选择“始终复制”,要不然读取不到。

把编译好的如下文件拷贝到D:\JobService\

以下2种方法都可以创建服务:

(1)控制台下执行如下命令:sc create QuartzService binpath= D:\QuartzService\Quartz.Net.Service.exe

完成服务创建 启动QuartzService服务可以看到D:\QuartzService\的日志文件有如下输出;例:如下图()

(2)cmd打开命令行工具,执行安装或卸载命令(以下目录存在):

安装命令:

cd  C:\WINDOWS\Microsoft.NET\Framework\v4.0.30319

C:\WINDOWS\Microsoft.NET\Framework\v4.0.30319\InstallUtil.exe  "D:\JobService\JobService.exe"

如下图:

从我的电脑-》右键-》找到“服务”里面 的JobSerivce1服务名,如下图:

启动服务:

net start  JobService1

停止服务

net stop  JobService1

下面这个是卸载服务命令: C:\WINDOWS\Microsoft.NET\Framework\v4.0.30319\InstallUtil.exe  /u "D:\JobService\JobService.exe" 路径"

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

调试:

如果需要调试服务中的方法,断点方法,选择“生成”-》附加到进程-》找到对应的服务进程;如下图:

等到服务执行的时候,会自动跳到断点处。

注:如果遇到启动服务的时候后报1053错误,那可能是appconfig配置节点configSections节点要放到最上面,我之前放下面,总是启动不了服务,换到上面,就可以正常启动了,找了好久的一个问题,是别人帮忙找到的。

转载来自:http://www.cnblogs.com/yangkangIT/p/5665102.html  

我做了一些修改

转载请注明原文地址: https://www.6miu.com/read-37552.html

最新回复(0)