工作中, 我们常常需要开发windows服务, 那么, 一个可维护性好, 可扩展性高的的windows程序可以使我们省去不少的时间和精力.
我们来分析一下
一个windows服务应该看成是一个对象, 它拥有以下基本行为
行为: 执行行为.(这个服务要做什么事)
同一种行为, 不同的实现逻辑, 典型的工厂模式.
下面, 我们来定义两个windows服务类
public class OneTask : IWindowTask{public void Run(params object[] parms){Console.WriteLine("我是第一个window模拟服务.第一第一");}}public class TwoTask:IWindowTask{public void Run(params object[] parms) {Console.WriteLine("我是第二个window模拟服务.第二第二");}}
以及约束其行为的接口
public interface IWindowTask
{void Run(params object[] parms);
}
数据表
添加两条记录
工厂
public class TaskFactory{static Hashtable ht = Hashtable.Synchronized(new Hashtable());public static IWindowTask GetTask(string classPath, IList parms) {if (ht[classPath] != null)return (IWindowTask)ht[classPath];else {//var taskInstance = Activator.CreateInstance(Type.GetType(classPath));//var taskInstance = System.Reflection.Assembly.Load("MyWindowServiceFramwork").CreateInstance(classPath);object taskInstance=null;taskInstance = Type.GetType(classPath).GetConstructor(Type.EmptyTypes).Invoke(null);ht[classPath] = taskInstance;return (IWindowTask)taskInstance;}}public static IWindowTask GetTask(string classPath) {return GetTask(classPath, null);}}枚举
public enum InterValType {second=1,minute=2,hour=3,day=4,week=5,month=6}
//给定时控件添加一个任务类ID的属性, 在下面要用到class MyTime : System.Timers.Timer {public int TaskID { get; set; }}private static void NewMethod1(){MyPractiseEntities enty = new MyPractiseEntities();//获得所有的有效任务.var tasks = enty.MyTask.Where(x => x.enable == true);foreach (var item in tasks){MyTime mytime = new MyTime();mytime.TaskID = item.ID;//将任务ID付给当前的定时类IDmytime.Start(); //开始, 默认间隔是100毫秒//达到时间间隔执行. 可以理解为每一个定时控件都是一个新的线程.mytime.Elapsed += delegate(object sender, System.Timers.ElapsedEventArgs e){//记录逻辑操作耗时多少, 用以计算下一次运行此方法的时间间隔.System.Diagnostics.Stopwatch stop = new System.Diagnostics.Stopwatch();stop.Start();MyPractiseEntities enty2 = new MyPractiseEntities();var currentTimer = sender as MyTime;//必须通过当前的时间控件重新获得数据库对象. 如果直接写item(见上一级的foreach), 那么得到的item始终是tasks集合的最后一个.var currentitem = enty2.MyTask.Where(x => x.ID == currentTimer.TaskID).FirstOrDefault();//如果当前任务满足执行条件if (currentitem.LastRunTime <= DateTime.Now && (currentitem.NextRunTime == null || currentitem.NextRunTime <= DateTime.Now)){currentTimer.Stop();//暂停当前任务//填充当前任务的所有参数var itemParameter = enty2.MyTaskParameter.Where(x => x.TaskID == currentitem.ID).ToList();Func<IList<MyTaskParameter>, object[]> toObjects=x=>{object[] objs =new object[ x.Count];for (int i = 0; i < x.Count; i++){objs[i] = x[i].ParmValue;}return objs;};//获得并执行//使用工厂反射出需要执行的任务类,并转化为接口对象/IWindowTask itask = TaskFactory.GetTask(currentitem.ClassPath);//执行itask.Run(toObjects(itemParameter));System.Threading.Thread.Sleep(2000);//更新下一次执行的时间Func<int, InterValType, double> plusSecond = (intervalue, intervalueType) =>{var temp = 0;switch ((int)intervalueType){case 1: temp = currentitem.Interval.Value; break;case 2: temp = currentitem.Interval.Value * 60; break;case 3: temp = currentitem.Interval.Value * 60 * 60; break;case 4: temp = currentitem.Interval.Value * 60 * 60 * 24; break;}return temp;};//读取配置文件来获得时间间隔var tempsecond = plusSecond(currentitem.Interval.Value, (InterValType)currentitem.IntervalType.Value);DateTime d1 = currentitem.NextRunTime.Value;currentitem.NextRunTime = d1.AddSeconds(tempsecond);currentitem.LastRunTime = DateTime.Now;enty2.SaveChanges();//更新任务的状态信息stop.Stop();//监视停止//时间控件下一次执行的时间间隔为配置间隔减去这次运行时长.currentTimer.Interval = tempsecond * 1000 - stop.ElapsedMilliseconds;//开始时间控件currentTimer.Start();Console.WriteLine(); Console.WriteLine();}};}}
程序下载: 见群共享搜索MyWIndowService