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

.NET中Quartz任务调度器的简单应用实例

程序员文章站 2022-05-23 21:20:24
1.首先从NuGet中安装Quartz,安装最新版本就OK 2.新建一个Job类实现Quart中的IJob接口用于执行业务逻辑,代码如下: 3.新建一个任务执行类用于启动任务,代码如下: 对于标黄色部分做简单说明 CheckUpdateJob:毫无疑问就是你的Job类。从源码里面看必须是需要实现IJ ......

1.首先从nuget中安装quartz,安装最新版本就ok

2.新建一个job类实现quart中的ijob接口用于执行业务逻辑,代码如下:

    class checkupdatejob : ijob
    {
       
        public async task execute(ijobexecutioncontext context)
        {
            //在此处实现业务
        }
    }

3.新建一个任务执行类用于启动任务,代码如下:

    class jobcontroller
    {
        //调度器
        ischeduler scheduler;
        //调度器工厂
        ischedulerfactory factory; 
        //执行时间间隔
        private int checkinternal = int.parse(configurationmanager.appsettings["checkinternal"]);
        public async task start()
        {
            factory = new stdschedulerfactory();
            scheduler = await factory.getscheduler();//创建一个任务
            ijobdetail jobcheck = jobbuilder.create<checkupdatejob>().withidentity("check", "other").build();
            //创建一个触发器
            itrigger checktrigger = triggerbuilder.create()
               .withidentity("check", "other")
               .withschedule(simpleschedulebuilder.create().withintervalinseconds(checkinternal).repeatforever())
               .startnow()
               .build();
            //把任务和触发器加入调度器中
            await scheduler.schedulejob(jobcheck, checktrigger);

            //开始执行
            await scheduler.start(); 
        }
    }

对于标黄色部分做简单说明

checkupdatejob:毫无疑问就是你的job类。从源码里面看必须是需要实现ijob接口的类,源码如图:

.NET中Quartz任务调度器的简单应用实例

 

check:自定义的job别名,当有很多的job需要执行的时候,可以使用别名区分。

other:自定义分组别名,当你有多job的时候可以把job进行分组,例如:订单,数据清理等;当你需要对job管理的时候便会派上用场。

itrigger 中的check,other道理同上

checkinternal:这个参数为轮询间隔秒数,这里我只做个简单间隔秒数轮询方式执行job,其内置了丰富的方式。比如:每月的第几号,每周的星期几,上午或者下午时间点等

 其他更多的应用可自行度娘或者看官方文档吧!

4.最后调用start()即可,代码如下:

        static void main(string[] args)
        {
            jobcontroller controller = new jobcontroller();
            var t = controller.start();
            t.wait();
            console.read();
        }