本篇文章給大家分享的是有關(guān)Quartz.Net怎么在.Net Core項目中使用,小編覺得挺實用的,因此分享給大家學(xué)習(xí),希望大家閱讀完這篇文章后可以有所收獲,話不多說,跟著小編一起來看看吧。
創(chuàng)新互聯(lián)建站-專業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性價比安新網(wǎng)站開發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫,直接使用。一站式安新網(wǎng)站制作公司更省心,省錢,快速模板網(wǎng)站建設(shè)找我們,業(yè)務(wù)覆蓋安新地區(qū)。費用合理售后完善,十多年實體公司更值得信賴。一、介紹
Quartz.NET是一個強(qiáng)大、開源、輕量的作業(yè)調(diào)度框架,是 OpenSymphony 的 Quartz API 的.NET移植,用C#改寫,可用于winform和asp.net應(yīng)用中。它靈活而不復(fù)雜。你能夠用它來為執(zhí)行一個作業(yè)而創(chuàng)建簡單的或復(fù)雜的作業(yè)調(diào)度。它有很多特征,如:數(shù)據(jù)庫支持,集群,插件,支持cron-like表達(dá)式等等。
實踐教程
以WebApi項目舉例,用VS腳手架功能新建WebApi項目。
public void ConfigureServices(IServiceCollection services) { services.AddMvc(); services.AddSingleton<ISchedulerFactory, StdSchedulerFactory>();//注冊ISchedulerFactory的實例。 }
[Route("api/[controller]")] public class ValuesController : Controller { private readonly ISchedulerFactory _schedulerFactory; private IScheduler _scheduler; public ValuesController(ISchedulerFactory schedulerFactory) { this._schedulerFactory = schedulerFactory; } [HttpGet] public async Task<string[]> Get() { //1、通過調(diào)度工廠獲得調(diào)度器 _scheduler = await _schedulerFactory.GetScheduler(); //2、開啟調(diào)度器 await _scheduler.Start(); //3、創(chuàng)建一個觸發(fā)器 var trigger = TriggerBuilder.Create() .WithSimpleSchedule(x => x.WithIntervalInSeconds(2).RepeatForever())//每兩秒執(zhí)行一次 .Build(); //4、創(chuàng)建任務(wù) var jobDetail = JobBuilder.Create<MyJob>() .WithIdentity("job", "group") .Build(); //5、將觸發(fā)器和任務(wù)器綁定到調(diào)度器中 await _scheduler.ScheduleJob(jobDetail, trigger); return await Task.FromResult(new string[] { "value1", "value2" }); } }
public class MyJob : IJob//創(chuàng)建IJob的實現(xiàn)類,并實現(xiàn)Excute方法。 { public Task Execute(IJobExecutionContext context) { return Task.Run(() => { using (StreamWriter sw = new StreamWriter(@"C:\Users\Administrator\Desktop\error.log", true, Encoding.UTF8)) { sw.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH-mm-ss")); } }); } }
輸出的結(jié)果:
2018-08-03 00-03-19
2018-08-03 00-03-20
2018-08-03 00-03-22
2018-08-03 00-03-24
2018-08-03 00-03-26
上面這種執(zhí)行的Job沒有參數(shù),當(dāng)需要參數(shù)可以通過下面兩種方法傳遞參數(shù):
1、在Trigger中添加參數(shù)值
var trigger3 = TriggerBuilder.Create() .WithSimpleSchedule(x =>x.WithIntervalInSeconds(2).RepeatForever())//間隔2秒 一直執(zhí)行 .UsingJobData("key1", 321) //通過在Trigger中添加參數(shù)值 .UsingJobData("key2", "123") .WithIdentity("trigger2", "group1") .Build();
2、在Job中添加參數(shù)值
IJobDetail job = JobBuilder.Create<MyJob>() .UsingJobData("key1", 123)//通過Job添加參數(shù)值 .UsingJobData("key2", "123") .WithIdentity("job1", "group1") .Build();
通過下面方法在Job中獲取參數(shù)值
public class MyJob : IJob { public Task Execute(IJobExecutionContext context) { var jobData = context.JobDetail.JobDataMap;//獲取Job中的參數(shù) var triggerData = context.Trigger.JobDataMap;//獲取Trigger中的參數(shù) var data = context.MergedJobDataMap;//獲取Job和Trigger中合并的參數(shù) var value1= jobData.GetInt("key1"); var value2= jobData.GetString("key2"); var dateString = DateTime.Now.ToString("yyyy-MM-dd HH-mm-ss");return Task.Run(() => { using (StreamWriter sw = new StreamWriter(@"C:\Users\Administrator\Desktop\error.log", true, Encoding.UTF8)) { sw.WriteLine(dateString); } }); } }
當(dāng)Job中的參數(shù)和Trigger中的參數(shù)名稱一樣時,用 context.MergedJobDataMap獲取參數(shù)時,Trigger中的值會覆蓋Job中的值。
3、上面那種情況只能適應(yīng)那種,參數(shù)值不變的情況。
假如有這種情況,這次的參數(shù)值是上一次執(zhí)行后計算的值,就不能使用上面方法了。如 每兩秒實現(xiàn)累加一操作,現(xiàn)在初始值是0,如果按照上面那種獲取值的操作,一直都是0+1,返回值一直都是1。為了滿足這個情況,只需要加一個特性[PersistJobDataAfterExecution]。
[PersistJobDataAfterExecution]//更新JobDetail的JobDataMap的存儲副本,以便下一次執(zhí)行這個任務(wù)接收更新的值而不是原始存儲的值 public class MyJob : IJob { public Task Execute(IJobExecutionContext context) { var jobData = context.JobDetail.JobDataMap; var triggerData = context.Trigger.JobDataMap; var data = context.MergedJobDataMap; var value1 = jobData.GetInt("key1"); var value2 = jobData.GetString("key2"); var value3 = data.GetString("key2"); var dateString = DateTime.Now.ToString("yyyy-MM-dd HH-mm-ss"); Random random = new Random(); jobData["key1"] = random.Next(1, 20);//這里面給key賦值,下次再進(jìn)來執(zhí)行的時候,獲取的值為更新的值,而不是原始值 jobData["key2"] = dateString; return Task.Run(() => { using (StreamWriter sw = new StreamWriter(@"C:\Users\Administrator\Desktop\error.log", true, Encoding.UTF8)) { sw.WriteLine($"{dateString} value1:{value1} value2:{value2}"); } //context.Scheduler.DeleteJob(context.JobDetail.Key); //context.Scheduler.Shutdown(); }); } }
三、Quartz.Net組成
Quartz主要有三部分組成任務(wù)(Job)、觸發(fā)器(Trigger)和調(diào)度器(Schedule)。
3.1 任務(wù)
Job就是執(zhí)行的作業(yè),Job需要繼承IJob接口,實現(xiàn)Execute方法。Job中執(zhí)行的參數(shù)從Execute方法的參數(shù)中獲取。
3.2 觸發(fā)器
觸發(fā)器常用的有兩種:SimpleTrigger觸發(fā)器和CronTrigger觸發(fā)器。
SimpleTrigger:能是實現(xiàn)簡單業(yè)務(wù),如每隔幾分鐘,幾小時觸發(fā)執(zhí)行,并限制執(zhí)行次數(shù)。
var trigger = TriggerBuilder.Create() .WithSimpleSchedule(x => x.WithIntervalInSeconds(2).WithRepeatCount(5))//間隔2秒 執(zhí)行6次 .UsingJobData("key1", 321) .WithIdentity("trigger", "group") .Build();
CronTrigger:Cron表達(dá)式包含7個字段,秒 分 時 月內(nèi)日期 月 周內(nèi)日期 年(可選)。
舉例:
var trigger = TriggerBuilder.Create() .WithCronSchedule("0 0 0 1 1 ?")// 每年元旦1月1日 0 點觸發(fā) .UsingJobData("key1", 321) .UsingJobData("key2", "trigger-key2") .WithIdentity("trigger4", "group14") .Build();
"0 15 10 * * ? *" 每天上午10:15觸發(fā)
"0 0-5 14 * * ?" 每天下午2點到下午2:05期間的每1分鐘觸發(fā)
3.3 調(diào)度器
調(diào)度器就是將任務(wù)和觸發(fā)器綁定,讓觸發(fā)器觸發(fā)的時候去執(zhí)行任務(wù)。
以上就是Quartz.Net怎么在.Net Core項目中使用,小編相信有部分知識點可能是我們?nèi)粘9ぷ鲿姷交蛴玫降?。希望你能通過這篇文章學(xué)到更多知識。更多詳情敬請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
本文題目:Quartz.Net怎么在.NetCore項目中使用-創(chuàng)新互聯(lián)
文章URL:http://jinyejixie.com/article46/coepeg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供外貿(mào)網(wǎng)站建設(shè)、企業(yè)網(wǎng)站制作、網(wǎng)站制作、定制開發(fā)、商城網(wǎng)站、網(wǎng)站維護(hù)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容