C# Quartzs定時器的使用教程
前言
首先想到倒計時，定時任務。大傢想到的肯定就是定時器。那麼定時器在web和winfrom程序中有著很大的作用。那在服務器端有沒有像定時器一樣的存在呢。
有瞭這些需求，我找到瞭第三方的組件 Quartz.Net 來實現（源碼位置）
實現步驟
（1）第一步，通過NuGet下載Quartz.Net組件並且引用到當前工程中
（2）創建兩個類，一個是操作類，一個類繼承IJob 並且需要實現IJob的方法。
/// <summary>
/// 操作類
/// </summary>
public class Operation : BaseBusiness<Auction>
{
#region 實例化
public Operation()
{
_options = new Options();
}
internal IOptions _options { get; }
#endregion
public static IScheduler scheduler;
public static ISchedulerFactory factory;
/// <summary>
/// 獲取cron表達式
/// </summary>
/// <param name="time">時間</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">拍賣數據對象主鍵</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);
}
//清楚所有定時任務
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;
//記錄兩個時間的差
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 + "時" + minutes + "分" + seconds + "秒";
//推送倒計時
PushHelper.AuctionCountDown(markId, days, hours, minutes, seconds);
//getTriggerState
});
}
/// <summary>
/// 設置定時任務
/// </summary>
/// <param name="Id">標的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)
{
//刪除任務
scheduler.DeleteJob(jobKey);
}
//設置Job StatefulJob
var job = JobBuilder.Create<SetAuctionings>()
.WithIdentity(GroupName + Id + MId + "j", GroupName)
.Build();
job.JobDataMap.Put("FreeTime", FreeTime);
//【方法1】 設置每秒執行
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);
}
}
以上是一個簡單的封裝，可以根據這個倒計時的推送。增加一些封裝 如：暫停，恢復，結束，更新等。
調用的話隻需要簡單的實例化一下進行調用。
然後我在大概說下其他封裝的思路和代碼片段；
延時倒計時：
根據傳過來的參數時間進行一個修改，刪除之前的任務重新開始一個任務；
/// <summary>
/// 【拍賣延時】修改倒計時任務
/// </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;
//拍賣進行中
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();
//修改結束時間 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);
//刪除任務
scheduler.DeleteJob(jobKey);
scheduler.ScheduleJob(job, newTrigger);
//修改最終結束的定時任務；
SetAuctioneds setAuctioneds = new SetAuctioneds();
setAuctioneds.SetEndQz(Id, FreeTime, Mid);
}
倒計時暫停：
調用組件的PauseTrigger方法可以進行暫停；
/// <summary>
/// 倒計時暫停
/// </summary>
public AjaxResult StopQz(string Id, string MId)
{
try
{
//方法1
//拍賣進行中
var GroupName = _options.GetPKById<Options_AuctionState>("1316283839361847296").ToString();
var mark = Service.GetIQueryable<MarkGoods>().FirstOrDefault(x => x.Id == MId);
if (mark == null)
return Error("找不到標的！");
//獲取實際結束時間。
var subEndTime = mark.EndTime.Value;
//計算暫停後剩餘的時間 = audEndTime（結束時間） - 當前時間
var nowEndTime = DateTime.Now;
var DifferTime = subEndTime.Subtract(nowEndTime);
//追加 剩餘時間 和 當前結束時間；
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("失敗：不存在此任務！");
}
if (Result == TriggerState.Paused)//暫停
{
return Success("失敗：該任務已暫停！");
}
else
{
scheduler.PauseTrigger(TriKey);
mark.AucTimeStatus = 2;
Service.UpdateAny<MarkGoods>(mark, new List<string> { "SurplusTime", "AucTimeStatus" });
return Success("成功：任務已暫停");
}
//方法2
//var mark = Service.GetIQueryable<MarkGoods>().FirstOrDefault(x => x.Id == MId);
//if (mark == null)
// return;
////獲取實際結束時間。
//var subEndTime = mark.EndTime.Value;
////計算暫停後剩餘的時間 = audEndTime（結束時間） - 當前時間
//var nowEndTime = DateTime.Now;
//var DifferTime = subEndTime.Subtract(nowEndTime);
////追加 剩餘時間 和 當前結束時間；
//mark.SurplusTime = DifferTime.ToString();
////mark.EndTime = nowEndTime;
//Service.UpdateAny<MarkGoods>(mark, new List<string> { "SurplusTime" });
////拍賣進行中
//var GroupName = _options.GetPKById<Options_AuctionState>("1316283839361847296").ToString();
////關閉該定時器
//RemoveJob(mark.AuctionId, mark.Id, GroupName);
}
catch (Exception)
{
throw;
}
}
倒計時恢復：
俗話說得好破鏡難圓，潑出去的水很難收回來。恢復也是這個道理，比如：倒計時走到瞭7暫停，那麼恢復的時候如何從7繼續呢。這裡就牽扯到瞭時間戳並且存入數據庫的介入瞭。
/// <summary>
/// 恢復倒計時
/// </summary>
public AjaxResult ReturnQz(string Id, string MId)
{
try
{
var mark = Service.GetIQueryable<MarkGoods>().FirstOrDefault(x => x.Id == MId);
if (mark == null)
return Error();
//獲取實際結束時間。
if (mark.SurplusTime.IsNullOrEmpty())
{
return Error();
}
TimeSpan.TryParse(mark.SurplusTime, out TimeSpan surplusTime);
//方法1
//拍賣進行中
//拍賣進行中
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("失敗：不存在此任務！");
}
if (Result == TriggerState.Normal)//暫停
{
return Error("失敗：任務正在進行，無需恢復！");
}
else
{
//結束時間 = 當前時間 + 剩餘時間
var endTime = DateTime.Now.Add(surplusTime);
//獲取限時競價時間
var LimitTime = endTime.AddHours(-mark.LimitHH.Value).AddMinutes(-mark.LimitMM.Value).AddSeconds(-mark.LimitSS.Value);
//修改倒計時任務；
UpdateQz(mark.AuctionId, mark.Id, endTime, LimitTime);
//追加 剩餘時間 和 當前結束時間；
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;
////獲取實際結束時間。
//if (mark.SurplusTime.IsNullOrEmpty())
//{
// return;
//}
//TimeSpan.TryParse(mark.SurplusTime, out TimeSpan surplusTime);
//TimeSpan a = new TimeSpan(1, 1, 1);
////結束時間 = 當前時間 + 剩餘時間
//var endTime = DateTime.Now.Add(surplusTime);
////獲取限時競價時間
//var LimitTime = endTime.AddHours(-mark.LimitHH.Value).AddMinutes(-mark.LimitMM.Value).AddSeconds(-mark.LimitSS.Value);
////新增倒計時任務；
//AddQz(mark.AuctionId, mark.Id, DateTime.Now, endTime, LimitTime);
////追加 剩餘時間 和 當前結束時間；
//mark.SurplusTime = "";
//mark.EndTime = endTime;
//Service.UpdateAny<MarkGoods>(mark, new List<string> { "SurplusTime", "EndTime" });
}
catch (Exception ex)
{
throw;
}
}
以上代碼均是提供思路，使用時需要進行代碼簡單改動。
以上就是C# Quartzs定時器的使用教程的詳細內容，更多關於C# Quartzs定時器的資料請關註WalkonNet其它相關文章！
推薦閱讀：
- Unity實現菜品識別的示例代碼
- Unity接入百度AI實現通用物體和場景識別
- Spring Boot 配置 Quartz 定時任務的方法
- Unity接入百度AI實現果蔬識別
- C#時間格式轉換為時間戳的方法步驟