Kepler-Release/Venus/Venus_RT/Modules/ResourceMonitor.cs

using Aitex.Core.RT.Device.Unit;
using Aitex.Core.RT.Log;
using Aitex.Core.RT.SCCore;
using MECF.Framework.Common.Equipment;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Management;
using System.Reflection;
using System.ServiceModel.Channels;
using System.Text;
using System.Timers;
using System.Windows;

namespace Venus_RT.Modules
{
    public class ResourceMonitor
    {
        private string processRTname = Process.GetCurrentProcess().ProcessName;
        private string processUIname = "Venus_UI";
        private string processSimuname = "Venus_Simulator";
        //private int _stringlen = 20;
        private int threshold = 800;
        private Process pro;
        private Timer _timer;
        //数据波动监测可用
        //List<double> _Numberofhandlesopened = new List<double>() { };
        //List<double> _Numberofmodules = new List<double>() { };
        //List<double> _Basicpriority = new List<double>() { };
        //List<double> _processor = new List<double>() { };
        //List<double> _Minimumworkingset = new List<double>() { };
        //List<double> _MaximumWorkingSet = new List<double>() { };
        //List<double> _Workset = new List<double>() { };
        //List<double> _Peakworkingset = new List<double>() { };
        //List<double> _Dedicatedmemorysize = new List<double>() { };
        //List<double> _UnpagedMemorySize = new List<double>() { };
        //List<double> _PagingMemorySize = new List<double>() { };
        //List<double> _Peakpagingmemorysize = new List<double>() { };
        //List<double> _VirtualMemorySize = new List<double>() { };
        //List<double> _PeakVirtualMemorySize = new List<double>() { };

        //string ProcessName              = string.Empty;
        //string ProcessID                = string.Empty;
        //string Starttime                = string.Empty;
        private string Response                 = string.Empty;
        private string MainWindowHandle         = string.Empty;
        //string MainWindowTitle          = string.Empty;
        private string AssociatedProcessHandle  = string.Empty;
        private string Numberofhandlesopened    = string.Empty;
        private string Numberofmodules          = string.Empty;
        private string Basicpriority            = string.Empty;
        private string Increasepriority         = string.Empty;
        private string processor                = string.Empty;
        private string Minimumworkingset        = string.Empty;
        private string MaximumWorkingSet        = string.Empty;
        private string Workset                  = string.Empty;
        private string Peakworkingset           = string.Empty;
        private string Dedicatedmemorysize      = string.Empty;
        private string UnpagedMemorySize        = string.Empty;
        private string PagingMemorySize         = string.Empty;
        private string Peakpagingmemorysize     = string.Empty;
        private string VirtualMemorySize        = string.Empty;
        private string PeakVirtualMemorySize    = string.Empty;
        private string Occupytime               = string.Empty;
        private string PrivilegeOccupancytime   = string.Empty;
        private string Useroccupiedtime         = string.Empty;
        private PerformanceCounter CpuOccupied;
        public ResourceMonitor() 
        {

            //ProcessName = "进程名称";
            //ProcessID = "进程ID".PadRight(_stringlen - 2, ' ');
            //Starttime = "启动时间";
            Response = "Response or not";
            MainWindowHandle = "Main Window Handle";
            //MainWindowTitle = "主窗口标题";
            AssociatedProcessHandle = "Associated Process Handle ";
            Numberofhandlesopened = "Number of handles opened ";
            Numberofmodules = "Number of modules ";
            Basicpriority = "Basic priority ";
            Increasepriority = "Increase priority ";
            processor = "processor ";
            Minimumworkingset = "Minimum working set ";
            MaximumWorkingSet = "Maximum working Set ";
            Workset = "Work set ";
            Peakworkingset = "Peak working set ";
            Dedicatedmemorysize = "Dedicated memory size ";
            UnpagedMemorySize = "Unpaged Memory Size ";
            PagingMemorySize = "Paging Memory Size ";
            Peakpagingmemorysize = "Peak paging memory size ";
            VirtualMemorySize = "Virtual Memory Size ";
            PeakVirtualMemorySize = "Peak Virtual Memory Size ";
            Occupytime = "Occupy time ";
            PrivilegeOccupancytime = "Privilege Occupancy time ";
            Useroccupiedtime = "User occupied time ";
            
        }

        ~ResourceMonitor() => _timer.Dispose();//定时器销毁

        public bool Initialize()
        {
            //>0 开启否则不开启
            if (SC.GetValue<int>("System.CheckResourceInterval") > 0)
            {
                _timer = new Timer();
                CpuOccupied  = new PerformanceCounter("Processor", "% Processor Time", "_Total");
                _timer.Enabled = true;
                _timer.Interval = SC.GetValue<int>("System.CheckResourceInterval") * 60 * 1000;
                _timer.Elapsed += GetProcessInfo;
                _timer.Start();
                //LOG.Write($"{ProcessName}" +
                //$"{ProcessID}" +
                ////$"{Starttime}"+
                //$"{Response}" +
                //$"{MainWindowHandle}" +
                ////$"{MainWindowTitle}"+
                //$"{AssociatedProcessHandle}" +
                //$"{Numberofhandlesopened}" +
                //$"{Numberofmodules}" +
                //$"{Basicpriority}" +
                //$"{Increasepriority}" +
                //$"{processor}" +
                //$"{Minimumworkingset}" +
                //$"{MaximumWorkingSet}" +
                //$"{Workset}" +
                //$"{Peakworkingset}" +
                //$"{Dedicatedmemorysize}" +
                //$"{UnpagedMemorySize}" +
                //$"{PagingMemorySize}" +
                //$"{Peakpagingmemorysize}" +
                //$"{VirtualMemorySize}" +
                //$"{PeakVirtualMemorySize}" +
                //$"{Occupytime}" +
                //$"{PrivilegeOccupancytime}" +
                //$"{Useroccupiedtime}");
            }
            return true;
        }

        private void GetProcessInfo(object sender, ElapsedEventArgs e)
        {
            try
            {
                string rtmonoitor = process_use(processRTname);
                string uimonoitor = process_use(processUIname); 
                string simumonoitor = process_use(processSimuname); 

                string systemMonitor = $"PC => {drive_use()}" +
                    $"{cpu_use()}" +
                    $"{memory_use()}";

                LOG.Write(eEvent.INFO_WINRESOURCE, ModuleName.System,
                    rtmonoitor +
                    " ".PadLeft(56, ' ') + uimonoitor +
                    " ".PadLeft(56, ' ') + simumonoitor +
                    " ".PadLeft(56, ' ') + systemMonitor 
                );
                //没有就不做任何操作

            }
            catch (Exception ex)
            {
                LOG.Write(eEvent.ERR_WINRESOURCE, ModuleName.System,$"Monitor Error happened: {ex}");
            }
        }

        //process
        private string process_use(string processname)
        {
            string monitor = "";
            //判断是否存在该进程
            //有就开始记录
            if (Process.GetProcessesByName(processname).Length > 0)
            {
                pro = Process.GetProcessesByName(processname)[0];

                //_Numberofhandlesopened.Add(pro.HandleCount);         //进程打开的句柄数
                //_Numberofmodules.Add(pro.Modules.Count);               //模块数量
                //_Basicpriority.Add(pro.BasePriority);                 //基本优先级
                //_processor.Add(pro.ProcessorAffinity.ToInt32());                     //处理器
                //_Minimumworkingset.Add(pro.MinWorkingSet.ToInt32());             //最小工作集
                //_MaximumWorkingSet.Add(pro.MaxWorkingSet.ToInt32());             //最大工作集
                //_Workset.Add(Convert.ToInt32(pro.WorkingSet64));                       //工作集
                //_Peakworkingset.Add(Convert.ToInt32(pro.PeakWorkingSet64));                //峰值工作集
                //_Dedicatedmemorysize.Add(Convert.ToInt32(pro.PrivateMemorySize64 / 1048576));           //专用内存大小
                //_UnpagedMemorySize.Add(Convert.ToInt32(pro.NonpagedSystemMemorySize64 / 1048576));             //未分页内存大小
                //_PagingMemorySize.Add(Convert.ToInt32(pro.PagedMemorySize64 / 1048576));              //分页内存大小
                //_Peakpagingmemorysize.Add(Convert.ToInt32(pro.PeakPagedMemorySize64 / 1048576));          //峰值分页内存大小
                //_VirtualMemorySize.Add(Convert.ToInt32(pro.VirtualMemorySize64 / 1024));             //虚拟内存大小
                //_PeakVirtualMemorySize.Add(Convert.ToInt32(pro.PeakVirtualMemorySize64 / 1048576));         //峰值虚拟内存大小

                monitor = //$"{ProcessName}:{pro.ProcessName}" +
                                   //$"{pro.StartTime.ToLongDateString() + pro.StartTime.ToLongTimeString()}" +
                $"{processname} => {Response}:{pro.Responding.ToString()}\t" +
                $"{MainWindowHandle}:{pro.MainWindowHandle.ToString()}\t" +
                //$"{pro.MainWindowTitle}" +
                $"{AssociatedProcessHandle}:{pro.Handle.ToString()}\t" +
                $"{Numberofhandlesopened}:{pro.HandleCount.ToString()}\t" +
                $"{Numberofmodules}:{pro.Modules.Count.ToString()}\t" +
                $"{Basicpriority}:{pro.BasePriority.ToString()} \t" +
                $"{Increasepriority}:{pro.PriorityBoostEnabled.ToString()}\t" +
                $"{processor}:{pro.ProcessorAffinity.ToInt32().ToString()}\t" +
                //$"{Minimumworkingset}:{pro.MinWorkingSet.ToInt32().ToString()}\t" +
                $"{MaximumWorkingSet}:{pro.MaxWorkingSet.ToInt32().ToString()}\t" +
                $"{Workset}:{pro.WorkingSet64.ToString()}\t" +
                $"{Peakworkingset}:{pro.PeakWorkingSet64.ToString()}\t" +
                $"{Dedicatedmemorysize}:{(pro.PrivateMemorySize64 / 1048576).ToString()}MB\t" +
                $"{UnpagedMemorySize}:{(pro.NonpagedSystemMemorySize64 / 1048576).ToString()}MB\t" +
                $"{PagingMemorySize}:{(pro.PagedMemorySize64 / 1048576).ToString()}MB\t" +
                $"{Peakpagingmemorysize}:{(pro.PeakPagedMemorySize64 / 1048576).ToString()}MB\t" +
                $"{VirtualMemorySize}:{(pro.VirtualMemorySize64 / 1048576).ToString()}MB\t" +
                $"{PeakVirtualMemorySize}:{(pro.PeakVirtualMemorySize64 / 1048576).ToString()}MB\t" +
                $"{Occupytime}:{pro.TotalProcessorTime.ToString()}\t" +
                $"{PrivilegeOccupancytime}:{pro.PrivilegedProcessorTime.ToString()}\t" +
                $"{Useroccupiedtime}:{pro.UserProcessorTime.ToString()}\r\n";

                //如果虚拟内存大于800MB 即报警
                if (pro.PagedMemorySize64 / 1048576 >= threshold)
                {
                    LOG.Write(eEvent.WARN_WINRESOURCE, ModuleName.System, $"警告！进程 {processname} 内存异常增长，超过{threshold}MB阈值！");
                }
            }
            return monitor;
        }

        //CPU
        private string cpu_use()
        {

            float cpu_use_per = CpuOccupied.NextValue();
            string cpu_use = $"CPU usage rate:{cpu_use_per:F2}%\t";
            return cpu_use;
        }
        
        //disk
        private string drive_use()
        {
            string drive_use = "";
            foreach (DriveInfo drive in DriveInfo.GetDrives())
            {
                if (drive.IsReady)
                {
                    drive_use += $"{drive.Name}";
                    drive_use += $" Total:{drive.TotalSize / 1024 / 1024 }MB";
                    drive_use += $" Used:{(drive.TotalSize - drive.AvailableFreeSpace) / 1024 / 1024 }MB";
                    drive_use += $" Free:{drive.AvailableFreeSpace / 1024 / 1024 }MB\t";
                }
            }
            return drive_use;
        }
        //memory
        private string memory_use()
        {
            string memory_use = "Memory status:" +
                $"Memory Available:{GetMemoryAvailable():F2}GB\t" +
                $"Memory Used:{GetMemoryUsed():F2}GB\t" +
                $"Memory Used Rate:{GetMemoryUsedRate():F2}%\t";
            return memory_use;
        }

        //MemoryAvailable
        private double? GetMemoryAvailable()
        {

            double availablebytes = 0;
            var managementClassOs = new ManagementClass("Win32_OperatingSystem");
            foreach (var managementBaseObject in managementClassOs.GetInstances())
                if (managementBaseObject["FreePhysicalMemory"] != null)
                    availablebytes = 1024 * double.Parse(managementBaseObject["FreePhysicalMemory"].ToString());
            return availablebytes / GbDiv;

        }
        //MemoryUsed
        private double? GetMemoryUsed()
        {
            double? PhysicalMemory = GetPhysicalMemory();
            double? MemoryAvailable = GetMemoryAvailable();
            double? MemoryUsed = (double?)(PhysicalMemory - MemoryAvailable);
            double currentMemoryUsed = (double)MemoryUsed;
            return currentMemoryUsed;
        }
        //PhysicalMemory
        private long? GetPhysicalMemory()
        {
            //获得物理内存
            var managementClass = new ManagementClass("Win32_ComputerSystem");
            var managementObjectCollection = managementClass.GetInstances();
            //long PhysicalMemory;
            foreach (var managementBaseObject in managementObjectCollection)
                if (managementBaseObject["TotalPhysicalMemory"] != null)
                {
                    return long.Parse(managementBaseObject["TotalPhysicalMemory"].ToString()) / GbDiv;
                }
            return null;

        }
        //MemoryUsedRate
        private double? GetMemoryUsedRate()
        {
            double? PhysicalMemory = GetPhysicalMemory();
            double? MemoryAvailable = GetMemoryAvailable();
            double? MemoryUsedRate = (double?)(PhysicalMemory - MemoryAvailable) / PhysicalMemory;
            return MemoryUsedRate.HasValue ? Convert.ToDouble(MemoryUsedRate * 100) : 0;
        }

        
        #region 单位转换进制

        private const int KbDiv = 1024;
        private const int MbDiv = 1024 * 1024;
        private const int GbDiv = 1024 * 1024 * 1024;

        #endregion
    }
}