asp.net自动执行计划任务代码实例

发布时间:2020-11-08编辑:脚本学堂
asp.net自动执行计划任务实现代码详解,在application_start和application_end事件中建立和销毁一个计划任务,在web站点实现计划任务的方法。

如何让一个或者多个任务在一定的时间或者一定的时间间隔内计划进行,比如定时备份或同步数据库,定时发送电子邮件等,我们称之为计划任务。

实现计划任务的方法也有很多,可以采用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:InetpubwwwrootCSTest为物理路径
string p = @"F:InetpubwwwrootCSTest";
//在虚拟目录的根目录下建立SchedulerJob文件夹,并设置权限为匿名可修改,
//SchedulerJob.txt就是我们所写的文件
string FILE_NAME = p+ "SchedulerJobSchedulerJob.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("rn"+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应用程序中执行计划任务_www.jb200.com</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应用程序中执行计划任务的简单例子,对于多个任务来说,需要在不同的线程内进行工作,对计划的安排也是很简单的,实际还需要站点堵塞,当机的情况。另外这里也没有进行错误的处理等工作,相信大家会写出更加完美的代码的。
 
资源回收,当web没有人访问的时候,定时器会回收停掉
不知道在 Application_End 时自动访问一次有用么,我这前测试了几天这个方法都可以行。
 

复制代码 代码示例:
void Application_End(object sender, EventArgs e)
{
///在应用程序关闭时运行的代码
webSocket.Stop();
Thread.Sleep(15000);
try
{
string url = "http://127.0.0.1/404.aspx?mater=" + DateTime.Now.Ticks;
HttpWebRequest httpWebRequest = (HttpWebRequest)HttpWebRequest.Create(url);
using (HttpWebResponse response = (HttpWebResponse)httpWebRequest.GetResponse())
{
Stream resStream = response.GetResponseStream();
}
}
catch (Exception ex)
{
//异常时,等15s,再访问一次。
Thread.Sleep(15000);
string url = "http://127.0.0.1/404.aspx?mater=" + DateTime.Now.Ticks;
HttpWebRequest httpWebRequest = (HttpWebRequest)HttpWebRequest.Create(url);
using (HttpWebResponse response = (HttpWebResponse)httpWebRequest.GetResponse())
{
Stream resStream = response.GetResponseStream();
}
 
Hangjing.AppLog.AppLog.Error("Application_End:" + ex);
}
}