您好,登錄后才能下訂單哦!
這篇文章主要介紹“C# Quartzs定時(shí)器的使用方法是什么”,在日常操作中,相信很多人在C# Quartzs定時(shí)器的使用方法是什么問題上存在疑惑,小編查閱了各式資料,整理出簡(jiǎn)單好用的操作方法,希望對(duì)大家解答”C# Quartzs定時(shí)器的使用方法是什么”的疑惑有所幫助!接下來(lái),請(qǐng)跟著小編一起來(lái)學(xué)習(xí)吧!
首先想到倒計(jì)時(shí),定時(shí)任務(wù)。大家想到的肯定就是定時(shí)器。那么定時(shí)器在web和winfrom程序中有著很大的作用。那在服務(wù)器端有沒有像定時(shí)器一樣的存在呢。
有了這些需求,我找到了第三方的組件 Quartz.Net 來(lái)實(shí)現(xiàn)(源碼位置)
(1)第一步,通過NuGet下載Quartz.Net組件并且引用到當(dāng)前工程中
(2)創(chuàng)建兩個(gè)類,一個(gè)是操作類,一個(gè)類繼承IJob 并且需要實(shí)現(xiàn)IJob的方法。
/// <summary> /// 操作類 /// </summary> public class Operation : BaseBusiness<Auction> { #region 實(shí)例化 public Operation() { _options = new Options(); } internal IOptions _options { get; } #endregion public static IScheduler scheduler; public static ISchedulerFactory factory; /// <summary> /// 獲取cron表達(dá)式 /// </summary> /// <param name="time">時(shí)間</param> /// <returns></returns> public string GetCron(DateTime? time) { var txt = Convert.ToDateTime(time).ToString("yyyy-MM-dd-HH-mm-ss"); var arr = txt.Split('-'); var result = string.Format("{0} {1} {2} {3} {4} ? {5}", arr[5], arr[4], arr[3], arr[2], arr[1], arr[0]); return result; } /// <summary> /// 刪除job /// </summary> /// <param name="Id">拍賣數(shù)據(jù)對(duì)象主鍵</param> /// <param name="GroupName">job的組名</param> public void RemoveJob(string Id, string MarkGoodsId, string GroupName) { //var jobKey = new JobKey(GroupName + Id + MId + "j", GroupName); var job = new JobKey(GroupName + Id + MarkGoodsId + "j", GroupName); scheduler.DeleteJob(job); } //清楚所有定時(shí)任務(wù) public void ClearJob() { if (scheduler != null) { scheduler.Clear(); } } }
public class SetAuctionings : Operation, IJob { public async Task Execute(IJobExecutionContext context) { await Task.Run(() => { DateTime freeTime = context.JobDetail.JobDataMap.GetDateTime("FreeTime"); var now = DateTime.Now; //記錄兩個(gè)時(shí)間的差 var days = freeTime.Subtract(now).Days; var hours = freeTime.Subtract(now).Hours; var minutes = freeTime.Subtract(now).Minutes; var seconds = freeTime.Subtract(now).Seconds; var result = days + "天" + hours + "時(shí)" + minutes + "分" + seconds + "秒"; //推送倒計(jì)時(shí) PushHelper.AuctionCountDown(markId, days, hours, minutes, seconds); //getTriggerState }); } /// <summary> /// 設(shè)置定時(shí)任務(wù) /// </summary> /// <param name="Id">標(biāo)的ID</param> public void AddQz(DateTime BeginTime, DateTime FreeTime) { var GroupName = _options.GetPKById<Options_AuctionState>("1316283839361847296").ToString(); factory = new StdSchedulerFactory(); scheduler = factory.GetScheduler().Result; var jobKey = new JobKey(GroupName + Id + MId + "j", GroupName); var GjobDetail = scheduler.GetJobDetail(jobKey); if (GjobDetail != null) { //刪除任務(wù) scheduler.DeleteJob(jobKey); } //設(shè)置Job StatefulJob var job = JobBuilder.Create<SetAuctionings>() .WithIdentity(GroupName + Id + MId + "j", GroupName) .Build(); job.JobDataMap.Put("FreeTime", FreeTime); //【方法1】 設(shè)置每秒執(zhí)行 ITrigger trigger = TriggerBuilder.Create() .WithIdentity(GroupName + Id + MId + "t", GroupName) .WithSimpleSchedule(x => x.WithIntervalInSeconds(1) .RepeatForever()) .StartAt(new DateTimeOffset(BeginTime)) .EndAt(new DateTimeOffset(FreeTime)) .Build(); //【方法2】 //var ExecSs = "0/1 * * * * ?"; //ITrigger trigger = TriggerBuilder.Create() // .WithIdentity(GroupName + Id + MeetingPlace + "t", GroupName) // .WithCronSchedule(ExecSs) // .StartAt(new DateTimeOffset(BeginTime)) // .EndAt(new DateTimeOffset(FreeTime)) // .Build(); scheduler.ScheduleJob(job, trigger); } }
以上是一個(gè)簡(jiǎn)單的封裝,可以根據(jù)這個(gè)倒計(jì)時(shí)的推送。增加一些封裝 如:暫停,恢復(fù),結(jié)束,更新等。
調(diào)用的話只需要簡(jiǎn)單的實(shí)例化一下進(jìn)行調(diào)用。
然后我在大概說(shuō)下其他封裝的思路和代碼片段;
延時(shí)倒計(jì)時(shí):
根據(jù)傳過來(lái)的參數(shù)時(shí)間進(jìn)行一個(gè)修改,刪除之前的任務(wù)重新開始一個(gè)任務(wù);
/// <summary> /// 【拍賣延時(shí)】修改倒計(jì)時(shí)任務(wù) /// </summary> /// <param name="Id"></param> /// <param name="MeetingPlace"></param> /// <param name="FreeTime"></param> public void UpdateQz(String Id, string Mid, DateTime FreeTime, DateTime LimitTime) { //scheduler = factory.GetScheduler().Result; //if (scheduler == null) // return; //拍賣進(jìn)行中 var GroupName = _options.GetPKById<Options_AuctionState>("1316283839361847296").ToString(); var jobKey = new JobKey(GroupName + Id + Mid + "j", GroupName); var GjobDetail = scheduler.GetJobDetail(jobKey); if (GjobDetail.Result == null) return; var triggerKey = new TriggerKey(GroupName + Id + Mid + "t", GroupName); var triggerr = scheduler.GetTrigger(triggerKey); var triggerBuilder = triggerr.Result.GetTriggerBuilder(); //修改結(jié)束時(shí)間 WithCronSchedule(ExecSs). ITrigger newTrigger = triggerBuilder.EndAt(new DateTimeOffset(FreeTime)).Build(); var job = GjobDetail.Result; job.JobDataMap.Put("AuctionId", Id); job.JobDataMap.Put("MarkId", Mid); job.JobDataMap.Put("FreeTime", FreeTime); job.JobDataMap.Put("LimitTime", LimitTime); //刪除任務(wù) scheduler.DeleteJob(jobKey); scheduler.ScheduleJob(job, newTrigger); //修改最終結(jié)束的定時(shí)任務(wù); SetAuctioneds setAuctioneds = new SetAuctioneds(); setAuctioneds.SetEndQz(Id, FreeTime, Mid); }
倒計(jì)時(shí)暫停:
調(diào)用組件的PauseTrigger方法可以進(jìn)行暫停; /// <summary> /// 倒計(jì)時(shí)暫停 /// </summary> public AjaxResult StopQz(string Id, string MId) { try { //方法1 //拍賣進(jìn)行中 var GroupName = _options.GetPKById<Options_AuctionState>("1316283839361847296").ToString(); var mark = Service.GetIQueryable<MarkGoods>().FirstOrDefault(x => x.Id == MId); if (mark == null) return Error("找不到標(biāo)的!"); //獲取實(shí)際結(jié)束時(shí)間。 var subEndTime = mark.EndTime.Value; //計(jì)算暫停后剩余的時(shí)間 = audEndTime(結(jié)束時(shí)間) - 當(dāng)前時(shí)間 var nowEndTime = DateTime.Now; var DifferTime = subEndTime.Subtract(nowEndTime); //追加 剩余時(shí)間 和 當(dāng)前結(jié)束時(shí)間; mark.SurplusTime = DifferTime.ToString(); //mark.EndTime = nowEndTime; //GroupName + Id + MId + "t", GroupName var TriKey = new TriggerKey(GroupName + Id + MId + "t", GroupName); var Result = scheduler.GetTriggerState(TriKey).Result; if (Result == TriggerState.None) { return Error("失?。翰淮嬖诖巳蝿?wù)!"); } if (Result == TriggerState.Paused)//暫停 { return Success("失?。涸撊蝿?wù)已暫停!"); } else { scheduler.PauseTrigger(TriKey); mark.AucTimeStatus = 2; Service.UpdateAny<MarkGoods>(mark, new List<string> { "SurplusTime", "AucTimeStatus" }); return Success("成功:任務(wù)已暫停"); } //方法2 //var mark = Service.GetIQueryable<MarkGoods>().FirstOrDefault(x => x.Id == MId); //if (mark == null) // return; ////獲取實(shí)際結(jié)束時(shí)間。 //var subEndTime = mark.EndTime.Value; ////計(jì)算暫停后剩余的時(shí)間 = audEndTime(結(jié)束時(shí)間) - 當(dāng)前時(shí)間 //var nowEndTime = DateTime.Now; //var DifferTime = subEndTime.Subtract(nowEndTime); ////追加 剩余時(shí)間 和 當(dāng)前結(jié)束時(shí)間; //mark.SurplusTime = DifferTime.ToString(); ////mark.EndTime = nowEndTime; //Service.UpdateAny<MarkGoods>(mark, new List<string> { "SurplusTime" }); ////拍賣進(jìn)行中 //var GroupName = _options.GetPKById<Options_AuctionState>("1316283839361847296").ToString(); ////關(guān)閉該定時(shí)器 //RemoveJob(mark.AuctionId, mark.Id, GroupName); } catch (Exception) { throw; } }
倒計(jì)時(shí)恢復(fù):
俗話說(shuō)得好破鏡難圓,潑出去的水很難收回來(lái)?;謴?fù)也是這個(gè)道理,比如:倒計(jì)時(shí)走到了7暫停,那么恢復(fù)的時(shí)候如何從7繼續(xù)呢。這里就牽扯到了時(shí)間戳并且存入數(shù)據(jù)庫(kù)的介入了。
/// <summary> /// 恢復(fù)倒計(jì)時(shí) /// </summary> public AjaxResult ReturnQz(string Id, string MId) { try { var mark = Service.GetIQueryable<MarkGoods>().FirstOrDefault(x => x.Id == MId); if (mark == null) return Error(); //獲取實(shí)際結(jié)束時(shí)間。 if (mark.SurplusTime.IsNullOrEmpty()) { return Error(); } TimeSpan.TryParse(mark.SurplusTime, out TimeSpan surplusTime); //方法1 //拍賣進(jìn)行中 //拍賣進(jìn)行中 var GroupName = _options.GetPKById<Options_AuctionState>("1316283839361847296").ToString(); var TriKey = new TriggerKey(GroupName + Id + MId + "t", GroupName); var Result = scheduler.GetTriggerState(TriKey).Result; if (Result == TriggerState.None) { return Error("失?。翰淮嬖诖巳蝿?wù)!"); } if (Result == TriggerState.Normal)//暫停 { return Error("失?。喝蝿?wù)正在進(jìn)行,無(wú)需恢復(fù)!"); } else { //結(jié)束時(shí)間 = 當(dāng)前時(shí)間 + 剩余時(shí)間 var endTime = DateTime.Now.Add(surplusTime); //獲取限時(shí)競(jìng)價(jià)時(shí)間 var LimitTime = endTime.AddHours(-mark.LimitHH.Value).AddMinutes(-mark.LimitMM.Value).AddSeconds(-mark.LimitSS.Value); //修改倒計(jì)時(shí)任務(wù); UpdateQz(mark.AuctionId, mark.Id, endTime, LimitTime); //追加 剩余時(shí)間 和 當(dāng)前結(jié)束時(shí)間; mark.SurplusTime = ""; mark.EndTime = endTime; var C1 = endTime.Subtract(DateTime.Now); var C2 = endTime.Subtract(LimitTime); if (C1 > C2) mark.AucTimeStatus = 0; else mark.AucTimeStatus = 1; Service.UpdateAny<MarkGoods>(mark, new List<string> { "SurplusTime", "EndTime", "AucTimeStatus" }); return Success(); } //方法2 //var mark = Service.GetIQueryable<MarkGoods>().FirstOrDefault(x => x.Id == MId); //if (mark == null) // return; ////獲取實(shí)際結(jié)束時(shí)間。 //if (mark.SurplusTime.IsNullOrEmpty()) //{ // return; //} //TimeSpan.TryParse(mark.SurplusTime, out TimeSpan surplusTime); //TimeSpan a = new TimeSpan(1, 1, 1); ////結(jié)束時(shí)間 = 當(dāng)前時(shí)間 + 剩余時(shí)間 //var endTime = DateTime.Now.Add(surplusTime); ////獲取限時(shí)競(jìng)價(jià)時(shí)間 //var LimitTime = endTime.AddHours(-mark.LimitHH.Value).AddMinutes(-mark.LimitMM.Value).AddSeconds(-mark.LimitSS.Value); ////新增倒計(jì)時(shí)任務(wù); //AddQz(mark.AuctionId, mark.Id, DateTime.Now, endTime, LimitTime); ////追加 剩余時(shí)間 和 當(dāng)前結(jié)束時(shí)間; //mark.SurplusTime = ""; //mark.EndTime = endTime; //Service.UpdateAny<MarkGoods>(mark, new List<string> { "SurplusTime", "EndTime" }); } catch (Exception ex) { throw; } }
到此,關(guān)于“C# Quartzs定時(shí)器的使用方法是什么”的學(xué)習(xí)就結(jié)束了,希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí),快去試試吧!若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí),請(qǐng)繼續(xù)關(guān)注億速云網(wǎng)站,小編會(huì)繼續(xù)努力為大家?guī)?lái)更多實(shí)用的文章!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。