using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.ServiceProcess;
using System.Text;
using System.Threading;
using System.Management;
using System.Configuration;
using System.Net;
using System.IO;
namespace MON.WS
{
public partial class Service : ServiceBase
{
//post 11.9
//卸載服務
//installutil /u F:/XLFX-2/XLFX/MON.WS/bin/debug/MON.WS.EXE
//安裝服務
//installutil F:/XLFX-2/XLFX/MON.WS/bin/debug/MON.WS.EXE
object threadObj;
Thread jobThread;
Dictionary<string, PerformanceCounter> dicCounter;
Dictionary<string, ManagementObject> dicDisk;
public Service()
{
InitializeComponent();
}
/// <summary>
/// 服務啟動
/// </summary>
/// <param name="args"></param>
protected override void OnStart(string[] args)
{
threadObj = new object();
dicCounter = new Dictionary<string, PerformanceCounter>();
dicDisk = new Dictionary<string, ManagementObject>();
jobThread = new Thread(new ThreadStart(Job));
jobThread.IsBackground = true;
jobThread.Start();
}
/// <summary>
/// 服務停止
/// </summary>
protected override void OnStop()
{
if (jobThread.IsAlive)
{
jobThread.Abort();
jobThread.Join();
}
foreach (var obj in dicCounter.Values)
{
obj.Dispose();
}
foreach (var obj in dicDisk.Values)
{
obj.Dispose();
}
dicDisk.Clear();
dicCounter.Clear();
}
/// <summary>
/// 監控線程
/// </summary>
void Job()
{
while (true)
{
lock (threadObj)
{
//監控開始
try
{
var obj = new MONServiceClient.MONService();
var hn = Dns.GetHostName();
var ips = GetIpv4Address(hn);
if (ips.Count < 1)
{
obj.Dispose();
Thread.Sleep(60000);//如果服務器出錯，那么就每分鐘去檢查一次
WriteLog("一個IPV4的地址也沒有得到");
continue;
}
DataSet ds = GetConfigDS(hn,ips,obj);
if (ds == null)
{
obj.Dispose();
Thread.Sleep(60000);
WriteLog("請檢查WEBService和全局變量設置");
continue;
}
int sleepTime;
try
{
sleepTime = Convert.ToInt32(ds.Tables[0].Rows[0]["LOG_CIRC"]) * 1000;//毫秒
}
catch
{
sleepTime = 60000;
}
if (sleepTime < 1)
{
sleepTime = 60000;
}
Thread.Sleep(sleepTime);
if (ds.Tables[1].Rows[0]["S_ISWATCH"].ToString() == "0")
{
//監控開關->關閉
obj.Dispose();
continue;
}
var arr = getWatchValue(ds).ToArray();
obj.UpdateServerStatus(arr);
obj.Dispose();
}
catch (Exception ex)
{
WriteLog(ex.Message);
}
//監控結束
}
}
}
/// <summary>
/// 獲取配置信息
/// </summary>
/// <param name="ips"></param>
/// <returns></returns>
DataSet GetConfigDS(string hn,List<IPAddress> ips,MONServiceClient.MONService obj)
{
DataSet ds;
try
{
if (ips.Count > 1)
{
ds = obj.GetMachineConfig(hn, ips[0].ToString(), ips[1].ToString());
}
else
{
ds = obj.GetMachineConfig(hn, ips[0].ToString(), "");
}
}
catch
{
ds = null;
}
return ds;
}
/// <summary>
/// 獲取性能數組
/// </summary>
/// <param name="ds"></param>
/// <returns></returns>
List<string> getWatchValue(DataSet ds)
{
var result = new List<string>();
result.Add(ds.Tables[1].Rows[0]["LIST_ID"].ToString());
result.Add(GetValue(ds.Tables[1].Rows[0]["S_CPU"].ToString()).ToString("F2"));
result.Add(GetDiskValue(ds.Tables[1].Rows[0]["S_DISK_APP"].ToString()).ToString("F2"));
result.Add(GetDiskValue(System.Environment.SystemDirectory.Substring(0, 2)).ToString("F2"));
result.Add(GetValue(ds.Tables[1].Rows[0]["S_MEMORY"].ToString()).ToString("F2"));
result.Add(GetValue(ds.Tables[1].Rows[0]["S_FLOW_IN"].ToString()).ToString("F2"));
result.Add(GetValue(ds.Tables[1].Rows[0]["S_FLOW_OUT"].ToString()).ToString("F2"));
result.Add(GetValue(ds.Tables[1].Rows[0]["S_WEB_PORT"].ToString()).ToString("F2"));
result.Add(GetValue(ds.Tables[1].Rows[0]["S_SQL_CONNECT"].ToString()).ToString("F2"));
result.Add(ds.Tables[1].Rows[0]["CAMP_ID"].ToString());
result.Add(ds.Tables[1].Rows[0]["CICODE"].ToString());
result.Add(ds.Tables[1].Rows[0]["S_KIND"].ToString());
return result;
}
/// <summary>
/// 獲取IPV4的地址
/// </summary>
/// <param name="hn"></param>
/// <returns></returns>
List<IPAddress> GetIpv4Address(string hn)
{
var result = new List<IPAddress>();
var ips = Dns.GetHostAddresses(hn);
foreach (var ip in ips)
{
if (ip.AddressFamily == System.Net.Sockets.AddressFamily.InterNetwork)
{
result.Add(ip);
}
}
return result;
}
/// <summary>
/// 獲取性能計數器的值
/// </summary>
/// <param name="configStr"></param>
/// <returns></returns>
double GetValue(string configStr)
{
try
{
if (!dicCounter.ContainsKey(configStr))
{
var arr = configStr.Split('#');
var pc = new PerformanceCounter();
pc.CategoryName = arr[0];
pc.CounterName = arr[1];
pc.InstanceName = arr[2];
dicCounter.Add(configStr, pc);
}
return dicCounter[configStr].NextValue();
}
catch (Exception ex)
{
WriteLog(string.Format("計數器取值錯誤：{0}{1}{2}", configStr, Environment.NewLine, ex.Message));
return -1;
}
}
/// <summary>
/// 獲取磁盤信息的值
/// </summary>
/// <param name="key"></param>
/// <returns></returns>
double GetDiskValue(string key)
{
try
{
if (!dicDisk.ContainsKey(key))
{
ManagementObject DiskInfo = new ManagementObject(string.Format("win32_logicaldisk.deviceid=/"{0}/"", key));
dicDisk.Add(key, DiskInfo);
}
dicDisk[key].Get();
var s = Convert.ToDouble(dicDisk[key]["Size"]);
var l = Convert.ToDouble(dicDisk[key]["FreeSpace"]);
var d = (s - l) / s * 100;
return d;
}
catch (Exception ex)
{
WriteLog(string.Format("獲取磁盤信息值錯誤：{0}{1}{2}", key, Environment.NewLine, ex.Message));
return -1;
}
}
/// <summary>
/// 寫本地日志
/// </summary>
/// <param name="text"></param>
void WriteLog(string text)
{
try
{
var logDic = ConfigurationManager.AppSettings["LogDic"];
int logDays;
try
{
logDays = Convert.ToInt32(ConfigurationManager.AppSettings["LogDays"]);
}
catch
{
logDays = 7;
}
if (logDays < 1)
{
logDays = 7;
}
var fs = LogFileMon(logDic, logDays);
StreamWriter writer = new StreamWriter(fs);
writer.WriteLine(DateTime.Now.ToString());
writer.WriteLine(text);
writer.WriteLine("-----------------------------------------------------------");
writer.Flush();
writer.Close();
fs.Close();
}
catch
{
//寫日志出錯就沒辦法了
}
}
/// <summary>
/// 維護日志文件
/// </summary>
/// <param name="logDic"></param>
/// <param name="days"></param>
FileStream LogFileMon(string logDic, int dayCount)
{
DirectoryInfo di = new DirectoryInfo(logDic);
//如果日志文件夾不存在則創建日志文件夾；
if (!di.Exists)
{
di.Create();
}
//當前應保存的日志數據
List<string> days = new List<string>();
for (var i = 0; i < dayCount; i++)
{
var d = DateTime.Now.AddDays(0 - i).ToString("yyyy-MM-dd");
days.Add(string.Format("{0}.log", d));
}
//刪除沒用的歷史數據
foreach (var f in di.GetFiles())
{
if (!days.Contains(f.Name))
{
f.Delete();
}
}
//返回當前日志文件的數據流
var fileName = Path.Combine(logDic, days[0]);
var fs = File.Open(fileName, FileMode.Append,FileAccess.Write);
return fs;
}
}
}
