菜的像徐坤
排名
7
文章
192
粉丝
15
评论
16
ICP备案 :渝ICP备18016597号-1
网站信息:2018-2025TNBLOG.NET
技术交流:群号656732739
联系我们:contact@tnblog.net
公网安备:50010702506256
欢迎加群交流技术

Quartz 定时器使用基础

2203人阅读 2023/12/8 10:01 总访问:971553 评论:0 收藏:0 手机
分类: Csharp

前言

 Quartz.NET是一个强大、开源、轻量的作业调度框架,是一个用C#编写的纯.NET库,是一个非常流行的开源Java作业调度框架。是 OpenSymphony 的 Quartz API 的.NET移植,非常适合在平时的工作中,定时轮询数据库同步,定时邮件通知,定时处理数据等

通俗说它的功能是:比如说我想每天晚上2点让程序或网站执行某些代码,或者每隔5秒种我想查看是否有新的任务要处理等。

Quartz主要有三部分组成任务(Job)、触发器(Trigger)和调度器(Schedule)。

  1. 任务
        Job就是执行的作业,Job需要继承IJob接口,实现Execute方法。Job中执行的参 数从Execute方法的参数中获取。


  2. 触发器
        触发器常用的有两种:SimpleTrigger触发器和CronTrigger触发器。
    SimpleTrigger: 能是实现简单业务,如每隔几分钟,几小时触发执行,并限制执行次数。

  1. 调度器
        调度器就是将任务和触发器绑定,让触发器触发的时候去执行任务。


代码

继承IJob创建一个任务

  1.    //实现Execute
  2.    public class DoSome : IJob
  3.    {
  4.        public async Task Execute(IJobExecutionContext context)
  5.        {
  6.            // 数据
  7.            string data = "这是定时器记录的数据" + DateTime.Now; 
  8.            // 文件路径
  9.            string filePath = "D:/code/测试/test.txt"
  10.            // 创建StreamWriter对象,将数据写入文件
  11.            await using StreamWriter writer = new StreamWriter(filePath, true);
  12.            await writer.WriteLineAsync(data);
  13.        }
  14.    }

定义作业和触发器,并加入任务调度

  1. // 创建调度器
  2. ISchedulerFactory schedulerFactory = new StdSchedulerFactory();
  3. IScheduler scheduler = await schedulerFactory.GetScheduler();
  4. // 启动调度器
  5. await scheduler.Start();
  6. // 定义作业和触发器
  7. IJobDetail job = JobBuilder.Create<DoSome>()
  8.     .WithIdentity("myJob""group1")
  9.     .Build();
  10. ITrigger trigger = TriggerBuilder.Create()
  11.     .WithIdentity("myTrigger""group1")
  12.     .StartNow()
  13.     .WithSimpleSchedule(x => x
  14.         .WithIntervalInSeconds(10)
  15.         .RepeatForever())
  16.     .Build();
  17. // 将作业和触发器加入调度器
  18. await scheduler.ScheduleJob(job, trigger);

使用cron 表达式

  1. // 创建调度器
  2. ISchedulerFactory schedulerFactory = new StdSchedulerFactory();
  3. IScheduler scheduler = await schedulerFactory.GetScheduler();
  4. // 启动调度器
  5. await scheduler.Start();
  6. // 定义作业和触发器
  7. IJobDetail job = JobBuilder.Create<DoSome>()
  8.     .WithIdentity("myJob""group1")
  9.     .Build();
  10. ITrigger trigger = TriggerBuilder.Create()
  11.     .WithIdentity("myTrigger""group1")
  12.     .StartNow()
  13.     .WithSchedule(CronScheduleBuilder.CronSchedule("0 0/5 * 1/1 * ? *")) // 使用cron表达式,每5分钟执行一次
  14.     .Build();
  15. // 将作业和触发器加入调度器
  16. await scheduler.ScheduleJob(job, trigger);

现在看看效果

评价