欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

C#基于Quartz.NET实现任务调度并部署Windows服务

程序员文章站 2022-06-07 11:00:16
一、Quartz.NET介绍 Quartz.NET是一个强大、开源、轻量的作业调度框架,是 OpenSymphony 的 Quartz API 的.NET移植,用C#改写,可用于winform和asp.net mvc、.Net Core应用中。它灵活而不复杂。你能够用它来为执行一个作业而创建简单的或 ......

一、quartz.net介绍

quartz.net是一个强大、开源、轻量的作业调度框架,是 opensymphony 的 quartz api 的.net移植,用c#改写,可用于winform和asp.net mvc、.net core应用中。它灵活而不复杂。你能够用它来为执行一个作业而创建简单的或复杂的作业调度。它有很多特征,如:数据库支持,集群,插件,支持cron-like表达式等等。

官网:

源码:https://github.com/quartznet/quartznet

二、quartz.net用途

 一,可以定时发邮件通知。 

二 , 电商网站的定时打折活动。(比如规定11月11日 淘宝购买女朋友打八折)

三, 定时对数据更新 或者添加。

四,自己朋友生日。 可以定时发生日祝福。 等等 (我也不一一举例了) 

三、quartz.net安装

我使用的vs版本是2017的  选择工具  - nuget包管理 - 管理解决方案的nuget包   输入 quartz.net 安装

C#基于Quartz.NET实现任务调度并部署Windows服务

还可以通过nuget控制台 通过安装命令  

install-package quartz

四、quartz.net实现思路

一:继承并实现ijob接口,在execute 方法中写你要定时执行的事情(切记 )

二:使用quartz创建任务调度核心代码步骤

  1、配置quartz,创建工厂,开启调度。

  2、创建工作任务

  3、创建触发器

  4、将任务加入到任务池

三:添加任务,使用topshelf部署windows服务,定时执行

五、代码步骤讲解

  一:继承并实现ijob接口,在execute 方法中写你要做的事情(切记 )

   

 1 using quartz.utility;
 2 using system;
 3 using system.io;
 4 using system.threading.tasks;
 5 
 6 namespace quartz.jobwork
 7 {
 8     public class myjob : ijob
 9     {
10         public task execute(ijobexecutioncontext context)
11         {
12             task task = null;
13             try
14             {
15                 string filename = "printlog.txt";
16                 streamwriter writer = new streamwriter(filename, true);
17                 task = writer.writelineasync(string.format("{0},测试", datetime.now.tolongtimestring()));
18                 writer.close();
19                 writer.dispose();
20             }
21             catch (exception ex)
22             {
23                 loghelper.writelog(ex.message.tostring(), ex);
24             }
25             return task;
26         }
27     }
28 }

 

二:使用quartz创建任务调度核心代码步骤

注:这里提供一个quartzhelper帮助类,直接把以下代码copy过去即可用,只需要重写execute方法即可。quartz3.0及以上的版本是采用的异步,3.0以下的版本没有采用异步,使用方法是一样的

 1 using quartz.impl;
 2 using system;
 3 using system.collections.generic;
 4 using system.collections.specialized;
 5 using system.linq;
 6 using system.text;
 7 using system.threading;
 8 using system.threading.tasks;
 9 
10 namespace quartz.utility
11 {
12     public class quartzhelper
13     {
14         static readonly ischeduler _scheduler;
15         static quartzhelper()
16         {
17             var properties = new namevaluecollection();
18             // 设置线程池
19             properties["quartz.threadpool.type"] = "quartz.simpl.simplethreadpool, quartz";
20             //设置线程池的最大线程数量
21             properties["quartz.threadpool.threadcount"] = "5";
22             //设置作业中每个线程的优先级
23             properties["quartz.threadpool.threadpriority"] = threadpriority.normal.tostring();
24 
25             // 远程输出配置
26             properties["quartz.scheduler.exporter.type"] = "quartz.simpl.remotingschedulerexporter, quartz";
27             properties["quartz.scheduler.exporter.port"] = "555";  //配置端口号
28             properties["quartz.scheduler.exporter.bindname"] = "quartzscheduler";
29             properties["quartz.scheduler.exporter.channeltype"] = "tcp"; //协议类型
30 
31             //创建一个工厂
32             var schedulerfactory = new stdschedulerfactory(properties);
33             //启动
34             _scheduler = schedulerfactory.getscheduler().result;
35             //1、开启调度
36             _scheduler.start();
37         }
38         /// <summary>
39         /// 时间间隔执行任务
40         /// </summary>
41         /// <typeparam name="t">任务类,必须实现ijob接口</typeparam>
42         /// <param name="seconds">时间间隔(单位:秒)</param>
43         public static async task<bool> executeinterval<t>(int seconds) where t : ijob
44         {
45             //2、创建工作任务
46             ijobdetail job = jobbuilder.create<t>().build();
47             // 3、创建触发器
48             itrigger trigger = triggerbuilder.create()
49            .startnow()
50            .withsimpleschedule(
51                 x =>x.withintervalinseconds(seconds)
52                 //x.withintervalinminutes(1)
53                 .repeatforever())
54            .build();
55             //4、将任务加入到任务池
56             await _scheduler.schedulejob(job, trigger);
57             return true;
58         }
59 
60         /// <summary>
61         /// 指定时间执行任务
62         /// </summary>
63         /// <typeparam name="t">任务类,必须实现ijob接口</typeparam>
64         /// <param name="cronexpression">cron表达式,即指定时间点的表达式</param>
65         public static async task<bool> executebycron<t>(string cronexpression) where t : ijob
66         {
67             //2、创建工作任务
68             ijobdetail job = jobbuilder.create<t>().build();
69             //3、创建触发器
70             icrontrigger trigger = (icrontrigger)triggerbuilder.create()
71             .startnow()
72             .withcronschedule(cronexpression)
73             .build();
74             //4、将任务加入到任务池
75             await _scheduler.schedulejob(job, trigger);
76             return true;
77         }
78     }
79 }

 

 三:添加任务,topshelf部署windows服务,定时执行

 1 namespace quartz
 2 {
 3     public class program
 4     {
 5         static void main(string[] args)
 6         {
 7             string cronexpression = "0 0 8,23 * * ? ";  //=>这是指每天的9点和16点执行任务
 8             cronexpression = "30 0/1 * * * ?";
 9             //quartzhelper.executebycron<myjob>(cronexpression).wait();  //=>这是调用cron计划方法
10             quartzhelper.executeinterval<myjob>(180).wait();
11             /*
12              简单说一下cron表达式吧,
13 
14             由7段构成:秒 分 时 日 月 星期 年(可选)
15  
16             "-" :表示范围  mon-wed表示星期一到星期三
17             "," :表示列举 mon,web表示星期一和星期三
18             "*" :表是“每”,每月,每天,每周,每年等
19             "/" :表示增量:0/15(处于分钟段里面) 每15分钟,在0分以后开始,3/20 每20分钟,从3分钟以后开始
20             "?" :只能出现在日,星期段里面,表示不指定具体的值
21             "l" :只能出现在日,星期段里面,是last的缩写,一个月的最后一天,一个星期的最后一天(星期六)
22             "w" :表示工作日,距离给定值最近的工作日
23             "#" :表示一个月的第几个星期几,例如:"6#3"表示每个月的第三个星期五(1=sun...6=fri,7=sat)
24  
25             如果minutes的数值是 '0/15' ,表示从0开始每15分钟执行
26  
27             如果minutes的数值是 '3/20' ,表示从3开始每20分钟执行,也就是‘3/23/43’
28             */
29             hostfactory.run(x =>
30             {
31                 x.uselog4net();
32                 //x.service<towncrier>(s =>                        
33                 //{
34                 //    s.constructusing(name => new towncrier());    
35                 //    s.whenstarted(tc => tc.start());              
36                 //    s.whenstopped(tc => tc.stop());               
37                 //});
38                 x.runaslocalsystem();
39                 x.setdescription("quartzjob任务定时发送");
40                 x.setdisplayname("quartzjob");
41                 x.setservicename("quartzjob");
42 
43                 x.enablepauseandcontinue();
44             });
45             console.readkey();
46         }
47     }
48 }

 

  最后就可以做自己想要做的事情了!

   下期讲解使用topshelf部署windows服务!