C# 定时执行任务 .

安哥网络

WEB程序启动时开始执行某一定时任务，应用池回收或程序关闭后再次启动定时任务，在原本基础上继续执行(利用序列化，保存其持久性)

定时任务对象序列化存入数据库，需要时再从数据库取出反序列化为一实例对象进行使用。

序列化，反序列化对象实例，byte[]之间的转换方法：

1. /// <summary>
   
2. /// 序列化一个类实例对象
   
3. /// </summary>
   
4. /// <param name="obj">类实例对象</param>
   
5. /// <returns>序列化后的byte数组</returns>
   
6. public static byte[] ClassSerializer(object obj)
   
7. {
   
8. //创建一内存流
   
9. MemoryStream stream = new MemoryStream();
   
10. 
    
11. //实例化二进制序列类
    
12. IFormatter bf = new BinaryFormatter();
    
13. //将给定类实例对象序列化到指定流
    
14. bf.Serialize(stream, obj);
    
15. 
    
16. //将流中内容读入到byte[]对象
    
17. byte[] info = new byte[stream.Length];
    
18. stream.Position = 0;
    
19. stream.Read(info, 0, (int)stream.Length);
    
20. 
    
21. //关闭流
    
22. stream.Close();
    
23. 
    
24. //返回序列化后的byte数组
    
25. return info;
    
26. }
    
27. 
    
28. /// <summary>
    
29. /// 反序列化流构建一个新对象
    
30. /// </summary>
    
31. /// <param name="info">序列化后的byte数组</param>
    
32. /// <returns></returns>
    
33. public static object ClassDeserialize(Byte[] info)
    
34. {
    
35. //创建一内存流用指定byte[]初始化
    
36. MemoryStream stream = new MemoryStream(info);
    
37. 
    
38. //实例化二进制序列类
    
39. IFormatter bf = new BinaryFormatter();
    
40. //反序列化流中数据，生成新的对象
    
41. Object obj = bf.Deserialize(stream);
    
42. 
    
43. //关闭流
    
44. stream.Close();
    
45. 
    
46. //返回反序列化后生成的对象
    
47. return obj;
    
48. }
    

复制代码

基础定时任务操作类：

1. namespace _66_TimerTask
   
2. {
   
3. //此类可序列化
   
4. [Serializable]
   
5. public class TimerInfo
   
6. {
   
7. //定义委托类
   
8. public delegate void TimerTaskDelegate();
   
9. 
   
10. //当前执行程序名称
    
11. public string name = "";
    
12. //几秒后再执行任务
    
13. public int second;
    
14. //定义委托实例
    
15. private TimerTaskDelegate fun;
    
16. 
    
17. //定义一个线程
    
18. //线程是不可序列化
    
19. [NonSerialized]
    
20. private Thread t;
    
21. 
    
22. /// <summary>
    
23. /// 构造函数
    
24. /// </summary>
    
25. /// <param name="name">线程名称</param>
    
26. /// <param name="second">几秒后再执行任务</param>
    
27. /// <param name="fun">要执行的任务</param>
    
28. public TimerInfo(string name, int second, TimerTaskDelegate fun)
    
29. {
    
30. this.name = name;
    
31. this.second = second;
    
32. this.fun = fun;
    
33. }
    
34. 
    
35. 
    
36. /// <summary>
    
37. /// 启动定时任务
    
38. /// </summary>
    
39. public void Star()
    
40. {
    
41. t = new Thread(NewThreadStar);
    
42. t.Name = this.name;
    
43. 
    
44. t.Start();
    
45. }
    
46. 
    
47. /// <summary>
    
48. /// 线程调用的方法
    
49. /// </summary>
    
50. private void NewThreadStar()
    
51. {
    
52. //要执行的目标方法
    
53. fun();
    
54. 
    
55. //当前线程挂起指定时间
    
56. Thread.Sleep(second*1000);
    
57. 
    
58. //递归调用实现循环
    
59. NewThreadStar();
    
60. }
    
61. 
    
62. /// <summary>
    
63. /// 终止定时任务
    
64. /// </summary>
    
65. public void Abort()
    
66. {
    
67. if (t != null)
    
68. {
    
69. t.Abort();
    
70. }
    
71. }
    
72. }
    
73. 
    
74. }

复制代码

定时任务调用的方法：

1. namespace _66_TimerTask.DelegateFunction
   
2. {
   
3. [Serializable]
   
4. public class DelegateFun
   
5. {
   
6. /// <summary>
   
7. /// 测试用方法
   
8. /// </summary>
   
9. public static void Test1()
   
10. {
    
11. SqlConnection con = new SqlConnection("Data Source=.;Initial Catalog=GlobeChineseClubV1.1;UID=sa;PWD=");
    
12. con.Open();
    
13. 
    
14. SqlCommand cmd = new SqlCommand("insert into TimerTest (time) values ('" + DateTime.Now + "')", con);
    
15. cmd.ExecuteNonQuery();
    
16. 
    
17. con.Close();
    
18. }
    
19. 
    
20. public static void Test2()
    
21. {
    
22. SqlConnection con = new SqlConnection("Data Source=.;Initial Catalog=GlobeChineseClubV1.1;UID=sa;PWD=");
    
23. con.Open();
    
24. 
    
25. SqlCommand cmd = new SqlCommand("insert into TimerTest2 (time) values ('" + DateTime.Now + "')", con);
    
26. cmd.ExecuteNonQuery();
    
27. 
    
28. con.Close();
    
29. }
    
30. }
    
31. }

复制代码

测试(Global.asax)：

1. TimerInfo t1;
   
2. 
   
3. void Application_Start(object sender, EventArgs e)
   
4. {
   
5. //在应用程序启动时运行的代码
   
6. CreateTimer();
   
7. }
   
8. 
   
9. //创建定时任务
   
10. private void CreateTimer()
    
11. {
    
12. #region 检查数据库中是否存储有序列化后的相关类实例对象
    
13. //如存在，查询数据库指定字段，反序列化为指定实例对象：t1 = (TimerInfo)SerializationHelper.ClassDeserialize((byte[])sdr["info"]);
    
14. //不存在，创建新的TimerInfo实例对象：t1 = new _66_TimerTask.TimerInfo(unCreateTimersName [i], 10, _66_TimerTask.DelegateFunction.DelegateFun.Test1);
    
15. #endregion
    
16. 
    
17. //启动定时任务
    
18. t1.Star();
    
19. }
    
20. 
    
21. void Application_End(object sender, EventArgs e)
    
22. {
    
23. //在应用程序关闭时运行的代码
    
24. //序列化指定实例对象，返回其BYTE[]
    
25. byte[] info1 = SerializationHelper.ClassSerializer(t1);
    
26. SqlConnection con = new SqlConnection(connectionStr);
    
27. con.Open();
    
28. 
    
29. //序列化对象后的BYTE[]写入数据库info字段(image类型)
    
30. SqlCommand cmd = new SqlCommand("delete TimerInfoTest;insert into TimerInfoTest (className,info) values ('" + t1.name + "', @info)", con);
    
31. cmd.Parameters.Add("@info", System.Data.SqlDbType.Binary);
    
32. cmd.Parameters["@info"].Value = info1;
    
33. 
    
34. cmd.ExecuteNonQuery();
    
35. 
    
36. con.Close();
    
37. }

复制代码