這篇文章主要介紹了Asp.Net(C#)自動執行計劃任務的程序實例分析,有需要的朋友可以參考一下
在業務復雜的應用程序中,有時候會要求一個或者多個任務在一定的時間或者一定的時間間隔內計劃進行,比如定時備份或同步數據庫,定時發送電子郵件等,我們稱之為計劃任務。實現計劃任務的方法也有很多,可以采用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應用程序中執行計劃任務的例子</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應用程序中執行計劃任務的簡單例子,對於多個任務來說,需要在不同的線程內進行工作,對計劃的安排也是很簡單的,實際還需要站點堵塞,當機的情況。另外這裡也沒有進行錯誤的處理等工作,相信大家會寫出更加完美的代碼的。 點擊下載源碼:http://xiazai.jb51.net/201401/yuanma/AutoRun(jb51.net).zip 資源回收,當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); } }