电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

.NET6+Quartz實現定時任務的示例詳解

瀏覽:214日期:2022-06-11 09:29:41
目錄
  • 什么是定時任務
  • 什么是Quartz
  • 涉及知識點
  • Quartz安裝
  • 創建一個簡單的定時器任務
    • 1. 創建工作單元Job
    • 2. 創建時間軸Scheduler
    • 3. 創建觸發規則Trigger
    • 4. 創建任務描述
    • 5. 建立三者聯系
    • 6. 簡單示例測試
  • 傳遞參數
    • 任務特性
      • 監聽器
        • 1. 創建監聽器
        • 2. 添加監聽
      • 日志管理
        • 完整示例

          在實際工作中,經常會有一些需要定時操作的業務,如:定時發郵件,定時統計信息等內容,那么如何實現才能使得我們的項目整齊劃一呢?本文通過一些簡單的小例子,簡述在.Net6+Quartz實現定時任務的一些基本操作,及相關知識介紹,僅供學習分享使用,如有不足之處,還請指正。

          什么是定時任務

          定時任務,也叫任務調度,是指在一定的載體上,根據具體的觸發規則,執行某些操作。所以定時任務需要滿足三個條件:載體(Scheduler),觸發規則(Trigger),具體業務操作(Job)。如下所示:

          什么是Quartz

          Quartz 是一個開源的作業調度框架,它完全由 Java 寫成,并設計用于 J2SE 和 J2EE 應用中。它提供了巨大的靈 活性而不犧牲簡單性。你能夠用它來為執行一個作業而創建簡單的或復雜的調度。它有很多特征,如:數據庫支持,集群,插件,EJB 作業預構 建,JavaMail 及其它,支持 cron-like 表達式等等。雖然Quartz最初是為Java編寫的,但是目前已經有.Net版本的Quartz,所以在.Net中應用Quartz已經不再是奢望,而是輕而易舉的事情了。

          Github上開源網址為:https://github.com/quartznet

          關于Quartz的快速入門和API文檔,可以參考:https://www.quartz-scheduler.net/documentation/quartz-3.x/quick-start.html

          涉及知識點

          在Quartz框架中,主要接口和API如下所示:

          其中IScheduler,ITrigger , IJob 三者之間的關系,如下所示:

          Quartz安裝

          為了方便,本示例創建一個基于.Net6.0的控制臺應用程序,在VS2022中,通過Nuget包管理器進行安裝,如下所示:

          創建一個簡單的定時器任務

          要開發一個簡單,完整且能運行的定時器任務,步驟如下所示:

          1. 創建工作單元Job

          創建任務需要實現IJob接口,如下所示:

          using Quartz;using System.Diagnostics;namespace DemoQuartz.QuartzA.Job{    /// <summary>    /// 測試任務,實現IJob接口    /// </summary>    public class TestJob : IJob    {public TestJob(){    Console.WriteLine("執行構造函數");//表示每一次計劃執行,都是一次新的實例}public Task Execute(IJobExecutionContext context){    return Task.Run(() =>     { Console.WriteLine($"******************************"); Console.WriteLine($"測試信息{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}"); Console.WriteLine($"******************************"); Console.WriteLine();     });}    }}

          2. 創建時間軸Scheduler

          時間軸也是任務執行的載體,可以通過StdSchedulerFactory進行獲取,如下所示:

          //創建計劃單元(時間軸,載體) StdSchedulerFactory schedulerFactory = new StdSchedulerFactory(); var scheduler = await schedulerFactory.GetScheduler(); await scheduler.Start();

          3. 創建觸發規則Trigger

          觸發規則就是那些時間點執行任務,可通過TriggerBuilder進行構建,如下所示:

          //Trigger時間觸發機制var trigger = TriggerBuilder.Create()    .WithIdentity("TestTrigger","TestGroup")    //.StartNow() //立即執行    .WithSimpleSchedule(w=>w.WithIntervalInSeconds(5).WithRepeatCount(5))//.RepeatForever()//無限循環    //.WithCronSchedule("5/10 * * * * ?") //通過Cron表達式定制時間觸發規則, 示例表示從5開始,每隔10秒一次    .Build();

          4. 創建任務描述

          任務描述定義了具體的任務名稱,分組等內容。可通過JobBuilder進行構建,如下所示:

          //Job詳細描述 var jobDetail = JobBuilder.Create<TestJob>()     .WithDescription("這是一個測試Job")     .WithIdentity("TestJob", "TestGroup")     .Build();

          5. 建立三者聯系

          通過載體,將規則和工作單元串聯起來,如下所示:

           //把時間和任務通過載體關聯起來 await scheduler.ScheduleJob(jobDetail, trigger);

          6. 簡單示例測試

          通過運行程序,示例結果如下所示:

          傳遞參數

          在Quartz框架下,如果需要給執行的Job傳遞參數,可以通過兩種方式:

          jobDetail.JobDataMap,工作描述時通過JobDataMap傳遞參數。

          trigger.JobDataMap, 時間觸發時通過JobDataMap傳遞參數。

          在Job工作單元中,可以通過Context中對應的JobDataMap獲取參數。

          傳遞參數,如下所示:

          //傳遞參數jobDetail.JobDataMap.Add("name", "Alan");jobDetail.JobDataMap.Add("age", 20);jobDetail.JobDataMap.Add("sex", true);//trigger同樣可以傳遞參數trigger.JobDataMap.Add("like1", "meimei");trigger.JobDataMap.Add("like2", "football");trigger.JobDataMap.Add("like3", "sing");

          獲取參數,如下所示:

          //獲取參數var name = context.JobDetail.JobDataMap.GetString("name");var age = context.JobDetail.JobDataMap.GetInt("age");var sex = context.JobDetail.JobDataMap.GetBoolean("sex") ? "男" : "女";var like1 = context.Trigger.JobDataMap.GetString("like1");var like2 = context.Trigger.JobDataMap.GetString("like2");var like3 = context.Trigger.JobDataMap.GetString("like3");//context.MergedJobDataMap.GetString("aa");//注意如果使用MergedJobDataMap,JobDetail和Trigger中用到相同的Key,則后面設置的會覆蓋前面設置的。

          注意:如果使用MergedJobDataMap,JobDetail和Trigger中用到相同的Key,則后面設置的會覆蓋前面設置的。

          任務特性

          假如我們的定時任務,執行一次需要耗時比較久,而且后一次執行需要等待前一次完成,并且需要前一次執行的結果作為參考,那么就需要設置任務的任性。因為默認情況下,工作單元在每一次運行都是一個新的實例,相互之間獨立運行,互不干擾。所以如果需要存在一定的關聯,就要設置任務的特性,主要有兩個,如下所示:

          • [PersistJobDataAfterExecution]//在執行完成后,保留JobDataMap數據
          • [DisallowConcurrentExecution]//不允許并發執行,即必須等待上次完成后才能執行下一次

          以上兩個特性,只需要標記在任務對應的類上即可。標記上后,只需要往對應的JobDataMap中添加值即可。

          監聽器

          在Quartz框架下,有三種監聽器,分別是:時間軸監聽器ISchedulerListener,觸發規則監聽器ITriggerListener,任務監聽器IJobListener。要實現對應監聽器,實現對應接口即可。實現監聽器步驟:

          1. 創建監聽器

          根據不同的需要,可以創建不同的監聽器,如下所示:

          時間軸監聽器SchedulerListener

          public class TestSchedulerListener : ISchedulerListener{    public Task JobAdded(IJobDetail jobDetail, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test Job is added.");});    }    public Task JobDeleted(JobKey jobKey, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test Job is deleted.");});    }    public Task JobInterrupted(JobKey jobKey, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test Job is Interrupted.");});    }    public Task JobPaused(JobKey jobKey, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test Job is paused.");});    }    public Task JobResumed(JobKey jobKey, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test Job is resumed.");});    }    public Task JobScheduled(ITrigger trigger, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test Job is scheduled.");});    }    public Task JobsPaused(string jobGroup, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test Jobs is paused.");});    }    public Task JobsResumed(string jobGroup, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test Jobs is resumed.");});    }    public Task JobUnscheduled(TriggerKey triggerKey, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test Jobs is un schedulered.");});    }    public Task SchedulerError(string msg, SchedulerException cause, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test scheduler is error.");});    }    public Task SchedulerInStandbyMode(CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test scheduler is standby mode.");});    }    public Task SchedulerShutdown(CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test scheduler is shut down.");});    }    public Task SchedulerShuttingdown(CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test scheduler is shutting down.");});    }    public Task SchedulerStarted(CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test scheduleer is started.");});    }    public Task SchedulerStarting(CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test scheduler is starting.");});    }    public Task SchedulingDataCleared(CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test scheduling is cleared.");});    }    public Task TriggerFinalized(ITrigger trigger, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test trigger is finalized.");});    }    public Task TriggerPaused(TriggerKey triggerKey, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test trigger is paused.");});    }    public Task TriggerResumed(TriggerKey triggerKey, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test trigger is resumed.");});    }    public Task TriggersPaused(string? triggerGroup, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test triggers is paused.");});    }    public Task TriggersResumed(string? triggerGroup, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test triggers is resumed.");});    }}

          觸發規則監聽器TriggerListener

          /// <summary>/// 觸發器監聽/// </summary>public class TestTriggerListener : ITriggerListener{    public string Name => "TestTriggerListener";    public Task TriggerComplete(ITrigger trigger, IJobExecutionContext context, SchedulerInstruction triggerInstructionCode, CancellationToken cancellationToken = default)    {//任務完成return Task.Run(() => {    Console.WriteLine("Test trigger is complete.");});    }    public Task TriggerFired(ITrigger trigger, IJobExecutionContext context, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test trigger is fired.");});    }    public Task TriggerMisfired(ITrigger trigger, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test trigger is misfired.");});    }    public Task<bool> VetoJobExecution(ITrigger trigger, IJobExecutionContext context, CancellationToken cancellationToken = default)    {return Task.Run(() => {    Console.WriteLine("Test trigger is veto.");    return false;//是否終止});    }}

          JobListener任務監聽器

          /// <summary>/// TestJob監聽器/// </summary>public class TestJobListener : IJobListener{    public string Name => "TestJobListener";    public Task JobExecutionVetoed(IJobExecutionContext context, CancellationToken cancellationToken = default)    {//任務被終止時return Task.Run(() => {    Console.WriteLine("Test Job is vetoed.");});    }    public Task JobToBeExecuted(IJobExecutionContext context, CancellationToken cancellationToken = default)    {//任務被執行時return Task.Run(() => {    Console.WriteLine("Test Job is to be executed.");});    }    public Task JobWasExecuted(IJobExecutionContext context, JobExecutionException? jobException, CancellationToken cancellationToken = default)    {//任務已經執行return Task.Run(() => {    Console.WriteLine("Test Job was executed.");});    }}

          2. 添加監聽

          在時間軸上的監聽管理器中進行添加,如下所示:

          //增加監聽 scheduler.ListenerManager.AddJobListener(new TestJobListener()); scheduler.ListenerManager.AddTriggerListener(new TestTriggerListener()); scheduler.ListenerManager.AddSchedulerListener(new TestSchedulerListener());

          日志管理

          在Quartz框架中,創建之前會進行日志創建檢測,所以如果需要獲取框架中的日志信息,可以進行創建實現ILogProvider,如下所示:

          public class TestLogProvider : ILogProvider{    public Logger GetLogger(string name)    {return (level, func, exception, parameters) =>{    if (level >= Quartz.Logging.LogLevel.Info && func != null)    {Console.WriteLine("[" + DateTime.Now.ToLongTimeString() + "] [" + level + "] " + func(), parameters);    }    return true;};    }    public IDisposable OpenMappedContext(string key, object value, bool destructure = false)    {throw new NotImplementedException();    }    public IDisposable OpenNestedContext(string message)    {throw new NotImplementedException();    }}

          然后在當前的Scheduler中,添加日志即可,如下所示:

           //日志 LogProvider.SetCurrentLogProvider(new TestLogProvider());

          完整示例

          在添加了監聽器,日志,參數傳遞,任務特性后,完整的目錄結構,如下所示:

          示例截圖

          到此這篇關于.NET6+Quartz實現定時任務的示例詳解的文章就介紹到這了,更多相關.NET6 Quartz定時任務內容請搜索以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持!

          標簽: ASP.NET
          主站蜘蛛池模板: VI设计-LOGO设计公司-品牌设计公司-包装设计公司-导视设计-杭州易象设计 | 耐破强度测试仪-纸箱破裂强度试验机-济南三泉中石单品站 | 车载加油机品牌_ 柴油加油机厂家 | 石英陶瓷,石英坩埚,二氧化硅陶瓷-淄博百特高新材料有限公司 | 氧化铁红厂家-淄博宗昂化工 | RTO换向阀_VOC高温阀门_加热炉切断阀_双偏心软密封蝶阀_煤气蝶阀_提升阀-湖北霍科德阀门有限公司 | 安徽合肥项目申报咨询公司_安徽合肥高新企业项目申报_安徽省科技项目申报代理 | 热工多功能信号校验仪-热电阻热电偶校验仿真仪-金湖虹润仪表 | ORP控制器_ORP电极价格-上优泰百科 | 塑钢件_塑钢门窗配件_塑钢配件厂家-文安县启泰金属制品有限公司 深圳南财多媒体有限公司介绍 | 北京网站建设-企业网站建设-建站公司-做网站-北京良言多米网络公司 | Type-c防水母座|贴片母座|耳机接口|Type-c插座-深圳市步步精科技有限公司 | 美甲贴片-指甲贴片-穿戴美甲-假指甲厂家--薇丝黛拉 | 钢格板|镀锌钢格板|热镀锌钢格板|格栅板|钢格板|钢格栅板|热浸锌钢格板|平台钢格板|镀锌钢格栅板|热镀锌钢格栅板|平台钢格栅板|不锈钢钢格栅板 - 专业钢格板厂家 | DDoS安全防护官网-领先的DDoS安全防护服务商 | 郑州律师咨询-郑州律师事务所_河南锦盾律师事务所 | 外贮压-柜式-悬挂式-七氟丙烷-灭火器-灭火系统-药剂-价格-厂家-IG541-混合气体-贮压-非贮压-超细干粉-自动-灭火装置-气体灭火设备-探火管灭火厂家-东莞汇建消防科技有限公司 | 包装机传感器-搅拌站传感器-山东称重传感器厂家-济南泰钦电气 | HEYL硬度计量泵-荧光法在线溶解氧仪-净时测控技术(上海)有限公司 | 轴流风机-鼓风机-离心风机-散热风扇-罩极电机,生产厂家-首肯电子 | 真空乳化机-灌装封尾机-首页-温州精灌 | 橡胶弹簧|复合弹簧|橡胶球|振动筛配件-新乡市永鑫橡胶厂 | 昆山PCB加工_SMT贴片_PCB抄板_线路板焊接加工-昆山腾宸电子科技有限公司 | 深圳美安可自动化设备有限公司,喷码机,定制喷码机,二维码喷码机,深圳喷码机,纸箱喷码机,东莞喷码机 UV喷码机,日期喷码机,鸡蛋喷码机,管芯喷码机,管内壁喷码机,喷码机厂家 | LED灯杆屏_LED广告机_户外LED广告机_智慧灯杆_智慧路灯-太龙智显科技(深圳)有限公司 | 圆形振动筛_圆筛_旋振筛_三次元振动筛-河南新乡德诚生产厂家 | 电磁铁_推拉电磁铁_机械手电磁吸盘电磁铁厂家-广州思德隆电子公司 | 钢托盘,钢制托盘,立库钢托盘,金属托盘制造商_南京飞天金属制品实业有限公司 | 铸钢件厂家-铸钢齿轮-减速机厂家-淄博凯振机械有限公司 | 自动化生产线-自动化装配线-直流电机自动化生产线-东莞市慧百自动化有限公司 | 中细软知识产权_专业知识产权解决方案提供商 | 丙烷/液氧/液氮气化器,丙烷/液氧/液氮汽化器-无锡舍勒能源科技有限公司 | 杭州月嫂技术培训服务公司-催乳师培训中心报名费用-产后康复师培训机构-杭州优贝姆健康管理有限公司 | STRO|DTRO-STRO反渗透膜(科普)_碟滤 | 高柔性拖链电缆-聚氨酯卷筒电缆-柔性屏蔽电缆厂家-玖泰电缆 | 并离网逆变器_高频UPS电源定制_户用储能光伏逆变器厂家-深圳市索克新能源 | 小型手持气象站-空气负氧离子监测站-多要素微气象传感器-山东天合环境科技有限公司 | 杭州厂房降温,车间降温设备,车间通风降温,厂房降温方案,杭州嘉友实业爽风品牌 | 河南mpp电力管_mpp电力管生产厂家_mpp电力电缆保护管价格 - 河南晨翀实业 | 继电器模组-IO端子台-plc连接线-省配线模组厂家-世麦德 | 泰来华顿液氮罐,美国MVE液氮罐,自增压液氮罐,定制液氮生物容器,进口杜瓦瓶-上海京灿精密机械有限公司 |