ASP.NET Core+Quartz.Net实现web定时任务

点击蓝色“Dotnet Plus”关注我哟

加个“星标”,每天清晨 07:25,干货推送!

作为一枚后端程序狗,项目实践常遇到定时任务的工作,最容易想到的的思路就是利用Windows计划任务/wndows service程序/Crontab程序等主机方法在主机上部署定时任务程序/脚本。

但是很多时候,使用的是共享主机或者受控主机,这些主机不允许你私自安装exe程序、Windows服务程序。

web程序中做定时任务,目前有两个方向:

① ASP.NET Core自带的HostService, 这是一个轻量级的后台服务,需要搭配timer完成定时任务
②老牌Quartz.Net组件,支持复杂灵活的Scheduling、支持ADO/RAM Job任务存储、支持集群、支持监听、支持插件。

此处我们的项目使用稍复杂的Quartz.net实现web定时任务。

项目背景

最近需要做一个计数程序:采用redis计数,设定每小时将当日累积数据持久化到关系型数据库sqlite。

添加Quartz.Net Nuget依赖包
<PackageReference Include="Quartz" Version="3.0.6" />

① 定义定时任务内容:Job
② 设置触发条件:Trigger
③ 将Quartz.Net集成进ASP.NET Core

头脑风暴

IScheduler类包装了上述背景需要完成的第①②点工作,
SimpleJobFactory工厂类定义了生成Job任务的过程:利用反射机制调用无参构造函数形成的Job实例

//----------------选自Quartz.Simpl.SimpleJobFactory类-------------
using System;
using Quartz.Logging;
using Quartz.Spi;
using Quartz.Util;
namespace Quartz.Simpl
{/// <summary>/// The default JobFactory used by Quartz - simply calls/// <see cref="ObjectUtils.InstantiateType{T}" /> on the job class./// </summary>public class SimpleJobFactory : IJobFactory{private static readonly ILog log = LogProvider.GetLogger(typeof (SimpleJobFactory));/// <summary>/// Called by the scheduler at the time of the trigger firing, in order to/// produce a <see cref="IJob" /> instance on which to call Execute./// </summary>public virtual IJob NewJob(TriggerFiredBundle bundle, IScheduler scheduler){IJobDetail jobDetail = bundle.JobDetail;Type jobType = jobDetail.JobType;try{if (log.IsDebugEnabled()){log.Debug($"Producing instance of Job '{jobDetail.Key}', class={jobType.FullName}");}return ObjectUtils.InstantiateType<IJob>(jobType);}catch (Exception e){SchedulerException se = new SchedulerException($"Problem instantiating class '{jobDetail.JobType.FullName}'", e);throw se;}}/// <summary>/// Allows the job factory to destroy/cleanup the job if needed./// No-op when using SimpleJobFactory./// </summary>public virtual void ReturnJob(IJob job){var disposable = job as IDisposable;disposable?.Dispose();}}
}//------------------节选自Quartz.Util.ObjectUtils类-------------------------public static T InstantiateType<T>(Type type)
{if (type == null){throw new ArgumentNullException(nameof(type), "Cannot instantiate null");}ConstructorInfo ci = type.GetConstructor(Type.EmptyTypes);if (ci == null){throw new ArgumentException("Cannot instantiate type which has no empty constructor", type.Name);}return (T) ci.Invoke(new object[0]);
}

很多时候,定义的Job任务依赖了其他服务(该Job定义有参构造函数),此时默认的SimpleJobFactory不能满足实例化要求,考虑自定义Job工厂类

关键思路:
① Quartz.Net提供IJobFactory接口,以便开发者定义灵活的Job工厂类

JobFactories may be of use to those wishing to have their application produce IJob instances via some special mechanism, such as to give the opportunity for dependency injection

② ASP.NET Core是以依赖注入为基础的,利用ASP.NET Core内置依赖注入容器IServiceProvider管理Job的实例化依赖

编码实践

已经定义好Job类:UsageCounterSyncJob

  1. 自定义Job工厂类:IOCJobFactory

   /// <summary>/// IOCJobFactory :在Timer触发的时候产生对应Job实例/// </summary>public class IOCJobFactory : IJobFactory{protected readonly IServiceProvider Container;public IOCJobFactory(IServiceProvider container){Container = container;}//Called by the scheduler at the time of the trigger firing, in order to produce//     a Quartz.IJob instance on which to call Execute.public IJob NewJob(TriggerFiredBundle bundle, IScheduler scheduler){return Container.GetService(bundle.JobDetail.JobType) as IJob;}// Allows the job factory to destroy/cleanup the job if needed.public void ReturnJob(IJob job){}}
  1. 在Quartz启动过程中应用自定义Job工厂

   public class QuartzStartup{public IScheduler _scheduler { get; set; }private readonly ILogger _logger;private readonly IJobFactory iocJobfactory;public QuartzStartup(IServiceProvider IocContainer, ILoggerFactory loggerFactory){_logger = loggerFactory.CreateLogger<QuartzStartup>();iocJobfactory = new IOCJobFactory(IocContainer);var schedulerFactory = new StdSchedulerFactory();_scheduler = schedulerFactory.GetScheduler().Result;_scheduler.JobFactory = iocJobfactory;}// Quartz.Net启动后注册job和triggerpublic void Start(){_logger.LogInformation("Schedule job load as application start.");_scheduler.Start().Wait();var UsageCounterSyncJob = JobBuilder.Create<UsageCounterSyncJob>().WithIdentity("UsageCounterSyncJob").Build();var UsageCounterSyncJobTrigger = TriggerBuilder.Create().WithIdentity("UsageCounterSyncCron").StartNow().WithCronSchedule("0 0 * * * ?")      // Seconds,Minutes,Hours,Day-of-Month,Month,Day-of-Week,Year(optional field).Build();_scheduler.ScheduleJob(UsageCounterSyncJob, UsageCounterSyncJobTrigger).Wait();_scheduler.TriggerJob(new JobKey("UsageCounterSyncJob"));}public void Stop(){if (_scheduler == null){return;}if (_scheduler.Shutdown(waitForJobsToComplete: true).Wait(30000))_scheduler = null;else{}_logger.LogCritical("Schedule job upload as application stopped");}}
  1. 结合ASP.NET Core依赖注入;web启动时绑定Quartz.Net

//-------------------------------截取自Startup文件------------------------
......
services.AddTransient<UsageCounterSyncJob>();      // 这里使用瞬时依赖注入
services.AddSingleton<QuartzStartup>();
......// 绑定Quartz.Net
public void Configure(IApplicationBuilder app, Microsoft.AspNetCore.Hosting.IApplicationLifetime lifetime, ILoggerFactory loggerFactory)
{var quartz = app.ApplicationServices.GetRequiredService<QuartzStartup>();lifetime.ApplicationStarted.Register(quartz.Start);lifetime.ApplicationStopped.Register(quartz.Stop);
}

以上: 我们对接ASP.NET Core依赖注入框架实现了一个自定义的JobFactory,每次任务触发时创建瞬时Job.

Github地址:https://github.com/zaozaoniao/ASPNETCore-Quartz.NET.git

附:IIS网站低频访问导致工作进程进入闲置状态的解决办法

IIS为网站默认设定了20min闲置超时时间:20分钟内没有处理请求、也没有收到新的请求,工作进程就进入闲置状态。

IIS上低频web访问会造成工作进程关闭,此时应用程序池回收,Timer等线程资源会被销毁;
当工作进程重新运作,Timer可能会重新生成, 但我们的设定的定时Job可能没有按需正确执行。

故为IIS站点实现低频web访问下的定时任务:可设置IdleTimeOut =0;将[应用程序池]->[正在回收]->不勾选[回收条件]

原创干货···推荐阅读

● 这么香的Chrome插件,你都安装了吗?

●  一文掌握Cookies前世今生

● ASP.NET Core跨平台技术内幕

● [ASP.NETCore3.1]使用浏览器嗅探解决部分浏览器丢失Cookie问题

● Abp vnext构建API接口服务

● 没用过.gitignore还敢自称高级开发?

戳原文,更有料!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/310587.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Redis基础数据结构内部实现简单介绍

5种基础数据结构 Redis有5种基础数据结构&#xff0c;分别是&#xff1a;String&#xff08;字符串&#xff09;&#xff0c;list&#xff08;列表&#xff09;&#xff0c;hash&#xff08;字典&#xff09;&#xff0c;set&#xff08;集合&#xff09;&#xff0c;zset&…

[剑指offer]面试题7:用两个栈实现队列

面试题7&#xff1a;用两个栈实现队列 题目&#xff1a;用两个栈实现一个队列。队列的声明如下&#xff0c;请实现它的两个函数appendTail和deleteHead&#xff0c;分别完成在队列尾部插入结点和在队列头部删除结点的功能。 用两个栈模拟一个队列的操作: 代码如下: #include …

ASP.NET CORE WEBAPI文件下载

最近要使用ASP.NET CORE WEBAPI用来下载文件&#xff0c;使用的.NET CORE 3.1。考虑如下场景&#xff1a;文件是程序生成的。文件应该能兼容各种格式。浏览器可以感知进行下载。准备经过简单的调研&#xff0c;得到以下结论。ASP.NET CORE 提供FileResult这种类型的ActionResul…

Redis高级数据结构原理解析-bitmap,hyperloglog

Redis 位图 开发过程中&#xff0c;我们可能遇到这种场景记录用户的打卡情况&#xff0c;签到情况&#xff0c;这些场景只有两种结果&#xff0c;有或者没有&#xff0c;加入记录的数据量比较大&#xff0c;比如用一年的数据&#xff0c;如果用Redis中普通key/value&#xff0…

[剑指offer]面试题8:旋转数组的最小数字

面试题8&#xff1a;旋转数组的最小数字 题目&#xff1a;把一个数组最开始的若干个元素搬到数组的末尾&#xff0c;我们称之为数组的旋转。输入一个递增排序的数组的一个旋转&#xff0c;输出旋转数组的最小元素。例如数组{3,4,5,1,2}为{1,2,3,4,5}的一个旋转&#xff0c;该数…

.NET Core + Kubernetes:快速体验

Kubernetes[1] 是目前非常主流的容器编排工具&#xff0c;在应用创建、应用部署、应用扩容、应用更新等方面都非常的方便&#xff0c;而且在应用故障时&#xff0c;也可以快速自愈。所以基于微服务架构下的产品&#xff0c;了解 Kubernetes 的使用是非常必要的&#xff0c;我猜…

Redis流量控制策略

Reids 简单流控 流控是分布式领域一个被经常用到的一个计数&#xff0c;当系统承载能力有限的时候&#xff0c;如何组织计划外的请求继续对系统施加压力&#xff0c;这是一个需要解决的问题&#xff0c;在系统承载达到峰值的时候&#xff0c;我们需要弃车保帅&#xff0c;保证…

[剑指offer]面试题9:斐波那契数列

面试题9&#xff1a;斐波那契数列 题目一&#xff1a;写一个函数&#xff0c;输入n&#xff0c;求斐波那契&#xff08;Fibonacci&#xff09;数列的第n项。斐波那契数列的定义如下&#xff1a; ❖ 效率很低的解法&#xff0c;挑剔的面试官不会喜欢 代码如下: long long fib(…

海底捞涨价,有错吗?

此前&#xff0c;有媒体报道&#xff0c;海底捞某些门店的菜品除了少部分维持原价&#xff0c;大部分都涨价了。随后&#xff0c;广大网民纷纷对此发表了看法。有人表示理解&#xff0c;理由是餐饮业在疫情期间损失巨大&#xff0c;此前也有一些餐饮业老板表达了资金链断裂的担…

Redis分布式锁奥义

分布式锁 分布式系统进行逻辑处理的时候&#xff0c;经常会遇到并发问题&#xff0c;例如直播场景中&#xff0c;用户需要连麦主播&#xff0c;当多个用户在同一个时刻一起连麦时候&#xff0c;应该保证只有一个用户能连麦成功&#xff0c;我们改怎么保证这种业务场景下保证数…

.NET Core + Kubernetes:Pod

在 .NET Core Kubernetes&#xff1a;快速体验 文章中&#xff0c;已经实现将一个 .NET Core API 服务部署在 Kubernetes 集群中&#xff0c;接下来将逐步了解 Kubernetes 中各核心模块。首先当然是 Pod&#xff0c;我相信 Pod 是在接触 Kubernetes 时听到较多的一个词语&…

[剑指offer]面试题10:二进制中1的个数

面试题10&#xff1a;二进制中1的个数 题目&#xff1a;请实现一个函数&#xff0c;输入一个整数&#xff0c;输出该数二进制表示中 1 的个数。例如把9表示成二进制是1001&#xff0c;有2位是1。因此如果输入9&#xff0c;该函数输出2。 ❖ 可能引起死循环的解法 代码如下: …

LBS解决方案

LBS解决方案 LBS&#xff08;基于地理位置的服务&#xff09;服务是现在移动互联网中比较常用的功能&#xff0c;例如外卖中我附近的店铺&#xff0c;通常是以客户位置坐标为中心&#xff0c;查询一定范围内的店铺信息&#xff0c;按照距离由近及原进行倒叙排序 方案一&#…

[剑指offer]面试题13:在O(1)时间删除链表结点

面试题13&#xff1a;在O&#xff08;1&#xff09;时间删除链表结点 题目&#xff1a;给定单向链表的头指针和一个结点指针&#xff0c;定义一个函数在 O&#xff08;1&#xff09;时间删除该结点。链表结点与函数的定义如下&#xff1a; struct ListNode {int value;ListNod…

长沙IT技术圈百万年薪大佬?是否存在?

作者&#xff1a;邹溪源&#xff0c;长沙资深互联网从业者&#xff0c;架构师社区特邀嘉宾&#xff01;01引子不知不觉&#xff0c;IT技术圈开始流传起“百万年薪”的故事&#xff0c;有人问我&#xff0c;长沙有百万大佬么&#xff1f;其实我也不知道。02背景长沙自古以来就是…

网络编程-网络分层的意义

网络 我们生活在一个网络无处不在的一个虚拟世界中&#xff0c;网络中的每一个设备都是一个节点。大多是我们的计算机&#xff0c;但是他还可以连接其他设备&#xff0c;例如打印机&#xff0c;路由器&#xff0c;网关&#xff0c;你的手机&#xff0c;智能家居等。我们可以使…

网络编程-TCP/IP协议栈-IP协议

协议 协议就是约定的一种规则&#xff0c;例如扑克游戏中约定好的各种规则&#xff0c;2<3<4<5<…等&#xff0c;以此作为游戏规则。当所有人都遵循这个规则&#xff0c;那么久可以不需要任何多余的交流就可以进行游戏&#xff0c;这个方式形成的约定就是一种协议…

.NET项目升级手记:可为空引用

c# 8引入了新特性&#xff1a;“可为空引用”&#xff08;详情&#xff09;&#xff0c;这个功能个人觉得挺好的&#xff0c;能够非常明确的表现程序设计者的意图&#xff0c;编译器能够进行检查&#xff0c;尽最大可能减小NullReferenceException错误。如果是新项目&#xff0…

[剑指offer]面试题15:链表中倒数第k个结点

面试题15&#xff1a;链表中倒数第k个结点 题目&#xff1a;输入一个链表&#xff0c;输出该链表中倒数第 k 个结点。为了符合大多数人的习惯&#xff0c;本题从1 开始计数&#xff0c;即链表的尾结点是倒数第1 个结点。例如一个链表有6个结点&#xff0c;从头结点开始它们的值…

.NET与鲲鹏共展翅,昇腾九万里(一)

2019年1月7日&#xff0c;华为推出鲲鹏920处理器&#xff0c;便宣告了构建鲲鹏生态系统的开始。据官方介绍&#xff0c;鲲鹏是一个包含了鲲鹏计算单元、AI处理单元、智能管理、智能网卡的片上系统SoC&#xff0c;在此之上加上服务器操作系统&#xff0c;从而形成一个生态的闭环…