C# Quartzs定时器的使用教程
程序员文章站
2022-06-25 07:55:00
目录前言实现步骤前言首先想到倒计时,定时任务。大家想到的肯定就是定时器。那么定时器在web和winfrom程序中有着很大的作用。那在服务器端有没有像定时器一样的存在呢。有了这些需求,我找到了第三方的组...
前言
首先想到倒计时,定时任务。大家想到的肯定就是定时器。那么定时器在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定时器的资料请关注其它相关文章!
推荐阅读
-
php使用Image Magick将PDF文件转换为JPG文件的方法_PHP教程
-
PHP调试利器XDebug的安装与使用_PHP教程
-
php使用curl判断网页404(不存在)的方法 原创,curl404_PHP教程
-
PHP的Laravel框架结合MySQL与Redis数据库的使用部署,laravelredis_PHP教程
-
ToolBar控件在C#开发APP中的使用方式【附案例源码】——Smobiler移动开发平台
-
PHP中使用curl伪造IP的简单方法,phpcurl伪造ip_PHP教程
-
使用 eAccelerator加速PHP代码的方法_PHP教程
-
php中使用临时表查询数据的一个例子_PHP教程
-
使用c#创建php可以调用的dll
-
腾讯会议怎么使用微信账号登录? 微信登录腾讯会议的教程