分享web开发知识

注册/登录|最近发布|今日推荐

主页 IT知识网页技术软件开发前端开发代码编程运营维护技术分享教程案例
当前位置:首页 > 运营维护

.NET 任务调度Quartz系列(1)——自建定时任务

发布时间:2023-09-06 02:08责任编辑:顾先生关键词:.NET

在我们平时项目中经常会遇到定时任务,比如定时同步数据,定时备份数据,定时统计数据等,定时任务我们都知道使用Quartz.net,此系列写的也是Quartz,但是在此之前,我们先用其他方式做个简单的定时任务进行入门。

首先呢,我们现在自己先写一个简单的定时循环任务,话不多说,直接上代码:

第一步:创建项目,新建一个类库:我们命名为TaskBase

第二部:添加一个抽象基础类BaseMonitor:

using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;namespace TaskBase{ ???/// <summary> ???/// 监测基础抽象类 ???/// </summary> ???public abstract class BaseMonitor ???{ ???????????????protected System.Threading.Thread _thread; ???????/// <summary> ???????/// 监控时间间隔(毫秒) ???????/// </summary> ???????public virtual int Interval { get; set; } ???????public virtual string Name { get; set; } ???????/// <summary> ???????/// 监控器状态 ???????/// </summary> ???????public virtual TaskState State { get; set; } ???????public BaseMonitor(string name) ???????{ ???????????Name = name; ???????????_thread = new System.Threading.Thread(BaseRun); ???????????_thread.IsBackground = true;//获取或设置一个值,该值指示某个线程是否为后台线程 ???????????_thread.Start(); ???????????State = TaskState.运行; ???????} ???????private void BaseRun() ???????{ ?????????????????????while (State==TaskState.运行) ???????????{ ???????????????try ???????????????{ ???????????????????Run(); ???????????????????System.Threading.Thread.Sleep(Interval); ???????????????} ???????????????catch (Exception ex) ???????????????{ ???????????????????State = TaskState.异常; ???????????????????PCore.Log.LogTextHelper.WriteErrorLog(this.GetType().Name + "监控出现错误,此监视器已暂停!", ex); ???????????????} ???????????} ???????} ???????protected virtual void Run() ???????{ } ???}}

(代码中PCore.Log.LogTextHelper.WriteErrorLog 是一个写文本日志的方法,可自行写个此方法。)

 注:此定时任务基础类 是用 System.Threading.Thread 实现,其中 TaskState为一个枚举来表示任务的状态:

using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;namespace TaskBase{ ??public enum TaskState ???{ ???????未开始=0, ???????运行=1, ???????暂停=2, ???????异常=3 ???}}

第三部:添加一个继承BaseMonitor的TestMontior类,代码如下:

using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;namespace TaskBase{ ??public class TestMontior:BaseMonitor ???{ ???????/// <summary> ???????/// 构造函数 ???????/// </summary> ???????/// <param name="name">检测器名称</param> ???????public TestMontior(string name) : base(name) ???????{ ???????} ???????/// <summary> ???????/// 监控时间间隔(毫秒) ???????/// </summary> ???????public override int Interval ???????{ ???????????get ???????????{ ?????????????return ?GlobalConfig.TestMonitorInterval; ???????????} ?????????????????} ???????public override string Name ???????{ ???????????get ???????????{ ???????????????return base.Name; ???????????} ???????????set ???????????{ ???????????????base.Name = value; ???????????} ???????} ???????public override TaskState State ???????{ ???????????get ???????????{ ???????????????return base.State; ???????????} ???????????set ???????????{ ???????????????base.State = value; ???????????} ???????} ???????protected override void Run() ???????{ ?????????????????????PCore.Log.LogTextHelper.WriteLog("TestMontitor监测器正在监测"); ???????} ???}}

注:TestMontior 相当于我们的Job,代码中 GlobalConfig是我定义的一个全局参数类:

using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;namespace TaskBase{ ??public static class GlobalConfig ???{ ???????public static int TestMonitorInterval ???????{ ???????????get { return 100 * 10; } ???????} ???????public static List<BaseMonitor> Monitor = new List<BaseMonitor>(); ???}}

创建完成之后就是这个样子:

定时任务的基础类库已经创建完毕,下面我们来看怎么使用它。

 第四部:在WEB中使用:创建一个WEB  MVC项目,引用TaskBase,然后在Global.asax中添加以下代码:

using System;using System.Collections.Generic;using System.Linq;using System.Web;using System.Web.Mvc;using System.Web.Optimization;using System.Web.Routing;namespace WebTaskTest{ ???public class MvcApplication : System.Web.HttpApplication ???{ ???????protected void Application_Start() ???????{ ???????????AreaRegistration.RegisterAllAreas(); ???????????FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters); ???????????RouteConfig.RegisterRoutes(RouteTable.Routes); ???????????BundleConfig.RegisterBundles(BundleTable.Bundles); ??????????TaskBase.GlobalConfig.Monitor.Add(new TaskBase.TestMontior("测试监控器Test"));//注册定时任务 ???????} ???}}

运行WEB站点,查看日志如下:

可以看到一秒钟执行一次 ,因为我们在GlobalConfig.TestMonitorInterval设置的就是一秒钟。

下面我们看如何在windows server中如何使用:

创建一个WindowsServerTest类库,引用TaskBse,添加一个windows服务:

using Quartz;using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Diagnostics;using System.Linq;using System.ServiceProcess;using System.Text;using System.Threading.Tasks;namespace WindowsServerTest{ ???partial class TestService : ServiceBase ???{ ???????public TestService() ???????{ ???????????InitializeComponent(); ???????} ???????protected override void OnStart(string[] args) ???????{ ???????????try ???????????{ ???????????????// TODO: 在此处添加代码以启动服务。 ???????????????PCore.Log.LogTextHelper.WriteLog("OnStart:Test服务开始..."); ??????????????TaskBase.GlobalConfig.Monitor.Add(new TaskBase.TestMontior("测试监控器Test"));//注册监视器 ??????????????????????????????????????????} ???????????catch (Exception ex) ???????????{ ???????????????PCore.Log.LogTextHelper.WriteErrorLog("出错了",ex); ???????????} ???????} ???????protected override void OnStop() ???????{ ?????????????????????// TODO: 在此处添加代码以执行停止服务所需的关闭操作。 ???????????PCore.Log.LogTextHelper.WriteLog("OnStop:Test服务结束..."); ???????} ???????protected override void OnPause() ???????{ ???????????PCore.Log.LogTextHelper.WriteLog("OnPause:Test服务暂停..."); ???????} ???????protected override void OnContinue() ???????{ ???????????PCore.Log.LogTextHelper.WriteLog("OnContinue:Test服务继续..."); ???????} ???}}

关于windows服务的安装卸载可自行百度,再此不多哔哔了。

安装好服务开始后,我们查看下日志如下:

此节中我们简单做了一个定时任务,下章我们将进行Quartz.net任务框架的介绍。(源代码会跟随后面的例子一并上传),请继续关注以后章节。

.NET 任务调度Quartz系列(1)——自建定时任务

原文地址:https://www.cnblogs.com/zyh000/p/9413220.html

知识推荐

我的编程学习网——分享web前端后端开发技术知识。 垃圾信息处理邮箱 tousu563@163.com 网站地图
icp备案号 闽ICP备2023006418号-8 不良信息举报平台 互联网安全管理备案 Copyright 2023 www.wodecom.cn All Rights Reserved