Quartz.Net定时任务EF+MVC版的web服务
之前项目采用JAVA 的 Quartz 进行定时服调度务处理程序,目前在.NET下面使用依然可以完成相同的工作任务,其实什么语言不重要,关键是我们要学会利用语言实现价值。它是一个简单的执行任务计划的组件,基本包括这三部分:Job(作业)、Trigger(触发器)、scheduler(调度器)。
1.Job 作业:需要在任务计划中执行的具体逻辑操作
2.Trigger 触发器:需要什么时间什么规则来去执行Job 作业
3.scheduler 调度器 :将Job 和 Trigger 注册到 scheduler 调度器中,主要负责协调Job、Trigger 的运行
.NET可以做成服务端方式也可以做成web端处理,本方法是采用web的方式处理,话不多说直接上干活。在这里借鉴了别人的方式但是别人的有些很多漏洞和错误,我也进行了抛砖引玉加以完善。
首先先创建一个新项目,新建一个类库JobLibrary项目库:
一个Job 创建一个实例类,创建两个实例类一个是UpdateCompleteJob.cs、UpdateAutoCancelStateJob.cs (之所以创建两个Job是为了能方便大家了解这个组件可以同时执行多个任务)
一:UpdateCompleteJob.cs 代码如下:
namespace JobLibrary {// quartz.net 禁止并发执行DisallowConcurrentExecution是禁止相同JobDetail同时执行,而不是禁止多个不同JobDetail同时执行。建议加上该特性,防止由于任务执行时间太长,长时间占用资源,导致其它任务堵塞。 [DisallowConcurrentExecution]public class UpdateCompleteJob : IJob{TRA_BargainOrder_Test ExpressModel;/// <summary>///在Job 中我们必须实现IJob接口中的Execute 这个方法,才能正确的使用Job/// </summary>public async Task Execute(IJobExecutionContext context){using (var _DbContext = new DefaultDbContext()){//var tarorder = new TRA_BargainOrder_Test()//{// BargainOrderCode="12345688899",// OrderStatus=1//};//_DbContext.TRA_BargainOrders.Add(tarorder);////保存记录,返回受影响的行数//int record = _DbContext.SaveChanges();//Console.WriteLine("添加{0}记录成功", record);var query = _DbContext.TRA_BargainOrders.Where(c => c.OrderStatus == (int)EnumHelper.OrderStatus.Sended);//var query = _DbContext.TRA_BargainOrders.Where(c => c.OrderStatus == (int)EnumHelper.OrderStatus.Sended// && c.PayStatus == (int)EnumHelper.PayStatus.Paid).OrderBy(c => c.CreateTime).ToList().Take(20);foreach (var item in query){if (!string.IsNullOrEmpty(item.ExpressCode)){//根据快递单号获取快递订单信息try{ExpressModel = await _DbContext.TRA_BargainOrders.SingleOrDefaultAsync(s => s.ExpressCode == item.ExpressCode);}catch (Exception e){new Exception(e.Message);}//确定 已签收 修改订单状态 已完成if (ExpressModel.OrderStatus ==1&& ExpressModel.ischeck == 1){var order = _DbContext.TRA_BargainOrders.FirstOrDefault(c => c.BargainOrderCode == item.BargainOrderCode);// var order = _DbContext.Set<TRA_BargainOrder_Test>().FirstOrDefault(c => c.BargainOrderCode == item.BargainOrderCode);order.OrderStatus = (int)EnumHelper.OrderStatus.Over;order.FlowStatus = (int)EnumHelper.FlowStatus.Over;order.UpdateTime = DateTime.Now;_DbContext.TRA_BargainOrders.Attach(order);_DbContext.Entry(order).State = EntityState.Modified;_DbContext.TRA_BargainOrders.AddOrUpdate(order);}}}//保存数据库不能放到循环中操作 try{_DbContext.SaveChanges();}catch (Exception E){ throw new Exception(E.Message); }}}} }
二:UpdateAutoCancelStateJob.cs 代码如下:
namespace JobLibrary {//在Quartz.Net中,一个job(作业)即为一个类,为了让job能在Quartz.Net的体系中执行,我们必须实现Quartz.Net提供的IJob接口的Execute方法,如本例所实现的IJob接口UpdateAutoCancelStateJob类: [DisallowConcurrentExecution]public class UpdateAutoCancelStateJob : IJob{public async Task Execute(IJobExecutionContext context){using (var _DbContext = new DefaultDbContext()){var order = await _DbContext.TRA_BargainOrders.FirstOrDefaultAsync(c => c.OrderStatus == (int)EnumHelper.OrderStatus.UnSend && c.PayStatus == (int)EnumHelper.PayStatus.UnPaid);if (order!=null){if (DateDiff(DateTime.Now, order.CreateTime) > 30){order.OrderStatus = (int)EnumHelper.OrderStatus.Cancel;order.FlowStatus = (int)EnumHelper.FlowStatus.Cancel;order.UpdateTime = DateTime.Now;_DbContext.SaveChanges();}}}}//计算时间差的方法private int DateDiff(DateTime DateTime1, DateTime DateTime2){TimeSpan tss = Convert.ToDateTime(DateTime1) - Convert.ToDateTime(DateTime2);int dateDiff = Convert.ToInt32(tss.TotalMinutes);return dateDiff;}} }
以下是web启动项目下的
三:设置Trigger 触发器,在实际中我是将Trigger和Job 直接注册到 scheduler 调度器中;就是需要将类库生成的DLL 拷贝到你的需要执行的项目的文件中
触发器的JobManage代码如下:
public class JobManage{private static ISchedulerFactory sf = new StdSchedulerFactory();//调度器private static IScheduler scheduler;/// <summary>/// 读取调度器配置文件的开始时间/// </summary>//public static void StartScheduleFromConfig()public static async void StartScheduleFromConfigAsync(){string currentDir = AppDomain.CurrentDomain.BaseDirectory;try{XDocument xDoc = XDocument.Load(Path.Combine(currentDir, "JobScheduler.config"));var jobScheduler = from x in xDoc.Descendants("JobScheduler") select x;var jobs = jobScheduler.Elements("Job");XElement jobDetailXElement, triggerXElement;//获取调度器scheduler = await sf.GetScheduler();//声明触发器 CronTriggerImpl cronTrigger;foreach (var job in jobs){//加载程序集joblibaray Assembly ass = Assembly.LoadFrom(Path.Combine(currentDir, job.Element("DllName").Value));//获取任务名字jobDetailXElement = job.Element("JobDetail");//获取任务触发的时间triggerXElement = job.Element("Trigger");JobDetailImpl jobDetail = new JobDetailImpl(jobDetailXElement.Attribute("job").Value,jobDetailXElement.Attribute("group").Value,ass.GetType(jobDetailXElement.Attribute("jobtype").Value));if (triggerXElement.Attribute("type").Value.Equals("CronTrigger")){cronTrigger = new CronTriggerImpl(triggerXElement.Attribute("name").Value,triggerXElement.Attribute("group").Value,triggerXElement.Attribute("expression").Value);//添加定时器await scheduler.ScheduleJob(jobDetail, cronTrigger);}}//开始执行定时器await scheduler.Start();}catch (Exception E){throw new Exception(E.Message);}}/// <summary>/// 关闭定时器/// </summary>public static void ShutDown(){if (scheduler != null && !scheduler.IsShutdown){scheduler.Shutdown();}}/// <summary>/// 从Scheduler 移除当前的Job,修改Trigger /// </summary>/// <param name="jobExecution"></param>/// <param name="time"></param>public static void ModifyJobTime(IJobExecutionContext jobExecution, String time){scheduler = jobExecution.Scheduler;ITrigger trigger = jobExecution.Trigger;IJobDetail jobDetail = jobExecution.JobDetail;if (trigger != null){CronTriggerImpl ct = (CronTriggerImpl)trigger;// 移除当前进程的Job scheduler.DeleteJob(jobDetail.Key);// 修改Trigger ct.CronExpressionString = time;Console.WriteLine("CronTrigger getName " + ct.JobName);// 重新调度jobDetail scheduler.ScheduleJob(jobDetail, ct);}}}
四:配置文件,主要是控制任务执行的时间和Job 的加载 JobScheduler.config
<?xml version="1.0" encoding="utf-8"?> <configuration><!--配置文件,主要是控制任务执行的时间和Job 的加载 配置中重要的几个属性 <DllName>JobLibrary.dll</DllName> dll的名字 ;jobtype 属性是dll名字+实例类的名字;expression 这个是设置执行的时间--><JobScheduler><Job Description="作业1"><DllName>JobLibrary.dll</DllName><JobDetail job="test1" group="test1Group" jobtype="JobLibrary.UpdateCompleteJob" /><Trigger name="test1" group="test1Group" type="CronTrigger" expression="0 0/50 * * * ?" /> <!--0 0/10 * * * ? 10分钟--> </Job><Job Description="作业2"><DllName>JobLibrary.dll</DllName><JobDetail job="test2" group="test2Group" jobtype="JobLibrary.UpdateAutoCancelStateJob" /><Trigger name="test2" group="test2Group" type="CronTrigger" expression="0/10 * * * * ?" /> <!--0/10 * * * * ? 10秒--> <!-- 每天凌晨1点执行一次:0 0 1 * * ? --> <!--每天凌晨1点30分执行一次:0 30 1 * * ?--> <!--每天的0点、13点、18点、21点都执行一次:0 0 0,13,18,21 * * ? --><!-- "0 0/5 14,18 * * ?" 每天14点或18点中,每5分钟触发--></Job></JobScheduler><system.web><compilation debug="true" targetFramework="4.6.1" /><httpRuntime targetFramework="4.6.1" /></system.web></configuration>
五:需要将scheduler 调度器注册到程序中;在程序中Global.asax.cs 中文件中添加注册,在这里启动执行任务
//需要将scheduler 调度器注册到程序中;在程序中Global.asax.cs 中文件中添加注册,在这里启动执行任务。protected void Application_Start(){AreaRegistration.RegisterAllAreas();FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);RouteConfig.RegisterRoutes(RouteTable.Routes);BundleConfig.RegisterBundles(BundleTable.Bundles);//执行的任务 JobManage.StartScheduleFromConfigAsync();}//当网站关闭时结束正在执行的工作protected void Application_End(object sender, EventArgs e){// 在应用程序关闭时运行的代码 JobManage.ShutDown();}
六:至此可以启动服务完成定时调度处理任务了
转载于:https://www.cnblogs.com/Warmsunshine/p/8430451.html
Quartz.Net定时任务EF+MVC版的web服务相关推荐
- 使用Spring MVC开发Restful Web服务
REST简介 摘自Wikipedia: REST风格的体系结构由客户端和服务器组成. 客户端向服务器发起请求: 服务器处理请求并返回适当的响应. 请求和响应围绕资源表示的传递而构建. 资源本质上可以是 ...
- 轻量级 Java Web 服务框架漫谈
博文太长了, 还是先说下概要: 框架"轻量"与否可以从两方面来看待: 1) 框架本身的体量 - 例如小 jar 无依赖的苗条框架; 2) 用户使用框架是否获得各种便利而无阻隔(&q ...
- Web 服务系列标准和规范
Web 服务系列标准是一组新兴标准,支持异类信息技术流程和系统间的互操作集成.可以将其视为一种新的具有自包含性和自描述性的 Web 应用程序,能提供从最基本的到最复杂的业务和科学流程的功能和互操作机制 ...
- 云原生Web服务框架ESA Restlight
云原生Web服务框架ESA Restlight ESA Stack(Elastic Service Architecture) 是OPPO云计算中心孵化的技术品牌,致力于微服务相关技术栈,帮助用户快速 ...
- quartz定时定时任务执行两次
quartz框架没问题. 流程: sping-quartz配置 <?xml version="1.0" encoding="UTF-8"?> < ...
- SpringBoot结合Quartz实现定时任务
<从零打造项目>系列文章 工具 比MyBatis Generator更强大的代码生成器 ORM框架选型 SpringBoot项目基础设施搭建 SpringBoot集成Mybatis项目实操 ...
- spring框架使用Quartz执行定时任务实例详解
版权声明:本文为博主原创文章,如需转载,请标明出处. https://blog.csdn.net/alan_liuyue/article/details/80382324 Quartz简介 1.Qua ...
- 菜鸟级三层框架(EF+MVC)项目实战之 系列一 EF零基础创建领域模型
系列概述:全系列会详细介绍抽象工厂三层的搭建,以及EF高级应用和 ASP.NET MVC3.0简单应用,应用到的技术有Ef.Lambda.Linq.Interface.T4等. 由于网上对涉及到的技术 ...
- Spring+Quartz实现定时任务
Spring整合Quartz实现定时任务步骤很简单,大致需要经过如下几步:创建任务(Job).配置JobDetail.配置触发器(Trigger).配置SchedulerFactoryBean 首先使 ...
最新文章
- CentOS7 service network start命令启动时报错解决方法
- mysql的limit和or_面试官:谈谈MySQL的limit用法、逻辑分页和物理分页
- python 为何要学16进制,从十六进制Python中的补
- VTK:曲线样条CurveSpline用法实战
- SSIS添加分区-动态
- (八)ASP.NET自定义用户控件(1)
- 《BI那点儿事》Cube的存储
- mongodb安装指南 及使用
- 得到常用汉字的拼音首字母
- 微信数据解密-dat查看
- [Hulu] 数组最大价值
- 单片机红绿灯加强版(kile仿真程序和protues硬件仿真)
- 携手共进 智享未来丨美格智能2023年代理商合作伙伴大会成功举办
- flutter 打开设置面板进行基本设置
- 硬件设计中与门、或门、非门电路详解
- 5.5 进入编辑模式 5.6 vim命令模式 5.7 vim实践
- python接入支付宝接口
- flashwindow vb_VB6.0 加载ShockwaveFlash(flash)控件
- 喜讯:世界首款阿兹海默老年痴呆症治疗药将上市
- 俄罗斯钓鱼四服务器未响应,俄罗斯钓鱼4《RussianFishing4》sbirolino钓组攻略
热门文章
- 解决 /lib64/libc.so.6: version `GLIBC_2.15‘ not found 问题
- Servlet使用基本步骤及功能实现
- 电脑基础操作_苹果电脑基础操作,和使用须知
- python middleware_Sanic middleware – 中间件
- 深度学习导论(5)手写数字识别问题步骤
- OpenCV图像处理(Python)学习笔记
- mybatis-generator 逆向生成工具(实体、dao、sql)
- 如何成为一名合格的自动驾驶工程师
- 谈晶体管的饱和状态和饱和压降
- C语言高级编程:数组名赋值给指针变量的用法解析