C# Quartzs定时器的使用教程

目录

前言

首先想到倒计时，定时任务。大家想到的肯定就是定时器。那么定时器在web和winfrom程序中有着很大的作用。那在服务器端有没有像定时器一样的存在呢。

有了这些需求，我找到了第三方的组件 quartz.net 来实现（源码位置）

实现步骤

（1）第一步，通过nuget下载quartz.net组件并且引用到当前工程中

（2）创建两个类，一个是操作类，一个类继承ijob 并且需要实现ijob的方法。

/// <summary>    /// 操作类    /// </summary>    public class operation : babusiness<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 tauctionings : 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 conds = freetime.subtrac办公用笔记本推荐t(now).conds;                var result = days + "天" + hours + "时" + minutes + "分" + conds + "秒";//推送倒计时                pushhelper.auctioncountdown(markid, days, hours, minutes, conds);                //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<tauctionings>()                       .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.withintervalinconds(1)                .repeatforever())                .startat(new datetimeofft(begintime))                .endat(new datetimeofft(freetime))                .build();            //【方法2】            //var execss = "0/1 * * * * ?";            //itrigger trigger = triggerbuilder.create()            //    .withidentity(groupname + id + meetingplace + "t", groupname)            //    .withcronschedule(execss)            //    .startat(new datetimeofft(begintime))            //    .endat(new datetimeofft(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 datetimeofft(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);              //修改最终结束的定时任务；            tauctioneds tauctioneds = new tauctioneds();            tauctioneds.tendqz(id, freetime, mid);        }

倒计时暂停：

调用组件的pautrigger方法可以进行暂停；/// <summary>/// 倒计时暂停/// </summary>public ajaxresult stopqz(string id, string mid){    try    {           //方法1        //拍卖进行中        var groupname = _options.getpkbyid<options_auctionstate>("1316283839361847296").tostring();           var mark = rvice.getiqueryable<markgoods>().firstordefault(x => x.id == mid);        if (ma观察小蚂蚁rk == 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.paud)//暂停        {            return success("失败：该任务已暂停！");         }        el        {            scheduler.pautrigger(trikey);            mark.auctimestatus = 2;            rvice.updateany<markgoods>(mark, new list<string> { "surplustime", "auctimestatus" });            return success("成功：任务已暂停");        }            //方法2        //var mark = rvice.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;        //rvice.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 = rvice.getiqueryable<markgoods>().firstordefault(x => x.id == mid);                if (mark == null)              新陈      return error();                //获取实际结束时间。                if (mark.surplustime.isnullorempty())                {                    return error();                }                timespan.trypar(mark.surplustime, out timespan surplustime);                //方法1                //拍卖进行中                //拍卖进行中                var groupname = _options.getpkb欢度国庆资料yid<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("失败：任务正在进行，无需恢复！");                }                el                {                    //结束时间  = 当前时间 + 剩余时间                    var endtime = datetime.now.add(surplustime);                    //获取限时竞价时间                    var limittime = endtime.addhours(-mark.limithh.value).addminutes(-mark.limitmm.value).addconds(-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;                    el                        mark.auctimestatus = 1;                    rvice.updateany<markgoods>(mark, new list<string> { "surplustime", "endtime", "auctimestatus" });                    return success();                }                //方法2                //var mark = rvice.getiqueryable<markgoods>().firstordefault(x => x.id == mid);                //if (mark == null)                //    return;                ////获取实际结束时间。                //if (mark.surplustime.isnullorempty())                //{                //    return;                //}                //timespan.trypar(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).addconds(-mark.limitss.value);                ////新增倒计时任务；                //addqz(mark.auctionid, mark.id, datetime.now, endtime, limittime);                ////追加 剩余时间 和 当前结束时间；                //mark.surplustime = "";                //mark.endtime = endtime;                //rvice.updateany<markgoods>(mark, new list<string> { "surplustime", "endtime" });            }            catch (exception ex)            {                throw;            }        }

以上代码均是提供思路，使用时需要进行代码简单改动。

以上就是c# quartzs定时器的使用教程的详细内容，更多关于c# quartzs定时器的资料请关注www.887551.com其它相关文章！