再谈Windows Service - 一个简单的自我例子和部署

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using log4net;

namespace WinConsoleService
{
     public  abstract  class TaskWorker
    {
         private  static  readonly ILog logger = LogManager.GetLogger( typeof(TestTaskWorker));

         public  bool Pause {  get;  set; }

         public  bool Stop {  get;  set; }

         public  abstract  void Run();
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using WinConsoleService.DAL;
using System.Configuration;
using System.Diagnostics;
using log4net;

namespace WinConsoleService
{
     public  class DbTaskWorker: TaskWorker
    {
         // private static readonly ILog logger = LogManager.GetLogger(typeof(TestTaskWorker));

         public  bool Pause {  get;  set; }

         public  bool Stop {  get;  set; }

         public  override  void Run()
        {
             // logger.Info("Test Task Work Started ...");
            
             while (!Stop)
            {
                 if (Pause)
                     continue;
 
                Do();
                
                Thread.Sleep( int.Parse(ConfigurationManager.AppSettings[ " WakeupInterval "]));
            }
        }

         private  void Do()
        {
            
            SqlDbUtil db =  new SqlDbUtil();
             string sql =  @" insert into Test2
                            values('1', '2' , '3') ";
             int ret = db.ExecuteSQL(sql);

             if (ret == - 1)
                FileUtil.WriteLog( " Exception: database insert error! ");
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.IO;
using System.Diagnostics;
using System.Configuration;
using log4net;

namespace WinConsoleService
{
     public  class FileTaskWorker : TaskWorker
    {
         private  static  readonly ILog logger = LogManager.GetLogger( typeof(FileTaskWorker));

         public  override  void Run()
        {
             while (!Stop)
            {
                 if (Pause)
                     continue;

                Do();

                Thread.Sleep( int.Parse(ConfigurationManager.AppSettings[ " WakeupInterval "]));
            }
        }

         private  void Do()
        {
            FileStream fs =  new FileStream( " E:\\PerformanceLog_ " + DateTime.Now.ToString( " yyyyMMdd ") +  " .log ", FileMode.Append);
            StreamWriter streamWriter =  new StreamWriter(fs);
            streamWriter.BaseStream.Seek( 0, SeekOrigin.End);
            streamWriter.WriteLine(DateTime.Now);
            streamWriter.Flush();
            streamWriter.Close();
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;

namespace WinConsoleService
{
     public  class FileUtil
    {
         public  static  void WriteLog( string ex)
        {
             /*
            FileStream fs = new FileStream("C:\\test.log", FileMode.Append);
            StreamWriter streamWriter = new StreamWriter(fs);
            streamWriter.BaseStream.Seek(0, SeekOrigin.End);
            streamWriter.WriteLine(ex);
            streamWriter.Flush();
             */

            StreamWriter sw = File.AppendText( " C:\\test.log ");
            sw.WriteLine(ex);
            sw.Close();


        }
    }
}

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Linq;
using System.ServiceProcess;
using System.Text;
using System.IO;
using System.Threading;

using log4net;

namespace WinConsoleService
{
     public  partial  class Service1 : ServiceBase
    {
         private TaskWorker worker;
        ILog logger = LogManager.GetLogger( typeof(Service1));

         public Service1()
        {
            FileUtil.WriteLog( " Windows Service Start ");

            InitializeComponent();
             this.worker =  new FileTaskWorker();

            AppDomain.CurrentDomain.UnhandledException +=  new UnhandledExceptionEventHandler(CurrentDomain_UnhandledException); 
        }

         void CurrentDomain_UnhandledException( object sender, UnhandledExceptionEventArgs e)
        {
             try
            {

                Exception ex = e.ExceptionObject  as Exception;
                FileUtil.WriteLog( " 来自Service1的全局异常,  " + ex.Message +  " 详细信息如下： "
                                    + Environment.NewLine +  " ［InnerException］ " + ex.InnerException
                                    + Environment.NewLine +  " ［Source］ " + ex.Source
                                    + Environment.NewLine +  " ［TargetSite］ " + ex.TargetSite
                                    + Environment.NewLine +  " ［StackTrace］ " + ex.StackTrace);
            }
             catch { }
        }
        
         protected  override  void OnStart( string[] args)
        {
            FileUtil.WriteLog( " OnStart ");
            Thread t =  new Thread( new ThreadStart( this.worker.Run));
            t.Start();
        }

         protected  override  void OnStop()
        {
            FileUtil.WriteLog( " OnStop ");

             this.worker.Stop =  true;
             this.worker.Pause =  true;
        }

         protected  override  void OnPause()
        {
            FileUtil.WriteLog( " OnPause ");
             this.worker.Pause =  true;
        }

         protected  override  void OnContinue()
        {
            FileUtil.WriteLog( " OnContinue ");
             this.worker.Pause =  false;
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceProcess;
using System.Text;
using log4net.Config;

namespace WinConsoleService
{
     static  class Program
    {
         ///   <summary>
         ///  应用程序的主入口点。
         ///   </summary>
         static  void Main()
        {
            XmlConfigurator.Configure();
            ServiceBase[] ServicesToRun;
            ServicesToRun =  new ServiceBase[] 
            { 
                 new Service1() 
            };
            ServiceBase.Run(ServicesToRun);
        }
    }
}