Asp.Net在Web應用程序中執行計劃任務(多線程)

2024-07-10 13:05:46

字體：大中小

來源：轉載

供稿：網友

在業務復雜的應用程序中，有時候會要求一個或者多個任務在一定的時間或者一定的時間間隔內計劃進行，比如定時備份或同步數據庫，定時發送電子郵件等，我們稱之為計劃任務。實現計劃任務的方法也有很多，可以采用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+ "http://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，定時刷新來檢查我們所記錄的數據
    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 src="schedulerjob/schedulerjob.txt">iframe>
        form>
      body>
    html>