1. 首页
  2. 服务端开发
  3. C#中Quartz的简单易懂定时任务实现

C#中Quartz的简单易懂定时任务实现

•服务端开发•阅读 3732

转载地址：https://www.cnblogs.com/wendj/archive/2018/09/18/9670412.html

作为一个优秀的开源调度框架，Quartz 具有以下特点：

  1. 强大的调度功能，例如支持丰富多样的调度方法，可以满足各种常规及特殊需求；
  2. 灵活的应用方式，例如支持任务和调度的多种组合方式，支持调度数据的多种存储方式；
  3. 分布式和集群能力，Terracotta 收购后在原来功能基础上作了进一步提升。

另外，作为 Spring 默认的调度框架，Quartz 很容易与 Spring 集成实现灵活可配置的调度功能。

quartz调度核心元素：

  1. Scheduler:任务调度器，是实际执行任务调度的控制器。在spring中通过SchedulerFactoryBean封装起来。
  2. Trigger：触发器，用于定义任务调度的时间规则，有SimpleTrigger,CronTrigger,DateIntervalTrigger和NthIncludedDayTrigger，其中CronTrigger用的比较多，本文主要介绍这种方式。CronTrigger在spring中封装在CronTriggerFactoryBean中。
  3. Calendar:它是一些日历特定时间点的集合。一个trigger可以包含多个Calendar，以便排除或包含某些时间点。
  4. JobDetail:用来描述Job实现类及其它相关的静态信息，如Job名字、关联监听器等信息。在spring中有JobDetailFactoryBean和 MethodInvokingJobDetailFactoryBean两种实现，如果任务调度只需要执行某个类的某个方法，就可以通过MethodInvokingJobDetailFactoryBean来调用。
  5. Job：是一个接口，只有一个方法void execute(JobExecutionContext context),开发者实现该接口定义运行任务，JobExecutionContext类提供了调度上下文的各种信息。Job运行时的信息保存在JobDataMap实例中。实现Job接口的任务，默认是无状态的，若要将Job设置成有状态的，在quartz中是给实现的Job添加@DisallowConcurrentExecution注解（以前是实现StatefulJob接口，现在已被Deprecated）,在与spring结合中可以在spring配置文件的job detail中配置concurrent参数。

我这里简单记录使用过程及代码：

1：首先引用Quartz组件

2：using Quartz;using Quartz.Impl;

注：在本地新建一个控制台项目，将以下代码copy过去即可用，只需要重写Execute方法即可。Quartz3.0及以上的版本是采用的异步，3.0以下的版本没有采用异步，使用方法是一样的

主函数入口文件：

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

usingBackgroundTask.job;

usinglog4net;

usingQuartz;

usingQuartz.Impl;

usingSystem;

usingSystem.Collections.Generic;

usingSystem.Linq;

usingSystem.Text;

usingSystem.Threading.Tasks;

namespaceBackgroundTask

{

classProgram

{

privatestaticreadonlyILog _log = LogManager.GetLogger(typeof(Program));

privatestaticreadonlystringtiggerName ="TestJobTrigger";

privatestaticreadonlystringgropName ="TestJobTriggerGrop";

privatestaticreadonlystringjobName ="TestJob";

//从工厂中获取一个调度器实例化

privatestaticIScheduler scheduler =null;

staticvoidMain(string[] args)

{

Console.WriteLine("开始任务....");

_log.Debug("开始任务....");

Start();

}

privatestaticasyncvoidStart()

{

//从工厂中获取一个调度器实例化

scheduler = await StdSchedulerFactory.GetDefaultScheduler();

await scheduler.Start();

//创建一个作业

IJobDetail job1 = JobBuilder.Create<TestJob>()

.WithIdentity(jobName, gropName)

.UsingJobData("key","value")// 传递参数 在Execute方法中获取（以什么类型值传入，取值就用相应的类型方法取值）

.Build();

// 创建触发器

ITrigger trigger1 = TriggerBuilder.Create()

.WithIdentity(tiggerName, gropName)

.StartNow()//现在开始

.WithSimpleSchedule(x => x//触发时间，10秒一次。

.WithIntervalInSeconds(10)

.RepeatForever())//不间断重复执行

.Build();

await scheduler.ScheduleJob(job1, trigger1);//把作业，触发器加入调度器。

Console.ReadKey();

// 清除任务和触发器

ClearJobTrigger();

}

/// <summary>

/// 清除任务和触发器

/// </summary>

privatestaticvoidClearJobTrigger()

{

TriggerKey triggerKey =newTriggerKey(tiggerName, gropName);

JobKey jobKey =newJobKey(jobName, gropName);

if(scheduler !=null)

{

scheduler.PauseTrigger(triggerKey);

scheduler.UnscheduleJob(triggerKey);

scheduler.DeleteJob(jobKey);

scheduler.Shutdown();// 关闭

}

}

}

}

　　

实现IJob 接口的任务文件

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

usinglog4net;

usingQuartz;

usingSystem;

usingSystem.Collections.Generic;

usingSystem.Linq;

usingSystem.Text;

usingSystem.Threading.Tasks;

namespaceBackgroundTask.job

{

publicclassTestJob : IJob

{

privatereadonlyILog _log = LogManager.GetLogger(typeof(TestJob));

/// <summary>

/// 测试作业

/// </summary>

/// <param name="context"></param>

/// <returns></returns>

publicasync Task Execute(IJobExecutionContext context)

{

　　　　　　　　JobDataMap dataMap = context.JobDetail.JobDataMap;

　　　　　　　　string k = dataMap.GetString("key");//获取参数(可根据传递的类型使用GetInt、GetFloat、GetString.....)

1

2

3

4

5

6

7

8

_log.Debug("run TestJob debug");

_log.Error("run TestJob error");

_log.Info("run TestJob info");

// 在这里处理你的任务

}

}

}<br><br>

相关推荐

Copyright © 2008-2024渝ICP备2022006305号-5.

本站所有数据收集于网络如有侵犯到您的权益请联系，进行下架处理。