task Scheduler

在业务复杂的应用程序中,有时候会要求一个或者多个任务在一定的时间或者一定的时间间隔内计划进行,比如定时备份或同步数据库,定时发送电子邮件等,我们称之为计划任务。实现计划任务的方法也有很多,可以采用SQLAgent执行存储过程来实现,也可以采用Windows任务调度程序来实现,也可以使用Windows服务来完成我们的计划任务,这些方法都是很好的解决方案。但是,对于Web应用程序来说,这些方法实现起来并不是很简单的,主机服务提供商或者不能直接提供这样的服务,或者需要你支付许多额外的费用。 本文就介绍一个直接在Web应用程序中使用的简单的方法,这个方法不需要任何额外的配置即可轻松实现。

由于ASP.NET站点是作为Web应用程序运行的,它并不受线程的限制,因此我们可以非常方便地在Application_Start和Application_End事件中建立和销毁一个计划任务。下面就简单介绍一下在Web站点实现计划任务的方法。我们的例子是定时往文件里添加信息,作为例子,这里把当前的时间定时地写入文件中。

一个计划任务的工作单元称之为一个任务(Job),下面的代码描述了对所有任务都可以被调度引擎计划执行的一个通用的接口,这里的每个任务实现了Execute方法,供调度引擎进行调用:

public interface ISchedulerJob

{

void Execute();

}

如前所述,我们的例子是实现往文件写如字符日期,下面就是实现这一任务的方法:

public class SampleJob : ISchedulerJob

{

public void Execute()

{

//文件保存的物理路径,CSTest为虚拟目录名称,F:\Inetpub\wwwroot\CSTest为物理路径

string p = @"F:\Inetpub\wwwroot\CSTest";

//我们在虚拟目录的根目录下建立SchedulerJob文件夹,并设置权限为匿名可修改,

//SchedulerJob.txt就是我们所写的文件

string FILE_NAME = p+ "\\SchedulerJob\\SchedulerJob.txt";

//取得当前服务器时间,并转换成字符串

string c = System.DateTime.Now.ToString("yyyy-mm-dd hh:MM:ss");

//标记是否是新建文件的标量

bool flag = false;

//如果文件不存在,就新建该文件

if (!File.Exists(FILE_NAME))

{

flag = true;

StreamWriter sr = File.CreateText(FILE_NAME);

sr.Close();

}

//向文件写入内容

StreamWriter x = new StreamWriter(FILE_NAME,true,System.Text.Encoding.Default);

if(flag) x.Write("计划任务测试开始:");

x.Write("\r\n"+c);

x.Close();

}

}

接下来,我们建立一个配置对象,告诉调度引擎执行什么任务和执行的时间间隔。

public class SchedulerConfiguration

{

//时间间隔

private int sleepInterval;

//任务列表

private ArrayList jobs = new ArrayList();

public int SleepInterval { get { return sleepInterval; } }

public ArrayList Jobs { get { return jobs; } }

//调度配置类的构造函数

public SchedulerConfiguration(int newSleepInterval)

{

sleepInterval = newSleepInterval;

}

}

下面就是调度引擎,定时执行配置对象的任务

public class Scheduler

{

private SchedulerConfiguration configuration = null;

public Scheduler(SchedulerConfiguration config)

{

configuration = config;

}

public void Start()

{

while(true)

{

//执行每一个任务

foreach(ISchedulerJob job in configuration.Jobs)

{

ThreadStart myThreadDelegate = new ThreadStart(job.Execute);

Thread myThread = new Thread(myThreadDelegate);

myThread.Start();

Thread.Sleep(configuration.SleepInterval);

}

}

}

}

所有的准备工作已经完成,下面就是激活引擎的工作了。为了让我们的任务计划执行,我们在Global.asax.cs文件里的Applicatio_Start和Application_End里进行建立和销毁工作,首先建立一个调度进程运行的线程,我们这里的运行间隔时间为3秒钟。

public System.Threading.Thread schedulerThread = null;

protected void Application_Start(Object sender, EventArgs e)

{

SchedulerConfiguration config = new SchedulerConfiguration(1000*3);

config.Jobs.Add(new SampleJob());

Scheduler scheduler = new Scheduler(config);

System.Threading.ThreadStart myThreadStart = new System.Threading.ThreadStart(scheduler.Start);

System.Threading.Thread schedulerThread = new System.Threading.Thread(myThreadStart);

schedulerThread.Start();

}

最后还需要在程序退出时进行销毁:

protected void Application_End(Object sender, EventArgs e)

{

if (null != schedulerThread)

{

schedulerThread.Abort();

}

}

好了,在VS.NET里建立一个C#的Web应用程序工程,建立TaskScheduler.cs类,并修改相应的Global.asax.cs文件。为了能看到效果,我们再建立一个表单WebForm1.aspx,定时刷新来检查我们所记录的数据:

<%@ Page language="c#" Codebehind="WebForm1.aspx.cs" AutoEventWireup="false"

Inherits="CSTest.WebForm1" %>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN" >

<HTML>

<HEAD>

<title>在Web应用程序中执行计划任务的例子</title>

<meta http-equiv="refresh" content="10">

<meta name="GENERATOR" Content="Microsoft Visual Studio 7.0">

<meta name="CODE_LANGUAGE" Content="C#">

<meta name="vs_defaultClientScript" content="JavaScript">

<meta name="vs_targetSchema" content="http://schemas.microsoft.com/intellisense/ie5">

</HEAD>

<body MS_POSITIONING="GridLayout">

<form id="Form1" method="post" runat="server">

<iframe style="width:100%;height:100%" src="SchedulerJob/SchedulerJob.txt"></iframe>

</form>

</body>

</HTML>

对工程进行编译并运行,就可以看到结果了,结果如下:

计划任务测试开始:

2003-13-10 11:08:15

2003-13-10 11:08:18

2003-13-10 11:08:21

2003-13-10 11:08:24

2003-13-10 11:08:27

2003-13-10 11:08:30

需要说明的是,以上只是在Web应用程序中执行计划任务的简单例子,对于多个任务来说,需要在不同的线程内进行工作,对计划的安排也是很简单的,实际还需要站点堵塞,当机的情况。另外这里也没有进行错误的处理等工作,相信大家会写出更加完美的代码的。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏魏琼东

一步一步教你使用AgileEAS.NET基础类库进行应用开发-基础篇-演示ORM的基本操作

系统回顾           前面的四篇文章我详细的介绍了AgileEAS.NET平台中统一数据访问(UDA)组件的用法,分析了两种数据处理流程的优缺点,以及基...

24050
来自专栏.NET技术

小技术之异步上传文件

  最近公司任务多,MVC 和 C#系列都没更新,不过折腾了下异步上传,其实挺简单的,不过以前没做过,打算记录下来方便以后用到,同时分享给需要的朋友,中间也遇到...

23920
来自专栏.NET技术

.net core实践系列之SSO-同域实现

SSO的系列还是以.Net Core作为实践例子与大家分享,SSO在Web方面复杂度分同域与跨域。本篇先分享同域的设计与实现,跨域将在下篇与大家分享。

48420
来自专栏ASP.NET MVC5 后台权限管理系统

ASP.NET MVC5+EF6+EasyUI 后台管理系统(90)-EF 扩展操作

这次我们来看 EntityFramework-Plus(免费开源) 库的用法相比其他扩展库,这个更加新并且用法更加简单

15000
来自专栏听雨堂

页面状态保持机制(编辑中)

Web应用程序中,有很多状态需要在页面的反复回调中能够保持住,还有一些状态需要在页面之间保持。对于状态的保持,是一个值得研究的问题。状态处理不当是页面失效或错误...

29450
来自专栏分布式系统和大数据处理

HttpModule介绍

Http 请求处理流程 和 Http Handler 介绍 这两篇文章里,我们首先了解了Http请求在服务器端的处理流程,随后我们知道Http请求最终会由实现了...

9030
来自专栏微服务

RabbitMQ入门HelloWorld(C#)(翻译)

介绍 先决条件 本教程假定RabbitMQ已安装并在标准端口(5672)上的本地主机上运行。如果您使用不同的主机,端口或凭据,连接设置将需要调整。 在哪里得到帮...

28690
来自专栏跟着阿笨一起玩NET

ASP.NET中Get和Post的用法

单form的提交有两种方式,一种是get的方法,一种是post 的方法.看下面代码,理解ASP.NET Get和Post两种提交的区别:

41620
来自专栏三杯水

Redis3.2.9/4.0.1集群部署配置优化

http://www.redis.cn/topics/cluster-spec.html

43420
来自专栏算法修养

后端处理高并发状态的多次重复请求

  相信做Web的,都有可能遇到有多次重复请求发送到后端的情况。而这些重复请求,可能大都是由于在网络较差的情况下,用户多次连续点击。最后导致后端面临处理大量重复...

57480

扫码关注云+社区

领取腾讯云代金券