系统数据监控

系统数据监控。

 

 

 

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading;
using Arch.CFramework.CLoggingAdapter;
using Ctrip.Mobile.AppDownload.Utility;namespace Ctrip.Mobile.AppDownload.Service
{public class MonitorService : RunningService{public MonitorService(){ElapsedMiliseconds = 3 * 60 * 60 * 1000;//每3小时记录一次。
            s_stopwatch.Start();}public override void LoopLogic(){string info = GetSystemInfo();//Dashboard is better.LoggingManager.Instance().Info("MoniterService", info, new Dictionary<string, string>() { { "SystemInfo", "SystemInfo" } });}Stopwatch s_stopwatch = new Stopwatch();private PerformanceCounter _pc;private static TimeSpan s_lastTotalProcessTime = TimeSpan.Zero;public string GetSystemInfo(){int timeout;int totalThreads;int memory;int workingSetExecludePrivate;int workerThreads;int completionPortThreads;int maxThreadPoolThreads;int maxIOCPThreads;string split = ", ";StringBuilder sbInfo = new StringBuilder();sbInfo.Append(DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss fff") + split);s_stopwatch.Stop();Process process = Process.GetCurrentProcess();if (_pc == null){_pc = new PerformanceCounter("Process", "Working Set - Private", process.ProcessName);}process.Refresh();totalThreads = process.Threads.Count;memory = (int)((process.WorkingSet64) / (1024 * 1024));workingSetExecludePrivate = (int)(_pc.NextValue() / (1024 * 1024));double elapsedProcessTime = (process.TotalProcessorTime - s_lastTotalProcessTime).TotalMilliseconds;double elapsedSystemTime = s_stopwatch.ElapsedMilliseconds;int cpu = (int)(Math.Round(elapsedProcessTime * 100.0 / elapsedSystemTime / Environment.ProcessorCount));s_lastTotalProcessTime = process.TotalProcessorTime;s_stopwatch.Restart();ThreadPool.GetAvailableThreads(out workerThreads, out completionPortThreads);ThreadPool.GetMaxThreads(out maxThreadPoolThreads, out maxIOCPThreads);sbInfo.AppendFormat("CPU: {0}, ", cpu < 100 ? cpu : 100);sbInfo.AppendFormat("worker thread: {0}, ", maxThreadPoolThreads - workerThreads);sbInfo.AppendFormat("cpio : {0}, ", maxIOCPThreads - completionPortThreads);sbInfo.AppendFormat("total Threads: {0}, ", totalThreads);sbInfo.AppendFormat("memory(working): {0}MB, ", memory);sbInfo.AppendFormat("memory(private): {0}MB, ", workingSetExecludePrivate);return sbInfo.ToString();}}
}