一步一步用C#寫一個檢查SQL Server假死警報服務

本文主要是寫Windows 服務的一個實際應用。包括一個后台定時執行檢查的服務、寫文本日志功能、加密解密功能、發送郵件功能、一個XML的配置文件和讀取XML配置內容功能、服務的安裝和刪除功能。

我先說明，我不在這里研究SQL Server為什么有假死這樣的現象，實際在工作上就是碰到了多次這樣的情況，即服務運行,但不提供服務。

VS中不可以調試服務，所以有很多寫LOG的調用，是為了方便調試跟蹤。

為防止后續發生SQL Server服務假死(即服務運行,但不提供服務)的情況可以更及時的處理，一發動千均，一出問題，整個生產現場就得停工，所以才有本文。

 

資料和要求：

主要的MES數據庫有18個，內容包含以下Instance和Database:

UsedFor	Instance	Database
CPT	[HZXL1\HZXL1]	XLProd_Cree_HZ2
CPT	[HZXL1\HZXL1]	XLProd_Cree_HZ2_Archive
CPT	[HZXL1\HZXL1]	XLSite_Cree_HZ2
Camstar OLTP	[HZCS1\HZCS1]	FASSL
Camstar OLTP	[HZCS1\HZCS1]	InSiteDB
Camstar OLTP	[HZCS1\HZCS1]	InSiteDB_CSIPurgeDB
Camstar ODS	HZCSODS01	CNSSLRTS
Camstar ODS	HZCSODS01	InSiteODS
PNT	HZBACK01	CreeMES_PNT
PNT	HZBACK01	CreeMES_ReplStage
PNT	HZBACK01	CrystalReports2008
PNT	HZBACK01	FAOpto
PNT	HZBACK01	Intranet_Apps
PNT	HZBACK01	PNT_Parameters
PNT	HZBACK01	PNTLampInfo
PNT	HZBACK01	ProberInfo
PNT	HZBACK01	WaferWorks_PT
PNT	HZBACK01	WaferWorks_Sphere

當無法連接數據庫時,發出警報。

可以連入時,每個判斷語句只需抓取sys.sysindexes的第一筆記錄,sample如下:

select top 1 'OK' from sys.sysindexes with(nolock)

判斷所有數據庫均能抓出數據,如果有不能抓出的數據,發出警報並顯示出詳細信息.

警報地址---(#Asia_IT_Operations; #HZ_IS_Helpdesk)

這樣第一時間Helpdesk會收到信息，確認問題無法處理時，可以聯系二線人員處理。

 

實際的效果：

生產的服務程序文件列表，包括主程序，安裝和刪除批處理

 

安裝后在服務中可以看到服務的情況

 

單個檢查項對應產生的日志文件

主程序日志文件

 

報警郵件

 

功能實現：

由於很多童孩都不多用服務，還是一步一步的寫出來，讓想試試又未試過的也可以照做。

我要檢查的數據庫眾多，18個，就18個嗎？

所以這些都要用配置文件來配置，可加可減才行.

日志是少不了的，那是否一定就要呢？什么時候都是有比無要好，但是可有可無才是靈活的方式，那要還是不要？

功能是要有，但是用與不用，改改參數就可以吧，那參數也放配置文件中好了。

要發郵件，SMTP是固定的嗎？有其它的沒有？可能想更換的時候也是有的？

也就是說SMTP的信息（服務器、用戶名、密碼等）都放配置文件。

還有收郵件的人員、日志文件的名稱和路徑、一些默認值、具體的數據庫信息都應該在配置文件中。

由於是給一線人員檢查用的，所以敏感信息需要加密后再放配置文件中，最后確定配置文件使用一個自定義的XML最好。

由上邊的內容，應該需要寫文本日志功能、一個XML的配置文件、加密解密功能、發送郵件功能、一個后台定時執行檢查的服務、讀取XML配置內容、服務的安裝和刪除功能.

OK,就一步一步來吧！

 

第一步：新建一個項目

如下圖，創建一個名為MonitorSqlServerWindowsService的Windows Service項目。

創建后的默認如下：

在屬性中更改名稱和服務名如下

 

第二步：加密解密功能實現

新建立一個類，名為MonitorSqlServerWindowsService

MonitorSqlServerWindowsService類的代碼：

using System;
using System.Security.Cryptography;
using System.IO;

namespace Core.DarrenEncodeOrDecode
{
    /// <summary>
    /// 描述：EncodeOrDecode是加密解密類
    /// 程序員：謝堂文(Darren Xie)
    /// 創建日期：2012-01-18
    /// 版本：1.0
    /// </summary>
    public class EncodeOrDecode
    {
        const string KEY_64 = "9Hgu#6w!";
        const string IV_64 = "InitVect";
        public EncodeOrDecode()
        {
            //
            // TODO: Add constructor logic here
            //
        }
        /// <summary>
        /// 默認的加密方法，加密傳入的字符串，返回加密後的字符串
        /// </summary>
        /// <param name="data">需要加密的字符串</param>
        /// <returns>加密後的字符串</returns>
        public static string Encode(string data)
        {
            byte[] byKey = System.Text.ASCIIEncoding.ASCII.GetBytes(KEY_64);
            byte[] byIV = System.Text.ASCIIEncoding.ASCII.GetBytes(IV_64);

            DESCryptoServiceProvider cryptoProvider = new DESCryptoServiceProvider();
            int i = cryptoProvider.KeySize;
            MemoryStream ms = new MemoryStream();
            CryptoStream cst = new CryptoStream(ms, cryptoProvider.CreateEncryptor(byKey, byIV), CryptoStreamMode.Write);

            StreamWriter sw = new StreamWriter(cst);
            sw.Write(data);
            sw.Flush();
            cst.FlushFinalBlock();
            sw.Flush();
            return Convert.ToBase64String(ms.GetBuffer(), 0, (int)ms.Length);
        }
        /// <summary>
        /// 自定義密鑰的加密方法，加密傳入的字符串，返回加密後的字符串
        /// </summary>
        /// <param name="data">需要加密的字符串</param>
        /// <returns>加密後的字符串</returns>
        public static string Encode(string data,string key,string iv)
        {
            byte[] byKey = System.Text.ASCIIEncoding.ASCII.GetBytes(key);
            byte[] byIV = System.Text.ASCIIEncoding.ASCII.GetBytes(iv);

            DESCryptoServiceProvider cryptoProvider = new DESCryptoServiceProvider();
            int i = cryptoProvider.KeySize;
            MemoryStream ms = new MemoryStream();
            CryptoStream cst = new CryptoStream(ms, cryptoProvider.CreateEncryptor(byKey, byIV), CryptoStreamMode.Write);

            StreamWriter sw = new StreamWriter(cst);
            sw.Write(data);
            sw.Flush();
            cst.FlushFinalBlock();
            sw.Flush();
            return Convert.ToBase64String(ms.GetBuffer(), 0, (int)ms.Length);
        }

        /// <summary>
        /// 默認的解密方法，傳入加密的字符串，返回解密後的字符串
        /// </summary>
        /// <param name="data">需要解密的字符串</param>
        /// <returns>解密後的字符串</returns>
        public static string Decode(string data)
        {
            byte[] byKey = System.Text.ASCIIEncoding.ASCII.GetBytes(KEY_64);
            byte[] byIV = System.Text.ASCIIEncoding.ASCII.GetBytes(IV_64);

            byte[] byEnc;
            try
            {
                byEnc = Convert.FromBase64String(data);
            }
            catch
            {
                return null;
            }

            DESCryptoServiceProvider cryptoProvider = new DESCryptoServiceProvider();
            MemoryStream ms = new MemoryStream(byEnc);
            CryptoStream cst = new CryptoStream(ms, cryptoProvider.CreateDecryptor(byKey, byIV), CryptoStreamMode.Read);
            StreamReader sr = new StreamReader(cst);
            return sr.ReadToEnd();
        }
        /// <summary>
        /// 自定義密鑰的解密方法，傳入加密的字符串，返回解密後的字符串
        /// </summary>
        /// <param name="data">需要解密的字符串</param>
        /// <returns>解密後的字符串</returns>
        public static string Decode(string data,string key,string iv)
        {
            byte[] byKey = System.Text.ASCIIEncoding.ASCII.GetBytes(key);
            byte[] byIV = System.Text.ASCIIEncoding.ASCII.GetBytes(iv);

            byte[] byEnc;
            try
            {
                byEnc = Convert.FromBase64String(data);
            }
            catch
            {
                return null;
            }

            DESCryptoServiceProvider cryptoProvider = new DESCryptoServiceProvider();
            MemoryStream ms = new MemoryStream(byEnc);
            CryptoStream cst = new CryptoStream(ms, cryptoProvider.CreateDecryptor(byKey, byIV), CryptoStreamMode.Read);
            StreamReader sr = new StreamReader(cst);
            return sr.ReadToEnd();
        }
    }
}

 

第三步：建立XML配置文件

增加一個XML文件到項目中，名為ServerConfig.xml，代碼如下：

<?xml version="1.0" encoding="utf-8" ?>
<parameters>

  <!--標準基礎信息-->
  <istest val="0">測試標識,1是測試，非1是正式</istest>
  <checkTime val="120">檢查週期，單位是秒</checkTime>
  <smtp name="你的SMTP服務器" from="你的郵箱地址" user="你的用戶名" pwd="M/R3ib7M0OVPpDWmAZjGGw==">郵件服務器信息</smtp>

  <defsqlUser dbuser="D+Zox91emVaNWnUtiLez9g==" userpwd="bCIkRm+dTA1kJO0oRlOLxg==">默認數據庫訪問賬號</defsqlUser>
  <to email="#[e-mail]; #[e-mail];[e-mail]"></to>
  <isLog val="1">是否產生日誌文件,1產生，非1就不產生</isLog>
  <LogFilePath val="">日誌文件存放路徑</LogFilePath>
  <LogFileName val="">日誌文件名</LogFileName>
  <sql val="select top 1 'OK' from sys.sysindexes with(nolock)"></sql>
  <dbsrv srvname="HZXL1\HZXL1" dbname="XLProd_Cree_HZ2" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZXL1\HZXL1" dbname="XLProd_Cree_HZ2_Archive" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZXL1\HZXL1" dbname="XLSite_Cree_HZ2" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZCS1\HZCS1" dbname="FASSL" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZCS1\HZCS1" dbname="InSiteDB" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZCS1\HZCS1" dbname="InSiteDB_CSIPurgeDB" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZCSODS01" dbname="CNSSLRTS" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZCSODS01" dbname="InSiteODS" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZBACK01" dbname="CreeMES_PNT" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZBACK01" dbname="CreeMES_ReplStage" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZBACK01" dbname="CrystalReports2008" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZBACK01" dbname="FAOpto" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZBACK01" dbname="Intranet_Apps" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZBACK01" dbname="PNT_Parameters" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZBACK01" dbname="PNTLampInfo" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZBACK01" dbname="ProberInfo" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZBACK01" dbname="WaferWorks_PT" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
  <dbsrv srvname="HZBACK01" dbname="WaferWorks_Sphere" dbuser="" userpwd="" sql="" descr="" LogFileName="">數據庫信息</dbsrv>
</parameters>

 

第四步：寫文本日志功能

增加一個類，名為FileLog.cs

代碼如下：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;//StreamWriter
using System.Collections;//arraylist

namespace Core.DarrenCoreLib.Log
{
    /// <summary>
    /// 描述：寫ＴＸＴ格式的ＬＯＧ
    /// 程序員：謝堂文(Darren Xie)
    /// 創建日期：2012-02-09
    /// 版本：1.0
    /// </summary>
    public static class FileLog
    {
        public static void writeTotxt(string fullFilepath, string ppContent)
        {
            StreamWriter Sw1 = null;
            try
            {
                Sw1 = new StreamWriter(fullFilepath, true, System.Text.Encoding.UTF8);
                {
                    Sw1.WriteLine(ppContent);
                }
            }
            catch (Exception ef)
            {
                throw new Exception(ef.Message);
            }
            finally
            {
                try
                {
                    Sw1.Close();
                }
                catch
                {
                }
            }

        }
    }
}

第五步：增加一個類用於實際的數據庫檢查對象，並且保存配置文件中對應的屬性以及寫日志、執行檢查、發送郵件等，具體看代碼注釋會更明白，就名為Srv.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Mail;
using System.Data.SqlClient;
using System.Data;
using System.Net;

namespace MonitorSqlServerWindowsService
{
    /// <summary>
    /// 描述：
    /// 程序員：謝堂文(Darren Xie)
    /// 創建日期：
    /// 版本：1.0
    /// </summary>
    public class Srv
    {

        string smtpName;
        string smtpPwd;
        string smtpUser;
        string from;
        string[] to;
        string srvname;
        string dbname;
        string dbuser;
        string userpwd;
        string sql;
        string descr;
        int isLog;
        string logFilePath;
        string logFileName;

        /// <summary>
        /// 生產日誌文件名稱
        /// </summary>
        public string LogFileName
        {
            get { return logFileName; }
            set { logFileName = value; }
        }
        /// <summary>
        /// 日誌文件存放的路徑
        /// </summary>
        public string LogFilePath
        {
            get { return logFilePath; }
            set { logFilePath = value; }
        }
        /// <summary>
        /// 是否產生日誌文件
        /// </summary>
        public int IsLog
        {
            get { return isLog; }
            set { isLog = value; }
        }

        /// <summary>
        /// SMTP服務器
        /// </summary>
        public string SmtpName
        {
            get { return smtpName; }
            set { smtpName = value; }
        }

        /// <summary>
        /// 用於發郵件的SMTP用戶密碼
        /// </summary>
        public string SmtpPwd
        {
            get { return smtpPwd; }
            set { smtpPwd = value; }
        }

        /// <summary>
        /// 用於發郵件的SMTP用戶名
        /// </summary>
        public string SmtpUser
        {
            get { return smtpUser; }
            set { smtpUser = value; }
        }

        /// <summary>
        /// 用於發郵件的SMTP用戶名郵件地址
        /// </summary>
        public string From
        {
            get { return from; }
            set { from = value; }
        }

       /// <summary>
       /// 收件人地址
       /// </summary>
        public string[] To
        {
            get { return to; }
            set { to = value; }
        }
        /// <summary>
        /// 連接字符串
        /// </summary>
        public string ConnectionString
        {
            get
            {
                return @"server="+Srvname+";database="+Dbname+";uid="+Core.DarrenEncodeOrDecode.EncodeOrDecode.Decode( Dbuser)+";pwd="+Core.DarrenEncodeOrDecode.EncodeOrDecode.Decode(Userpwd)+"";
            }
        }


        public string Srvname
        {
            get { return srvname; }
            set { srvname = value; }
        }

        /// <summary>
        /// 數據庫所在的服務器名
        /// </summary>
        public string Dbname
        {
            get { return dbname; }
            set { dbname = value; }
        }

        /// <summary>
        /// 數據庫用戶名
        /// </summary>
        public string Dbuser
        {
            get { return dbuser; }
            set { dbuser = value; }
        }

        /// <summary>
        /// 數據庫用戶的密碼
        /// </summary>
        public string Userpwd
        {
            get { return userpwd; }
            set { userpwd = value; }
        }

        /// <summary>
        /// 檢查用的SQL語句
        /// </summary>
        public string Sql
        {
            get { return sql; }
            set { sql = value; }
        }

        /// <summary>
        /// 描述信息
        /// </summary>
        public string Descr
        {
            get { return descr; }
            set { descr = value; }
        }
        /// <summary>
        /// 執行連接和查詢測試
        /// </summary>
        public void Chk()
        {
            using (SqlConnection conn = new SqlConnection(ConnectionString))
            {
                try
                {
                    writestr("開始連接" + Srvname + "服務器上的數據庫" + Dbname);
                    conn.Open();
                    writestr("連接" + Srvname + "服務器上的數據庫" + Dbname + "成功");

                    writestr("開始測試查詢" + Srvname + "服務器上的數據庫" + Dbname + "上的數據");

                    if (Core.DarrenCoreLib.DB.SqlHelper.ExecuteScalar(conn, CommandType.Text, Sql).ToString().ToUpper() == "OK")
                    {
                        writestr("查詢" + Srvname + "服務器上的數據庫" + Dbname + "數據測試成功");
                    }
                    else
                    {
                        throw new Exception("查詢" + Srvname + "服務器上的數據庫" + Dbname + "數據測試失敗");
                    }
                }
                catch (Exception ee)
                {

                        writestr(Srvname + "服務器上的數據庫" + Dbname + "檢查失敗" + ee.Message);
                        writestr("準備發送郵件");
                        writestr(this.To[0]);
                        string errMsg = ee.Message;
                    try
                    {
                        if (this.From.Trim() == string.Empty)
                        {
                            throw new Exception("沒有指定發件者地址。");
                        }
                        if (this.Srvname.Trim() == string.Empty)
                        {
                            throw new Exception("沒有指定服務器。");
                        }
                        if (this.Dbname.Trim() == string.Empty)
                        {
                            throw new Exception("沒有指定數據庫。");
                        }
                        if (this.To.Length == 0)
                        {
                            throw new Exception("沒有指定收件者地址。");
                        }

                        if (this.SendMail(this.From, this.To, "檢查服務器 " + this.Srvname + "上的數據庫 " + this.Dbname + " 失敗", "<H1>SQL Server假死警報服務! </H1><br/>   <b>信息內容：<b/>" + errMsg + "<br/>服務器：" + this.Srvname + "<br/>數據庫：" + this.Dbname +"<br/>來自配置文件的數據庫描述信息："+this.Descr.ToString()+ "<br/>請注意檢查確認，這是郵系統自動檢查發出的信息。<br/>來自服務器：" + Dns.GetHostName()))
                        {
                            writestr("發送郵件成功");
                        }
                    }
                    catch (Exception em)
                    {
                        writestr("發送郵件失敗,"+em.Message);
                    }
                }
                finally
                {
                    try
                    {
                        conn.Close();
                    }
                    catch { }
                }
            }
        }
        /// <summary>
        /// 寫日誌文件
        /// </summary>
        /// <param name="readme"></param>
        private void writestr(string readme)
        {
            if (IsLog == 1)
            {
                Core.DarrenCoreLib.Log.FileLog.writeTotxt((LogFilePath + LogFileName), "\r\n事件：" + readme + "\r\n操作時間：" + System.DateTime.Now.ToString("yyy-MM-dd HH:mm:ss"));
            }
        }
        /// <summary>
        /// 發送郵件
        /// </summary>
        /// <param name="messagefrom"></param>
        /// <param name="MessageTo"></param>
        /// <param name="MessageSubject"></param>
        /// <param name="MessageBody"></param>
        /// <returns></returns>
        public bool SendMail(string messagefrom, string[] MessageTo, string MessageSubject, string MessageBody)
        {
            MailMessage message = new MailMessage();
            message.SubjectEncoding = System.Text.Encoding.Unicode;
            SmtpClient sc = new SmtpClient();
            try
            {
                MailAddress Messagefrom = new MailAddress(messagefrom);
                message.From = Messagefrom;

                foreach (string to in MessageTo)
                {
                    writestr(to);
                    message.To.Add(to);
                }//收件人郵箱地址可以是多個以實現群發
                if (MessageSubject.Trim() == string.Empty)
                {
                    throw new Exception("沒有指定郵件標題。");
                }
                message.Subject = MessageSubject;
                if (messagefrom.Trim() == string.Empty)
                {
                    throw new Exception("沒有指定郵件內容。");
                }
                message.Body = MessageBody;
                message.IsBodyHtml = true;              //是否為html格式
                message.Priority = MailPriority.High;  //發送郵件的優先等級
                if (SmtpName.Trim() == string.Empty)
                {
                    throw new Exception("沒有指定SMTP地址。");
                }
                if (SmtpUser.Trim() == string.Empty)
                {
                    throw new Exception("沒有指定SMTP用戶名。");
                }
                if (SmtpPwd.Trim() == string.Empty)
                {
                    throw new Exception("沒有指定SMTP密碼。");
                }
                sc.Host = SmtpName;              //指定發送郵件的服務器地址或IP
                //sc.Port = 212;                          //指定發送郵件端口
                //   sc.UseDefaultCredentials = true;
                // sc.EnableSsl = true;
                sc.Credentials = new System.Net.NetworkCredential(SmtpUser, Core.DarrenEncodeOrDecode.EncodeOrDecode.Decode(SmtpPwd)); //指定登錄服務器的用戶名和密碼
            }
            catch (Exception ee)
            {
                throw new Exception(ee.Message);
            }

            try
            {
                sc.Send(message);      //發送郵件
            }
            catch (Exception e)
            {
                throw new Exception(e.Message);
            }
            return true;
        }
    }
}

第六步：在服務的設計視圖中，增加一個timer控件名為timerChkSql，有一點要注意，timer有不同的，，要加正確的命名空間下的timer控件，請注意清楚如下的區另，紅色標記的才是正確的，否則到時會不工作；

在控件的選擇項中可以看到它們

之后你會看到

 

第七步：回到服務的功能上，需要組裝上邊幾個功能在一起，對了，先要讀取配置文件，讀取時建立每個數據庫對象

先建立一個List來放對象，在MyService.cs中增加以下屬性

private System.Collections.Generic.List<Srv> srvList = new List<Srv>();
        /// <summary>
        /// 用城保存需要檢查的數據庫的信息對象列表
        /// </summary>
        public System.Collections.Generic.List<Srv> SrvList
        {
            get { return srvList; }
            set { srvList = value; }
        }

OnStart中讀取配置文件時，用string filexml = System.Windows.Forms.Application.StartupPath.ToString() + @"\ServerConfig.xml"來取配置文件的實際路徑，這樣可以取到安裝的目錄。

在timerChkSql_Elapsed中增加定時檢查的功能代碼

//執行檢查
           writestr("執行檢查。");
           try
           {               
               foreach (Srv s in SrvList)
               {
                   writestr("執行檢查" + s.Dbname);
                   s.Chk();
               }
           }
           catch (Exception ee)
           {
               writestr("執行檢查出錯。" + ee.Message);
               EventLog.WriteEntry("執行檢查出錯。" + ee.Message);
           }

 

完整的MyService.cs代碼：

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Linq;
using System.ServiceProcess;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.ServiceProcess;
using System.IO;
using System.Text;
using System.Timers;
using System.Threading;
using Core.DarrenCoreLib;
using System.Net.Mail;
using System.Data.SqlClient;
using System.Xml;

//=================================================================================
//
//        Copyright (C) 2012， 謝堂文(Darren Xie)
//        All rights reserved
//        Created by Darren at 12-03-15 14:12:57
//        Email: [e-mail]
//        http://www.cnblogs.com/yiyumeng/
//
//==================================================================================

namespace MonitorSqlServerWindowsService
{
    public partial class MyService : ServiceBase
    {

        private System.Collections.Generic.List<Srv> srvList = new List<Srv>();
        /// <summary>
        /// 用城保存需要檢查的數據庫的信息對象列表
        /// </summary>
        public System.Collections.Generic.List<Srv> SrvList
        {
            get { return srvList; }
            set { srvList = value; }
        }
        public MyService()
        {
            InitializeComponent();
        }

        protected override void OnStart(string[] args)
        {

            int istest = 0;
            string defsqlUser_dbuser = string.Empty;
            string defsqlUser_userpwd = string.Empty;
            string smtpName = string.Empty;
            string smtpFrom = string.Empty;
            string smtpUser = string.Empty;
            string smtpPwd = string.Empty;
            string[] to = null;
            int isLog = 0;
            string LogFilePath = string.Empty;
            string LogFileName = string.Empty;
            string sql = string.Empty;

            EventLog.WriteEntry("檢查SQL服務器的服務啟動。");//在系統事件查看器里的應用程序事件里來源的描述
            writestr("服務啟動");//自定義文本日志
            XmlDocument xmlDoc = new XmlDocument();
            try
            {
                string filexml = System.Windows.Forms.Application.StartupPath.ToString() + @"\ServerConfig.xml";
                if (!System.IO.File.Exists(filexml))
                {
                    throw new Exception("找不到配置文件" + filexml);
                }
                writestr("讀取檢查週期時間");
                xmlDoc.Load(filexml);
            }
            catch (Exception ee)
            {
                EventLog.WriteEntry("檢查SQL服務器的服務啟動時讀取檢查週期時間出錯。" + ee.Message);
                writestr("檢查SQL服務器的服務啟動時讀取檢查週期時間出錯。" + ee.Message);
            }
            XmlNodeList nodeList = xmlDoc.SelectSingleNode("parameters").ChildNodes;
            try
            {
                writestr("開始讀取配置內容");
                foreach (XmlNode xn in nodeList)
                {

                    if (xn.Name == "checkTime")
                    {
                        timerChkSql.Interval = (double.Parse(xn.Attributes["val"].Value))*1000;
                        writestr("讀取到檢查週期時間" + xn.Attributes["val"].Value);
                    }
                    if (xn.Name == "istest")
                    {
                        istest = int.Parse(xn.Attributes["val"].Value);

                    }
                    if (xn.Name == "smtp")
                    {
                        smtpName = xn.Attributes["name"].Value;

                        smtpFrom = xn.Attributes["from"].Value;

                        smtpUser = xn.Attributes["user"].Value;

                        smtpPwd = xn.Attributes["pwd"].Value;


                    }
                    if (xn.Name == "defsqlUser")
                    {

                        defsqlUser_dbuser = xn.Attributes["dbuser"].Value;

                        defsqlUser_userpwd = xn.Attributes["userpwd"].Value;

                    }
                    if (xn.Name == "to")
                    {
                        to = xn.Attributes["email"].Value.Split(new char[] { ';' });

                    }
                    if (xn.Name == "isLog")
                    {
                        isLog = int.Parse(xn.Attributes["val"].Value);

                    }
                    if (xn.Name == "LogFilePath")
                    {
                        LogFilePath = xn.Attributes["val"].Value == "" ? System.Windows.Forms.Application.StartupPath.ToString() +@"\": xn.Attributes["val"].Value;

                    }
                    if (xn.Name == "sql")
                    {
                        sql = xn.Attributes["val"].Value;

                    }
                    if (xn.Name == "LogFileName")
                    {

                        LogFileName = xn.Attributes["val"].Value;

                    }
                    if (xn.Name == "dbsrv")
                    {
                        Srv s = new Srv();
                        s.IsLog = isLog;
                        s.Srvname = xn.Attributes["srvname"].Value;
                        s.Dbname = xn.Attributes["dbname"].Value;
                        s.Dbuser = xn.Attributes["dbuser"].Value != "" ? xn.Attributes["dbuser"].Value : defsqlUser_dbuser;
                        s.Userpwd = xn.Attributes["userpwd"].Value != "" ? xn.Attributes["userpwd"].Value : defsqlUser_userpwd;
                        s.Sql = xn.Attributes["sql"].Value != "" ? xn.Attributes["sql"].Value : sql;
                        s.Descr = xn.Attributes["descr"].Value;
                        s.LogFileName = xn.Attributes["LogFileName"].Value != "" ? xn.Attributes["LogFileName"].Value : (LogFileName != "" ? LogFileName : s.Dbname + "ChkLog.txt");
                        s.LogFilePath = LogFilePath;
                        s.To = to;
                        s.From = smtpFrom;
                        s.SmtpName = smtpName;
                        s.SmtpPwd = smtpPwd;
                        s.SmtpUser = smtpUser;
                        SrvList.Add(s);

                    }


                }
                writestr("讀取配置內容完成。");

            }
            catch (Exception ee)
            {
                EventLog.WriteEntry("檢查SQL服務器的服務啟動時讀取配置內容出錯。" + ee.Message);
                writestr("檢查SQL服務器的服務啟動時讀取配置內容出錯。" + ee.Message);
            }

        }

        protected override void OnStop()
        {
            writestr("服務停止");
            EventLog.WriteEntry("檢查SQL服務器的服務停止。");
        }

        private void timerChkSql_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
        {
            //執行檢查
            writestr("執行檢查。");
            try
            {
                foreach (Srv s in SrvList)
                {
                    writestr("執行檢查" + s.Dbname);
                    s.Chk();
                }
            }
            catch (Exception ee)
            {
                writestr("執行檢查出錯。" + ee.Message);
                EventLog.WriteEntry("執行檢查出錯。" + ee.Message);
            }




        }
        public void writestr(string readme)
        {
            Core.DarrenCoreLib.Log.FileLog.writeTotxt((System.Windows.Forms.Application.StartupPath.ToString() + @"\" + "MonitorSqlServerWindowsService.txt"), "\r\n事件：" + readme + "\r\n操作時間：" + System.DateTime.Now.ToString("yyy-MM-dd HH:mm:ss"));
        }



    }
}

 

第八步：增加安裝

在設計頁面點右鍵增加安裝，之后你會看到以下的樣子，並分別進行設定。

注意設定你的顯示信息和服務名稱，不是控件名。

同時也要設定StartType,我設為自動，這樣一開機就會自動啟用。

 

注意使用LocalSystem賬號的設定，否則無法自動運行。

 

第九步：生成

先取Releasc的方式進行Build.

你會看到在BIN目錄下有一個Release。

就會有以下圖文件，除標了顏色的四個

 

從C:\Windows\Microsoft.NET\Framework\v2.0.50727中復制InstallUtil.exe和InstallUtilLib.dll這兩個文件出來。

從源代碼文件中復制配置文件ServerConfig.xml出來。

建立安裝批處理文件Install.bat，假設安裝目錄是C:\MonitorSqlServerWindowsService：

c:
cd C:\MonitorSqlServerWindowsService
InstallUtil MonitorSqlServerWindowsService.exe
net start MonitorSqlServerStatus

 

建立反安裝批處理文件UnInstall.bat，假設安裝目錄是C:\MonitorSqlServerWindowsService：

c:
cd C:\MonitorSqlServerWindowsService
net stop MonitorSqlServerStatus
InstallUtil -u MonitorSqlServerWindowsService.exe

之后把所有這個文件夾下的文件復制到一個MonitorSqlServerWindowsService文件夾下。要在那台電腦站安裝，說復制到C盤再運行安裝批處理就可以了。

 

另外，我把發郵件的地址加入139郵箱，並設好139郵件用長信息通知，那就可以在收到郵件時，也收到信息，在信息內容中就可以有350個字的內容，看你的提醒內容吧。

 

文墨所限，請多多指教。

請尊重原創版權，轉載注明出處。