何为心跳监控系统?

故名思义,就是监控某个或某些个程序的运行状态,就好比医院里面的心跳监视仪一样,能够随时显示病人的心跳情况。

心跳监控的目的是什么?

与医院里面的心跳监视仪目的类似,监控程序运行状态,一旦出现问题(比如:一些自动运行的服务、程序等突然停止运行了),那么心跳监控系统就能“感知到”并及时的显示在监控界面上,同时可以通过微信、短信告之相关的人员,以便他们及时处理程序异常,从而避免一些自动运行的服务、程序等突然停止运行而造成的一系列损失

心跳监控系统实现的思路是怎样的?

核心技术:WCF的双工通讯

实现步骤:

1.定义WCF的服务契约接口以及回调接口,服务方法主要包括:Start(被监控的程序启动时调用,即通知监控系统,我已经启动了)、Stop(被监控的程序停止时调用,即通知监控系统,我已经停止了)、ReportRunning(被监控的程序运行中定时调用,即通知监控系统,我是正常的并在运行中,同时还起到检测监控系统是否在运行的一个功能,一举两得),回调服务方法应有:Listen(这个是给监控系统主动去定时回调被监控的程序(心跳),如果被监控的程序能正常的返回状态,那么就是正常的,否则有可能已经“死了”,这时监控系统就需要按照预设指令作出相应的操作,比如:监控主界面显示异常的程序,同时发送异常通知消息给相关人员)

2.建立一个心跳监控系统Winform项目,并实现WCF服务,即集成实现WCF服务宿主程序,同时每一个WCF服务方法均需关联界面,即:程序启动了、停止了、运行中均会在界面实时显示出来或做一些实时统计;

3.其它被监控的程序(指自动运行的服务、程序等)需要集成实现WCF回调接口及开启WCF服务通讯的功能;

心跳监控系统的运行顺序是怎样的?如何保证监控方与被监控方实时不间断通讯?

运行顺序:

1.开启心跳监控系统(即:同时开启WCF服务宿主程序),确保监控服务正常运行;

2.开启其它被监控的程序,确保开启客户端与监控系统的WCF双工通讯服务正常;

注意:一定要先开启心跳监控系统,否则其它被监控的程序因无法与监控系统的WCF双工通讯服务正常连接而报错或多次尝试重连;

保证监控方与被监控方实时不间断通讯:

在保证按照上面所说的运行顺序依次开启心跳监控系统,再开启其它被监控的程序,正常建立一次通讯后,后续只要任何一方出现通讯中断,均会自动尝试重连(主要是客户端重连,心跳监控系统除非停止运行,否则不会中断,若因停止运行造成双方通讯中断,只需重启心跳监控系统即可)

通讯模式:

推模式:被监控的程序通过主动的调用WCF服务方法:Start、Stop、ReportRunning 向心跳监控系统告之运行状态,若通讯失败,则自动尝试重连,直至连接成功;

拉模式:心跳监控系统主动回调Listen方法,向被监控的程序索取运行状态,若通讯失败,则会在指定时间内多次重试回调客户端,若客户端在规定的时间范围内仍无法返回消息,则视为客户端异常,那么心跳监控系统则会进行异常的处理;

实现源代码:

ProgramMonitor.Core 类库项目:主要是定义WCF服务的相关接口以及实现回调的接口(因为每个客户端都需实现一遍回调接口,故统一实现,客户端集成后直接可以用,简化集成客户端的开发成本),心跳监控系统及需要被监控的程序均需要依赖该DLL;

ProgramMonitor WINFORM项目:心跳监控系统

整个解决方案如下图示:

注:由于源代码相对较多,故不再一一说明,只对重点的代码作解释

ProgramMonitor.Core

IListenService:(心跳监控WCF服务契约接口)

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.ServiceModel;namespace ProgramMonitor.Core
{[ServiceContract(Namespace = "http://www.zuowenjun.cn", SessionMode = SessionMode.Required, CallbackContract = typeof(IListenCall))]public interface IListenService{[OperationContract(IsOneWay = true)]void Start(ProgramInfo programInfo);[OperationContract(IsOneWay = true)]void Stop(string programId);[OperationContract(IsOneWay = true)]void ReportRunning(ProgramInfo programInfo);}
}

IListenCall:(监听回调服务接口,主用被心跳监控系统调用)

using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.Text;namespace ProgramMonitor.Core
{public interface IListenCall{[OperationContract]int Listen(string programId);}
}

ProgramInfo:(程序信息类,主要用于获取被监控程序的基本信息)

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.ServiceModel;
using System.Runtime.Serialization;namespace ProgramMonitor.Core
{[DataContract(Namespace = "http://www.zuowenjun.cn")]public class ProgramInfo{public ProgramInfo(){}[DataMember]public string Id { get; internal set; }[DataMember]public string Name { get; set; }[DataMember]public string Version { get; set; }[DataMember]public string InstalledLocation { get; set; }[DataMember]public string Description { get; set; }private int runState = -1;/// <summary>/// 运行状态,-1:表示停止,0表示启动,1表示运行中/// </summary>[DataMember]public int RunState{get{return runState;}set{this.UpdateStateTime = DateTime.Now;if (value < 0){runState = -1;this.StopTime = this.UpdateStateTime;}else if (value == 0){runState = 0;this.StartTime = this.UpdateStateTime;}else{runState = 1;}}}[DataMember]public DateTime UpdateStateTime { get; private set; }[DataMember]public DateTime StartTime { get; private set; }[DataMember]public DateTime StopTime { get; private set; }}
}

ListenClient:(监听客户端类,实现WCF回调服务接口,主要用于被监控的程序)

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Security.Cryptography;
using System.ServiceModel;
using System.ServiceModel.Description;
using System.Text;namespace ProgramMonitor.Core
{public class ListenClient : IListenCall{private static object syncObject = new object();private static ListenClient instance = null;private ProgramInfo programInfo = null;private string serviceHostAddr = null;private int autoReportRunningInterval = 300;private DuplexChannelFactory<IListenService> listenServiceFactory = null;private IListenService proxyListenService = null;private System.Timers.Timer reportRunningTimer = null;private ListenClient(ProgramInfo programInfo, string serviceHostAddr = null, int autoReportRunningInterval = 300){programInfo.Id = CreateProgramId();this.programInfo = programInfo;this.serviceHostAddr = serviceHostAddr;if (autoReportRunningInterval >= 60) //最低1分钟的间隔{this.autoReportRunningInterval = autoReportRunningInterval;}BuildAutoReportRunningTimer();}private void BuildAutoReportRunningTimer(){reportRunningTimer = new System.Timers.Timer(autoReportRunningInterval * 1000);reportRunningTimer.Elapsed += (s, e) =>{ReportRunning();};}private void BuildListenClientService(){if (listenServiceFactory == null){if (string.IsNullOrEmpty(serviceHostAddr)){serviceHostAddr = System.Configuration.ConfigurationManager.AppSettings["ServiceHostAddr"];}InstanceContext instanceContext = new InstanceContext(instance);NetTcpBinding binding = new NetTcpBinding();binding.ReceiveTimeout = new TimeSpan(0, 5, 0);binding.SendTimeout = new TimeSpan(0, 5, 0);Uri baseAddress = new Uri(string.Format("net.tcp://{0}/ListenService", serviceHostAddr));listenServiceFactory = new DuplexChannelFactory<IListenService>(instanceContext, binding, new EndpointAddress(baseAddress));}proxyListenService = listenServiceFactory.CreateChannel();}public static ListenClient GetInstance(ProgramInfo programInfo, string serviceHostAddr = null, int autoReportRunningInterval = 300){if (instance == null){lock (syncObject){if (instance == null){instance = new ListenClient(programInfo, serviceHostAddr, autoReportRunningInterval);instance.BuildListenClientService();}}}return instance;}public void ReportStart(){proxyListenService.Start(programInfo);reportRunningTimer.Start();}public void ReportStop(){proxyListenService.Stop(programInfo.Id);reportRunningTimer.Stop();}public void ReportRunning(){try{proxyListenService.ReportRunning(programInfo);}catch{BuildListenClientService();}}int IListenCall.Listen(string programId){if (programInfo.Id.Equals(programId, StringComparison.OrdinalIgnoreCase)){if (programInfo.RunState >= 0){return 1;}}return -1;}private string CreateProgramId(){Process currProcess = Process.GetCurrentProcess();int procCount = Process.GetProcessesByName(currProcess.ProcessName).Length;string currentProgramPath = currProcess.MainModule.FileName;return GetMD5HashFromFile(currentProgramPath) + "_" + procCount;}private string GetMD5HashFromFile(string fileName){try{byte[] hashData = null;using (FileStream fs = new FileStream(fileName, System.IO.FileMode.Open, FileAccess.Read)){MD5 md5 = new MD5CryptoServiceProvider();hashData = md5.ComputeHash(fs);fs.Close();}StringBuilder sb = new StringBuilder();for (int i = 0; i < hashData.Length; i++){sb.Append(hashData[i].ToString("x2"));}return sb.ToString();}catch (Exception ex){throw new Exception("GetMD5HashFromFile Error:" + ex.Message);}}}}

这里特别说一下:CreateProgramId方法,因为心跳监控系统主要是依据ProgramId来识别每个不同的程序,故ProgramId非常重要,而我这里采用的是文件的 MD5值+进程数作为ProgramId,有些人可能要问,为什么要加进程数呢?原因很简单,因为有些程序是允许开启多个的实例的,如果不加进程数,那么心跳监控系统就无法识别多个同一个程序到底是哪个。

ProgramMonitor

ListenService:(WCF心跳监控服务接口实现类)

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using ProgramMonitor.Core;
using System.ServiceModel;namespace ProgramMonitor.Service
{[ServiceBehavior(ConcurrencyMode = ConcurrencyMode.Reentrant, InstanceContextMode = InstanceContextMode.PerCall)]public class ListenService : IListenService{public void Start(ProgramInfo programInfo){var listenCall = OperationContext.Current.GetCallbackChannel<IListenCall>();Common.SaveProgramStartInfo(programInfo, listenCall);}public void Stop(string programId){Common.SaveProgramStopInfo(programId);}public void ReportRunning(ProgramInfo programInfo){var listenCall = OperationContext.Current.GetCallbackChannel<IListenCall>();Common.SaveProgramRunningInfo(programInfo, listenCall);}}
}

Common:(通用业务逻辑类,主要用于WCF与UI实时沟通与联动)

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using ProgramMonitor.Core;
using System.Collections.Concurrent;
using System.Timers;
using System.Threading;
using Timer = System.Timers.Timer;
using ProgramMonitor.Service;
using System.Data.SqlClient;
using log4net;namespace ProgramMonitor
{public static class Common{public static ConcurrentDictionary<string, ProgramInfo> ProgramInfos = null;public static ConcurrentDictionary<string, IListenCall> ListenCalls = null;public static ConcurrentBag<string> ManualStopProgramIds = null;public static System.Timers.Timer loadTimer = null;public static Timer listenTimer = null;public static SynchronizationContext SyncContext = null;public static Action<ProgramInfo, bool> RefreshListView;public static Action<ProgramInfo, bool> RefreshTabControl;public static int ClearInterval = 5;public static int ListenInterval = 2;public static bool Listening = false;public static string DbConnString = null;public static string[] NoticePhoneNos = null;public static string NoticeWxUserIds = null;public static ILog Logger = LogManager.GetLogger("ProgramMonitor");public const string SqlProviderName = "System.Data.SqlClient";public static void SaveProgramStartInfo(ProgramInfo programInfo, IListenCall listenCall){programInfo.RunState = 0;ProgramInfos.AddOrUpdate(programInfo.Id, programInfo, (key, value) => programInfo);ListenCalls.AddOrUpdate(programInfo.Id, listenCall, (key, value) => listenCall);RefreshListView(programInfo, false);RefreshTabControl(programInfo, true);WriteLog(string.Format("程序名:{0},版本:{1},已启动运行", programInfo.Name, programInfo.Version), false);}public static void SaveProgramStopInfo(string programId){ProgramInfo programInfo;if (ProgramInfos.TryGetValue(programId, out programInfo)){programInfo.RunState = -1;RefreshListView(programInfo, false);IListenCall listenCall = null;ListenCalls.TryRemove(programId, out listenCall);RefreshTabControl(programInfo, true);}WriteLog(string.Format("程序名:{0},版本:{1},已停止运行", programInfo.Name, programInfo.Version), false);}public static void SaveProgramRunningInfo(ProgramInfo programInfo, IListenCall listenCall){if (!ProgramInfos.ContainsKey(programInfo.Id) || !ListenCalls.ContainsKey(programInfo.Id)){SaveProgramStartInfo(programInfo, listenCall);}programInfo.RunState = 1;RefreshTabControl(programInfo, true);WriteLog(string.Format("程序名:{0},版本:{1},正在运行中", programInfo.Name, programInfo.Version), false);}public static void AutoLoadProgramInfos(){if (loadTimer == null){loadTimer = new Timer(1 * 60 * 1000);loadTimer.Elapsed += delegate(object sender, ElapsedEventArgs e){var timer = sender as Timer;try{timer.Stop();foreach (var item in ProgramInfos){var programInfo = item.Value;RefreshListView(programInfo, false);}}finally{if (Listening){timer.Start();}}};}else{loadTimer.Interval = 1 * 60 * 1000;}loadTimer.Start();}public static void AutoListenPrograms(){if (listenTimer == null){listenTimer = new Timer(ListenInterval * 60 * 1000);listenTimer.Elapsed += delegate(object sender, ElapsedEventArgs e){var timer = sender as Timer;try{timer.Stop();foreach (var item in ListenCalls){bool needUpdateStatInfo = false;var listenCall = item.Value;var programInfo = ProgramInfos[item.Key];int oldRunState = programInfo.RunState;try{programInfo.RunState = listenCall.Listen(programInfo.Id);}catch{if (programInfo.RunState != -1){programInfo.RunState = -1;needUpdateStatInfo = true;}}if (programInfo.RunState == -1 && programInfo.StopTime.AddMinutes(5) < DateTime.Now) //如果停了5分钟,则发一次短信{SendNoticeSms(programInfo);SendNoticeWeiXin(programInfo);programInfo.RunState = -1;//重新刷新状态}if (oldRunState != programInfo.RunState){needUpdateStatInfo = true;WriteLog(string.Format("程序名:{0},版本:{1},运行状态变更为:{2}", programInfo.Name, programInfo.Version,programInfo.RunState), false);}RefreshTabControl(programInfo, needUpdateStatInfo);}}finally{if (Listening){timer.Start();}}};}else{listenTimer.Interval = ListenInterval * 60 * 1000;}listenTimer.Start();}public static void SendNoticeSms(ProgramInfo programInfo){if (NoticePhoneNos == null || NoticePhoneNos.Length <= 0) return;using (DataAccess da = new DataAccess(Common.DbConnString, Common.SqlProviderName)){da.UseTransaction();foreach (string phoneNo in NoticePhoneNos){var parameters = da.ParameterHelper.AddParameter("@Mbno", phoneNo).AddParameter("@Msg", string.Format("程序名:{0},版本:{1},安装路径:{2},已停止运行了,请尽快处理!",programInfo.Name, programInfo.Version, programInfo.InstalledLocation)).AddParameter("@SendTime", DateTime.Now).AddParameter("@KndType", "监控异常通知").ToParameterArray();da.ExecuteCommand("insert into OutBox(Mbno,Msg,SendTime,KndType) values(@Mbno,@Msg,@SendTime,@KndType)", paramObjs: parameters);}da.Commit();WriteLog(string.Format("程序名:{0},版本:{1},已停止运行超过5分钟,成功发送短信通知到:{2}",programInfo.Name, programInfo.Version, string.Join(",", NoticePhoneNos)), false);}}public static void SendNoticeWeiXin(ProgramInfo programInfo){if (string.IsNullOrEmpty(NoticeWxUserIds)) return;string msg = string.Format("程序名:{0},版本:{1},安装路径:{2},已停止运行了,请尽快处理!",programInfo.Name, programInfo.Version, programInfo.InstalledLocation);var wx = new WeChat();var result = wx.SendMessage(NoticeWxUserIds, msg);if (result["errmsg"].ToString().Equals("ok", StringComparison.OrdinalIgnoreCase)){WriteLog(string.Format("程序名:{0},版本:{1},已停止运行超过5分钟,成功发送微信通知到:{2}", programInfo.Name, programInfo.Version,NoticeWxUserIds), false);}}public static void BuildConnectionString(string server, string db, string uid, string pwd){SqlConnectionStringBuilder connStrBuilder = new SqlConnectionStringBuilder();connStrBuilder.DataSource = server;connStrBuilder.InitialCatalog = db;connStrBuilder.UserID = uid;connStrBuilder.Password = pwd;connStrBuilder.IntegratedSecurity = false;connStrBuilder.ConnectTimeout = 15;DbConnString = connStrBuilder.ToString();}public static void WriteLog(string msg, bool isError = false){if (isError){Logger.Error(msg);}else{Logger.Info(msg);}}}
}

FrmMain:(心跳监控系统窗体类)

using ProgramMonitor.Core;
using ProgramMonitor.Service;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.ServiceModel;
using System.ServiceModel.Description;
using System.Text;
using System.Threading;
using System.Windows.Forms;namespace ProgramMonitor
{public partial class FrmMain : Form{private ServiceHost serviceHost = null;public FrmMain(){InitializeComponent();tabControl1.SizeMode = TabSizeMode.Fixed;tabControl1.ItemSize = new Size(0, 1);#if (DEBUG)btnTestSend.Visible = true;
#elsebtnTestSend.Visible = false;
#endifCommon.SyncContext = SynchronizationContext.Current;Common.ProgramInfos = new ConcurrentDictionary<string, ProgramInfo>();Common.ListenCalls = new ConcurrentDictionary<string, IListenCall>();Common.ManualStopProgramIds = new ConcurrentBag<string>();Common.RefreshListView = RefreshListView;Common.RefreshTabControl = RefreshTabControl;}#region 自定义方法区域private void RefreshListView(ProgramInfo programInfo, bool needUpdateStatInfo){Common.SyncContext.Post(o =>{string listViewItemKey = string.Format("lvItem_{0}", programInfo.Id);if (!listView1.Items.ContainsKey(listViewItemKey)){var lstItem = listView1.Items.Add(listViewItemKey, programInfo.Name, 0);lstItem.Name = listViewItemKey;lstItem.Tag = programInfo.Id;lstItem.SubItems.Add(programInfo.Version);lstItem.SubItems.Add(programInfo.InstalledLocation);lstItem.ToolTipText = programInfo.Description;if (needUpdateStatInfo){UpdateProgramListenStatInfo();}}else{if (!Common.ListenCalls.ContainsKey(programInfo.Id) && programInfo.RunState == -1 && Common.ClearInterval > 0&& programInfo.StopTime.AddMinutes(Common.ClearInterval) < DateTime.Now) //当属于正常关闭的程序在指定时间后从监控列表中移除{RemoveListenItem(programInfo.Id);}}}, null);}private void RefreshTabControl(ProgramInfo programInfo, bool needUpdateStatInfo){Common.SyncContext.Post(o =>{string tabPgName = string.Format("tabpg_{0}", programInfo.Id);string msgCtrlName = string.Format("{0}_MsgText", tabPgName);if (!tabControl1.TabPages.ContainsKey(tabPgName)){RichTextBox rchTextBox = new RichTextBox();rchTextBox.Name = msgCtrlName;rchTextBox.Dock = DockStyle.Fill;rchTextBox.ReadOnly = true;AppendTextToRichTextBox(rchTextBox, programInfo);var tabPg = new TabPage();tabPg.Name = tabPgName;tabPg.Controls.Add(rchTextBox);tabControl1.TabPages.Add(tabPg);}else{var tabPg = tabControl1.TabPages[tabPgName];var rchTextBox = tabPg.Controls[msgCtrlName] as RichTextBox;AppendTextToRichTextBox(rchTextBox, programInfo);}if (needUpdateStatInfo){UpdateProgramListenStatInfo();}}, null);}private void UpdateProgramListenStatInfo(){int runCount = Common.ProgramInfos.Count(p => p.Value.RunState >= 0);labRunCount.Text = string.Format("{0}个", runCount);labStopCount.Text = string.Format("{0}个", Common.ProgramInfos.Count - runCount);foreach (ListViewItem lstItem in listView1.Items){string programId = lstItem.Tag.ToString();if (Common.ProgramInfos[programId].RunState == -1){lstItem.ForeColor = Color.Red;}else{lstItem.ForeColor = Color.Black;}}}private void RemoveListenItem(string programInfoId){ProgramInfo programInfo = Common.ProgramInfos[programInfoId];listView1.Items.RemoveByKey(string.Format("lvItem_{0}", programInfo.Id));tabControl1.TabPages.RemoveByKey(string.Format("tabpg_{0}", programInfo.Id));Common.ProgramInfos.TryRemove(programInfo.Id, out programInfo);IListenCall listenCall = null;Common.ListenCalls.TryRemove(programInfoId, out listenCall);UpdateProgramListenStatInfo();}private void AppendTextToRichTextBox(RichTextBox rchTextBox, Core.ProgramInfo programInfo){Color msgColor = Color.Black;string lineMsg = string.Format("{0:yyyy-MM-dd HH:mm}\t{1}({2})\t{3} \n", DateTime.Now, programInfo.Name, programInfo.Version, GetRunStateString(programInfo.RunState, out msgColor));rchTextBox.SelectionColor = msgColor;rchTextBox.SelectionStart = rchTextBox.Text.Length;rchTextBox.AppendText(lineMsg);rchTextBox.SelectionLength = rchTextBox.Text.Length;if(rchTextBox.Lines.Length>1000){}}private string GetRunStateString(int runState, out Color msgColor){if (runState < 0){msgColor = Color.Red;return "程序已停止运行";}else if (runState == 0){msgColor = Color.Blue;return "程序已启动运行";}else{msgColor = Color.Black;return "程序已在运行中";}}private void StartListenService(){if (serviceHost == null){string serviceHostAddr = System.Configuration.ConfigurationManager.AppSettings["ServiceHostAddr"];string serviceMetaHostAddr = System.Configuration.ConfigurationManager.AppSettings["ServiceMetaHostAddr"];serviceHost = new ServiceHost(typeof(ListenService));NetTcpBinding binding = new NetTcpBinding();binding.ReceiveTimeout = new TimeSpan(0, 5, 0);binding.SendTimeout = new TimeSpan(0, 5, 0);serviceHost.AddServiceEndpoint(typeof(IListenService), binding, string.Format("net.tcp://{0}/ListenService", serviceHostAddr));if (serviceHost.Description.Behaviors.Find<ServiceMetadataBehavior>() == null){ServiceMetadataBehavior behavior = new ServiceMetadataBehavior();behavior.HttpGetEnabled = true;behavior.HttpGetUrl = new Uri(string.Format("http://{0}/ListenService/metadata", serviceMetaHostAddr));serviceHost.Description.Behaviors.Add(behavior);}serviceHost.Opened += (s, arg) =>{SetUIStyle("S");Common.Listening = true;Common.AutoLoadProgramInfos();Common.AutoListenPrograms();};serviceHost.Closed += (s, arg) =>{SetUIStyle("C");Common.loadTimer.Stop();Common.listenTimer.Stop();Common.Listening = false;};}serviceHost.Open();}private void StopListenService(){try{if (serviceHost != null && serviceHost.State != CommunicationState.Closed){serviceHost.Close();}serviceHost = null;}catch{ }}private void SetUIStyle(string state){if (state == "S"){labSericeState.BackColor = Color.Green;txtRefreshInterval.Enabled = false;txtListenInterval.Enabled = false;btnExec.Tag = "C";btnExec.Text = "停止监控";panel1.Enabled = false;panel2.Enabled = false;}else{labSericeState.BackColor = Color.Red;txtRefreshInterval.Enabled = true;txtListenInterval.Enabled = true;btnExec.Tag = "S";btnExec.Text = "开启监控";panel1.Enabled = true;panel2.Enabled = true;}}private void InitListViewStyle(){ImageList imgList = new ImageList();imgList.ImageSize = new Size(32, 32);imgList.Images.Add(Properties.Resources.monitor);listView1.SmallImageList = imgList;listView1.LargeImageList = imgList;listView1.View = View.Details;listView1.GridLines = false;listView1.FullRowSelect = true;listView1.Columns.Add("程序名称", -2);listView1.Columns.Add("版本");listView1.Columns.Add("运行路径");int avgWidth = listView1.Width / 3;}private void InitNoticeSetting(){if (chkSendSms.Checked){bool dbConnected = false;Common.BuildConnectionString(txtServer.Text, txtDb.Text, txtUID.Text, txtPwd.Text);using (var da = new DataAccess(Common.DbConnString, Common.SqlProviderName)){try{da.ExecuteScalar<DateTime>("select getdate()");dbConnected = true;}catch (Exception ex){MessageBox.Show("数据库测试连接失败,原因:" + ex.Message);}}if (dbConnected){if (txtPhoneNos.Text.Trim().IndexOf(",") >= 0){Common.NoticePhoneNos = txtPhoneNos.Text.Trim().Split(new[] { "," }, StringSplitOptions.RemoveEmptyEntries);}else{Common.NoticePhoneNos = new[] { txtPhoneNos.Text.Trim() };}}}else{Common.NoticePhoneNos = null;}if (chkSendWx.Checked){Common.NoticeWxUserIds = txtWxUIDs.Text.Trim();}else{Common.NoticeWxUserIds = null;}}private bool IsRightClickSelectedItem(Point point){foreach (ListViewItem item in listView1.SelectedItems){if (item.Bounds.Contains(point)){return true;}}return false;}#endregionprivate void btnExec_Click(object sender, EventArgs e){string state = (btnExec.Tag ?? "S").ToString();if (state == "S"){InitNoticeSetting();Common.ClearInterval = int.Parse(txtRefreshInterval.Text);Common.ListenInterval = int.Parse(txtListenInterval.Text);StartListenService();}else{StopListenService();}}private void listView1_SelectedIndexChanged(object sender, EventArgs e){if (listView1.SelectedItems.Count <= 0) return;string programId = listView1.SelectedItems[0].Tag.ToString();string tabPgName = string.Format("tabpg_{0}", programId);if (tabControl1.TabPages.ContainsKey(tabPgName)){tabControl1.SelectedTab = tabControl1.TabPages[tabPgName];}else{MessageBox.Show("未找到相应的程序监控记录!");listView1.SelectedItems[0].ForeColor = Color.Red;}}private void FrmMain_Load(object sender, EventArgs e){InitListViewStyle();}private void FrmMain_FormClosing(object sender, FormClosingEventArgs e){if (MessageBox.Show("您确定要退出吗?退出后将无法正常监控各程序的运行状况", "退出提示", MessageBoxButtons.OKCancel, MessageBoxIcon.Question) == DialogResult.Cancel){e.Cancel = true;return;}StopListenService();}private void btnTestSend_Click(object sender, EventArgs e){var wx = new WeChat();var msg = wx.SendMessage("kyezuo", "测试消息,有程序停止运行了,赶紧处理!");MessageBox.Show(msg["errmsg"].ToString());}private void listView1_MouseUp(object sender, MouseEventArgs e){if (e.Button == MouseButtons.Right && IsRightClickSelectedItem(e.Location)){ctxMuPop.Show(listView1, e.Location);}}private void removeToolStripMenuItem_Click(object sender, EventArgs e){if (listView1.SelectedItems.Count <= 0) return;string programId = listView1.SelectedItems[0].Tag.ToString();if (Common.ProgramInfos[programId].RunState != -1){MessageBox.Show("只有被监控的程序处于已停止状态的监控项才能移除,除外情况请务必保持正常!");return;}RemoveListenItem(programId);}}
}

窗体类中主要是用到了几个更新UI上控件信息的方法以及开启、关闭WCF服务的方法,很简单,一看就明白,无需多讲。

FrmMain.Designer.cs:(Form窗体设计类,系统自动生成的,再此贴出是便于大家可以直接COPY到自己的代码中直接用)

namespace ProgramMonitor
{partial class FrmMain{/// <summary>/// 必需的设计器变量。/// </summary>private System.ComponentModel.IContainer components = null;/// <summary>/// 清理所有正在使用的资源。/// </summary>/// <param name="disposing">如果应释放托管资源,为 true;否则为 false。</param>protected override void Dispose(bool disposing){if (disposing && (components != null)){components.Dispose();}base.Dispose(disposing);}#region Windows 窗体设计器生成的代码/// <summary>/// 设计器支持所需的方法 - 不要/// 使用代码编辑器修改此方法的内容。/// </summary>private void InitializeComponent(){this.components = new System.ComponentModel.Container();this.tableLayoutPanel1 = new System.Windows.Forms.TableLayoutPanel();this.splitContainer1 = new System.Windows.Forms.SplitContainer();this.listView1 = new System.Windows.Forms.ListView();this.tabControl1 = new System.Windows.Forms.TabControl();this.tabControl2 = new System.Windows.Forms.TabControl();this.tabPage1 = new System.Windows.Forms.TabPage();this.groupBox1 = new System.Windows.Forms.GroupBox();this.btnTestSend = new System.Windows.Forms.Button();this.labSericeState = new System.Windows.Forms.Label();this.btnExec = new System.Windows.Forms.Button();this.txtListenInterval = new System.Windows.Forms.TextBox();this.txtRefreshInterval = new System.Windows.Forms.TextBox();this.labStopCount = new System.Windows.Forms.Label();this.labRunCount = new System.Windows.Forms.Label();this.label4 = new System.Windows.Forms.Label();this.label3 = new System.Windows.Forms.Label();this.label2 = new System.Windows.Forms.Label();this.label1 = new System.Windows.Forms.Label();this.tabPage2 = new System.Windows.Forms.TabPage();this.labLine = new System.Windows.Forms.Label();this.panel1 = new System.Windows.Forms.Panel();this.txtPwd = new System.Windows.Forms.TextBox();this.txtUID = new System.Windows.Forms.TextBox();this.txtDb = new System.Windows.Forms.TextBox();this.txtServer = new System.Windows.Forms.TextBox();this.label8 = new System.Windows.Forms.Label();this.label9 = new System.Windows.Forms.Label();this.txtPhoneNos = new System.Windows.Forms.TextBox();this.label7 = new System.Windows.Forms.Label();this.label6 = new System.Windows.Forms.Label();this.label5 = new System.Windows.Forms.Label();this.chkSendSms = new System.Windows.Forms.CheckBox();this.panel2 = new System.Windows.Forms.Panel();this.txtWxUIDs = new System.Windows.Forms.TextBox();this.chkSendWx = new System.Windows.Forms.CheckBox();this.label10 = new System.Windows.Forms.Label();this.ctxMuPop = new System.Windows.Forms.ContextMenuStrip(this.components);this.removeToolStripMenuItem = new System.Windows.Forms.ToolStripMenuItem();this.tableLayoutPanel1.SuspendLayout();((System.ComponentModel.ISupportInitialize)(this.splitContainer1)).BeginInit();this.splitContainer1.Panel1.SuspendLayout();this.splitContainer1.Panel2.SuspendLayout();this.splitContainer1.SuspendLayout();this.tabControl2.SuspendLayout();this.tabPage1.SuspendLayout();this.groupBox1.SuspendLayout();this.tabPage2.SuspendLayout();this.panel1.SuspendLayout();this.panel2.SuspendLayout();this.ctxMuPop.SuspendLayout();this.SuspendLayout();// // tableLayoutPanel1// this.tableLayoutPanel1.ColumnCount = 1;this.tableLayoutPanel1.ColumnStyles.Add(new System.Windows.Forms.ColumnStyle(System.Windows.Forms.SizeType.Percent, 100F));this.tableLayoutPanel1.Controls.Add(this.splitContainer1, 0, 1);this.tableLayoutPanel1.Controls.Add(this.tabControl2, 0, 0);this.tableLayoutPanel1.Dock = System.Windows.Forms.DockStyle.Fill;this.tableLayoutPanel1.Location = new System.Drawing.Point(0, 0);this.tableLayoutPanel1.Name = "tableLayoutPanel1";this.tableLayoutPanel1.RowCount = 2;this.tableLayoutPanel1.RowStyles.Add(new System.Windows.Forms.RowStyle(System.Windows.Forms.SizeType.Absolute, 150F));this.tableLayoutPanel1.RowStyles.Add(new System.Windows.Forms.RowStyle());this.tableLayoutPanel1.Size = new System.Drawing.Size(1039, 722);this.tableLayoutPanel1.TabIndex = 0;// // splitContainer1// this.splitContainer1.Dock = System.Windows.Forms.DockStyle.Fill;this.splitContainer1.FixedPanel = System.Windows.Forms.FixedPanel.Panel1;this.splitContainer1.Location = new System.Drawing.Point(3, 153);this.splitContainer1.Name = "splitContainer1";// // splitContainer1.Panel1// this.splitContainer1.Panel1.AutoScroll = true;this.splitContainer1.Panel1.Controls.Add(this.listView1);this.splitContainer1.Panel1MinSize = 150;// // splitContainer1.Panel2// this.splitContainer1.Panel2.Controls.Add(this.tabControl1);this.splitContainer1.Panel2MinSize = 500;this.splitContainer1.Size = new System.Drawing.Size(1033, 608);this.splitContainer1.SplitterDistance = 296;this.splitContainer1.TabIndex = 0;// // listView1// this.listView1.Dock = System.Windows.Forms.DockStyle.Fill;this.listView1.Location = new System.Drawing.Point(0, 0);this.listView1.Name = "listView1";this.listView1.Size = new System.Drawing.Size(296, 608);this.listView1.TabIndex = 0;this.listView1.UseCompatibleStateImageBehavior = false;this.listView1.View = System.Windows.Forms.View.Details;this.listView1.SelectedIndexChanged += new System.EventHandler(this.listView1_SelectedIndexChanged);this.listView1.MouseUp += new System.Windows.Forms.MouseEventHandler(this.listView1_MouseUp);// // tabControl1// this.tabControl1.Dock = System.Windows.Forms.DockStyle.Fill;this.tabControl1.Location = new System.Drawing.Point(0, 0);this.tabControl1.Margin = new System.Windows.Forms.Padding(3, 0, 3, 3);this.tabControl1.Name = "tabControl1";this.tabControl1.SelectedIndex = 0;this.tabControl1.Size = new System.Drawing.Size(733, 608);this.tabControl1.TabIndex = 0;// // tabControl2// this.tabControl2.Controls.Add(this.tabPage1);this.tabControl2.Controls.Add(this.tabPage2);this.tabControl2.Dock = System.Windows.Forms.DockStyle.Fill;this.tabControl2.Location = new System.Drawing.Point(3, 3);this.tabControl2.Name = "tabControl2";this.tabControl2.SelectedIndex = 0;this.tabControl2.Size = new System.Drawing.Size(1033, 144);this.tabControl2.TabIndex = 1;// // tabPage1// this.tabPage1.Controls.Add(this.groupBox1);this.tabPage1.Location = new System.Drawing.Point(4, 22);this.tabPage1.Name = "tabPage1";this.tabPage1.Padding = new System.Windows.Forms.Padding(3);this.tabPage1.Size = new System.Drawing.Size(1025, 118);this.tabPage1.TabIndex = 0;this.tabPage1.Text = "监控基本信息";this.tabPage1.UseVisualStyleBackColor = true;// // groupBox1// this.groupBox1.Controls.Add(this.btnTestSend);this.groupBox1.Controls.Add(this.labSericeState);this.groupBox1.Controls.Add(this.btnExec);this.groupBox1.Controls.Add(this.txtListenInterval);this.groupBox1.Controls.Add(this.txtRefreshInterval);this.groupBox1.Controls.Add(this.labStopCount);this.groupBox1.Controls.Add(this.labRunCount);this.groupBox1.Controls.Add(this.label4);this.groupBox1.Controls.Add(this.label3);this.groupBox1.Controls.Add(this.label2);this.groupBox1.Controls.Add(this.label1);this.groupBox1.Dock = System.Windows.Forms.DockStyle.Fill;this.groupBox1.Location = new System.Drawing.Point(3, 3);this.groupBox1.Name = "groupBox1";this.groupBox1.Size = new System.Drawing.Size(1019, 112);this.groupBox1.TabIndex = 1;this.groupBox1.TabStop = false;// // btnTestSend// this.btnTestSend.Location = new System.Drawing.Point(14, 73);this.btnTestSend.Name = "btnTestSend";this.btnTestSend.Size = new System.Drawing.Size(123, 23);this.btnTestSend.TabIndex = 4;this.btnTestSend.Text = "测试发送消息";this.btnTestSend.UseVisualStyleBackColor = true;this.btnTestSend.Click += new System.EventHandler(this.btnTestSend_Click);// // labSericeState// this.labSericeState.BackColor = System.Drawing.Color.Red;this.labSericeState.Location = new System.Drawing.Point(578, 40);this.labSericeState.Name = "labSericeState";this.labSericeState.Size = new System.Drawing.Size(34, 22);this.labSericeState.TabIndex = 3;this.labSericeState.TextAlign = System.Drawing.ContentAlignment.MiddleCenter;// // btnExec// this.btnExec.Location = new System.Drawing.Point(487, 40);this.btnExec.Name = "btnExec";this.btnExec.Size = new System.Drawing.Size(75, 23);this.btnExec.TabIndex = 2;this.btnExec.Text = "开启监控";this.btnExec.UseVisualStyleBackColor = true;this.btnExec.Click += new System.EventHandler(this.btnExec_Click);// // txtListenInterval// this.txtListenInterval.Location = new System.Drawing.Point(147, 41);this.txtListenInterval.Name = "txtListenInterval";this.txtListenInterval.Size = new System.Drawing.Size(68, 21);this.txtListenInterval.TabIndex = 1;this.txtListenInterval.Text = "2";// // txtRefreshInterval// this.txtRefreshInterval.Location = new System.Drawing.Point(411, 41);this.txtRefreshInterval.Name = "txtRefreshInterval";this.txtRefreshInterval.Size = new System.Drawing.Size(68, 21);this.txtRefreshInterval.TabIndex = 1;this.txtRefreshInterval.Text = "5";// // labStopCount// this.labStopCount.AutoSize = true;this.labStopCount.Font = new System.Drawing.Font("宋体", 14.25F, System.Drawing.FontStyle.Bold, System.Drawing.GraphicsUnit.Point, ((byte)(134)));this.labStopCount.ForeColor = System.Drawing.Color.Red;this.labStopCount.Location = new System.Drawing.Point(841, 42);this.labStopCount.Name = "labStopCount";this.labStopCount.Size = new System.Drawing.Size(40, 19);this.labStopCount.TabIndex = 0;this.labStopCount.Text = "0个";// // labRunCount// this.labRunCount.AutoSize = true;this.labRunCount.Font = new System.Drawing.Font("宋体", 14.25F, System.Drawing.FontStyle.Bold, System.Drawing.GraphicsUnit.Point, ((byte)(134)));this.labRunCount.ForeColor = System.Drawing.Color.Green;this.labRunCount.Location = new System.Drawing.Point(721, 42);this.labRunCount.Name = "labRunCount";this.labRunCount.Size = new System.Drawing.Size(40, 19);this.labRunCount.TabIndex = 0;this.labRunCount.Text = "0个";// // label4// this.label4.AutoSize = true;this.label4.Location = new System.Drawing.Point(782, 45);this.label4.Name = "label4";this.label4.Size = new System.Drawing.Size(53, 12);this.label4.TabIndex = 0;this.label4.Text = "已停止:";// // label3// this.label3.AutoSize = true;this.label3.Location = new System.Drawing.Point(645, 45);this.label3.Name = "label3";this.label3.Size = new System.Drawing.Size(53, 12);this.label3.TabIndex = 0;this.label3.Text = "运行中:";// // label2// this.label2.AutoSize = true;this.label2.Location = new System.Drawing.Point(12, 45);this.label2.Name = "label2";this.label2.Size = new System.Drawing.Size(125, 12);this.label2.TabIndex = 0;this.label2.Text = "监听探测间隔(分):";// // label1// this.label1.AutoSize = true;this.label1.Location = new System.Drawing.Point(232, 45);this.label1.Name = "label1";this.label1.Size = new System.Drawing.Size(173, 12);this.label1.TabIndex = 0;this.label1.Text = "正常停止清除列表时长(分):";// // tabPage2// this.tabPage2.Controls.Add(this.labLine);this.tabPage2.Controls.Add(this.panel1);this.tabPage2.Controls.Add(this.panel2);this.tabPage2.Location = new System.Drawing.Point(4, 22);this.tabPage2.Name = "tabPage2";this.tabPage2.Padding = new System.Windows.Forms.Padding(3);this.tabPage2.Size = new System.Drawing.Size(1025, 118);this.tabPage2.TabIndex = 1;this.tabPage2.Text = "消息通知设置";this.tabPage2.UseVisualStyleBackColor = true;// // labLine// this.labLine.BackColor = System.Drawing.Color.FromArgb(((int)(((byte)(224)))), ((int)(((byte)(224)))), ((int)(((byte)(224)))));this.labLine.Dock = System.Windows.Forms.DockStyle.Bottom;this.labLine.FlatStyle = System.Windows.Forms.FlatStyle.Popup;this.labLine.Location = new System.Drawing.Point(3, 59);this.labLine.Name = "labLine";this.labLine.Size = new System.Drawing.Size(1019, 2);this.labLine.TabIndex = 0;// // panel1// this.panel1.Controls.Add(this.txtPwd);this.panel1.Controls.Add(this.txtUID);this.panel1.Controls.Add(this.txtDb);this.panel1.Controls.Add(this.txtServer);this.panel1.Controls.Add(this.label8);this.panel1.Controls.Add(this.label9);this.panel1.Controls.Add(this.txtPhoneNos);this.panel1.Controls.Add(this.label7);this.panel1.Controls.Add(this.label6);this.panel1.Controls.Add(this.label5);this.panel1.Controls.Add(this.chkSendSms);this.panel1.Dock = System.Windows.Forms.DockStyle.Top;this.panel1.Location = new System.Drawing.Point(3, 3);this.panel1.Name = "panel1";this.panel1.Size = new System.Drawing.Size(1019, 52);this.panel1.TabIndex = 0;// // txtPwd// this.txtPwd.Location = new System.Drawing.Point(925, 24);this.txtPwd.Name = "txtPwd";this.txtPwd.PasswordChar = '*';this.txtPwd.Size = new System.Drawing.Size(91, 21);this.txtPwd.TabIndex = 5;// // txtUID// this.txtUID.Location = new System.Drawing.Point(779, 24);this.txtUID.Name = "txtUID";this.txtUID.PasswordChar = '*';this.txtUID.Size = new System.Drawing.Size(91, 21);this.txtUID.TabIndex = 4;// // txtDb// this.txtDb.Location = new System.Drawing.Point(628, 24);this.txtDb.Name = "txtDb";this.txtDb.Size = new System.Drawing.Size(96, 21);this.txtDb.TabIndex = 3;this.txtDb.Text = "";// // txtServer// this.txtServer.Location = new System.Drawing.Point(423, 24);this.txtServer.Name = "txtServer";this.txtServer.Size = new System.Drawing.Size(150, 21);this.txtServer.TabIndex = 2;this.txtServer.Text = "";// // label8// this.label8.AutoSize = true;this.label8.Location = new System.Drawing.Point(876, 27);this.label8.Name = "label8";this.label8.Size = new System.Drawing.Size(41, 12);this.label8.TabIndex = 7;this.label8.Text = "密码:";// // label9// this.label9.AutoSize = true;this.label9.Location = new System.Drawing.Point(579, 27);this.label9.Name = "label9";this.label9.Size = new System.Drawing.Size(53, 12);this.label9.TabIndex = 7;this.label9.Text = "数据库:";// // txtPhoneNos// this.txtPhoneNos.Location = new System.Drawing.Point(213, 22);this.txtPhoneNos.Name = "txtPhoneNos";this.txtPhoneNos.Size = new System.Drawing.Size(155, 21);this.txtPhoneNos.TabIndex = 1;// // label7// this.label7.AutoSize = true;this.label7.Location = new System.Drawing.Point(730, 27);this.label7.Name = "label7";this.label7.Size = new System.Drawing.Size(53, 12);this.label7.TabIndex = 7;this.label7.Text = "用户名:";// // label6// this.label6.AutoSize = true;this.label6.Location = new System.Drawing.Point(374, 27);this.label6.Name = "label6";this.label6.Size = new System.Drawing.Size(53, 12);this.label6.TabIndex = 7;this.label6.Text = "服务器:";// // label5// this.label5.AutoSize = true;this.label5.Location = new System.Drawing.Point(3, 27);this.label5.Name = "label5";this.label5.Size = new System.Drawing.Size(185, 12);this.label5.TabIndex = 7;this.label5.Text = "通知手机号(多个请用,分隔):";// // chkSendSms// this.chkSendSms.AutoSize = true;this.chkSendSms.Location = new System.Drawing.Point(3, 3);this.chkSendSms.Name = "chkSendSms";this.chkSendSms.Size = new System.Drawing.Size(72, 16);this.chkSendSms.TabIndex = 0;this.chkSendSms.Text = "短信通知";this.chkSendSms.UseVisualStyleBackColor = true;// // panel2// this.panel2.Controls.Add(this.txtWxUIDs);this.panel2.Controls.Add(this.chkSendWx);this.panel2.Controls.Add(this.label10);this.panel2.Dock = System.Windows.Forms.DockStyle.Bottom;this.panel2.Location = new System.Drawing.Point(3, 61);this.panel2.Name = "panel2";this.panel2.Size = new System.Drawing.Size(1019, 54);this.panel2.TabIndex = 1;// // txtWxUIDs// this.txtWxUIDs.Location = new System.Drawing.Point(188, 15);this.txtWxUIDs.Name = "txtWxUIDs";this.txtWxUIDs.Size = new System.Drawing.Size(828, 21);this.txtWxUIDs.TabIndex = 0;this.txtWxUIDs.Text = "@all";// // chkSendWx// this.chkSendWx.AutoSize = true;this.chkSendWx.Location = new System.Drawing.Point(3, 3);this.chkSendWx.Name = "chkSendWx";this.chkSendWx.Size = new System.Drawing.Size(72, 16);this.chkSendWx.TabIndex = 6;this.chkSendWx.Text = "微信通知";this.chkSendWx.UseVisualStyleBackColor = true;// // label10// this.label10.AutoSize = true;this.label10.Location = new System.Drawing.Point(3, 24);this.label10.Name = "label10";this.label10.Size = new System.Drawing.Size(179, 12);this.label10.TabIndex = 7;this.label10.Text = "通知微信ID(多个请用|分隔):";// // ctxMuPop// this.ctxMuPop.Items.AddRange(new System.Windows.Forms.ToolStripItem[] {this.removeToolStripMenuItem});this.ctxMuPop.Name = "ctxMuPop";this.ctxMuPop.Size = new System.Drawing.Size(125, 26);// // removeToolStripMenuItem// this.removeToolStripMenuItem.Name = "removeToolStripMenuItem";this.removeToolStripMenuItem.Size = new System.Drawing.Size(124, 22);this.removeToolStripMenuItem.Text = "移除监控";this.removeToolStripMenuItem.Click += new System.EventHandler(this.removeToolStripMenuItem_Click);// // FrmMain// this.AutoScaleDimensions = new System.Drawing.SizeF(6F, 12F);this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font;this.ClientSize = new System.Drawing.Size(1039, 722);this.Controls.Add(this.tableLayoutPanel1);this.Name = "FrmMain";this.StartPosition = System.Windows.Forms.FormStartPosition.CenterScreen;this.Text = "程序运行状态监控系统";this.FormClosing += new System.Windows.Forms.FormClosingEventHandler(this.FrmMain_FormClosing);this.Load += new System.EventHandler(this.FrmMain_Load);this.tableLayoutPanel1.ResumeLayout(false);this.splitContainer1.Panel1.ResumeLayout(false);this.splitContainer1.Panel2.ResumeLayout(false);((System.ComponentModel.ISupportInitialize)(this.splitContainer1)).EndInit();this.splitContainer1.ResumeLayout(false);this.tabControl2.ResumeLayout(false);this.tabPage1.ResumeLayout(false);this.groupBox1.ResumeLayout(false);this.groupBox1.PerformLayout();this.tabPage2.ResumeLayout(false);this.panel1.ResumeLayout(false);this.panel1.PerformLayout();this.panel2.ResumeLayout(false);this.panel2.PerformLayout();this.ctxMuPop.ResumeLayout(false);this.ResumeLayout(false);}#endregionprivate System.Windows.Forms.TableLayoutPanel tableLayoutPanel1;private System.Windows.Forms.SplitContainer splitContainer1;private System.Windows.Forms.ListView listView1;private System.Windows.Forms.GroupBox groupBox1;private System.Windows.Forms.TextBox txtListenInterval;private System.Windows.Forms.Label label2;private System.Windows.Forms.Label labStopCount;private System.Windows.Forms.Label labRunCount;private System.Windows.Forms.Label label4;private System.Windows.Forms.Label label3;private System.Windows.Forms.Button btnExec;private System.Windows.Forms.TabControl tabControl1;private System.Windows.Forms.Label labSericeState;private System.Windows.Forms.TextBox txtRefreshInterval;private System.Windows.Forms.Label label1;private System.Windows.Forms.TabControl tabControl2;private System.Windows.Forms.TabPage tabPage1;private System.Windows.Forms.TabPage tabPage2;private System.Windows.Forms.Panel panel2;private System.Windows.Forms.CheckBox chkSendWx;private System.Windows.Forms.Label label10;private System.Windows.Forms.TextBox txtWxUIDs;private System.Windows.Forms.Panel panel1;private System.Windows.Forms.TextBox txtPwd;private System.Windows.Forms.TextBox txtUID;private System.Windows.Forms.TextBox txtDb;private System.Windows.Forms.TextBox txtServer;private System.Windows.Forms.Label label8;private System.Windows.Forms.Label label9;private System.Windows.Forms.TextBox txtPhoneNos;private System.Windows.Forms.Label label7;private System.Windows.Forms.Label label6;private System.Windows.Forms.Label label5;private System.Windows.Forms.CheckBox chkSendSms;private System.Windows.Forms.Label labLine;private System.Windows.Forms.Button btnTestSend;private System.Windows.Forms.ContextMenuStrip ctxMuPop;private System.Windows.Forms.ToolStripMenuItem removeToolStripMenuItem;}
}

被监控的客户端程序集成WCF监听客户端很简单,只需引用ProgramMonitor.Core,然后实例化ListenClient,最后就可以通过该ListenClient与心跳监控系统进行双工通讯,在此就不贴出源代码了。

上述代码中还有用到两个类:

DataAccess:数据访问类,这个我之前的文章有介绍,详见:DataAccess通用数据库访问类,简单易用,功能强悍

WeChat:微信企业号发送消息类,注意是微信企业号,不是公众号,这里我也贴出源代码来,供大家了解:

using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using System.Web;namespace ProgramMonitor.Service
{public class WeChat{private readonly string _url = null;private readonly string _corpid = null;private readonly string _secret = null;public WeChat(){_url = "https://qyapi.weixin.qq.com/cgi-bin";_corpid = "CorpID是企业号的标识,每个企业号拥有一个唯一的CorpID";_secret = "secret是管理组凭证密钥,系统管理员在企业号管理后台创建管理组时,企业号后台为该管理组分配一个唯一的secret";}public string GetToken(string url_prefix = "/"){string urlParams = string.Format("corpid={0}&corpsecret={1}", HttpUtility.UrlEncodeUnicode(_corpid), HttpUtility.UrlEncodeUnicode(_secret));string url = _url + url_prefix + "gettoken?" + urlParams;string result = HttpGet(url);var content = JObject.Parse(result);return content["access_token"].ToString();}public JObject PostData(dynamic data, string url_prefix = "/"){string dataStr = JsonConvert.SerializeObject(data);string url = _url + url_prefix + "message/send?access_token=" + GetToken();string result = HttpPost(url, dataStr);return JObject.Parse(result);}public JObject SendMessage(string touser, string message){var data = new { touser = touser, toparty = "1", msgtype = "text", agentid = "2", text = new { content = message }, safe = "0" };var jResult = PostData(data);return jResult;}private string HttpPost(string Url, string postDataStr){HttpWebRequest request = (HttpWebRequest)WebRequest.Create(Url);request.Method = "POST";request.ContentType = "application/x-www-form-urlencoded";byte[] data = Encoding.UTF8.GetBytes(postDataStr);request.ContentLength = data.Length;Stream myRequestStream = request.GetRequestStream();myRequestStream.Write(data, 0, data.Length);myRequestStream.Close();HttpWebResponse response = (HttpWebResponse)request.GetResponse();Stream myResponseStream = response.GetResponseStream();StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.UTF8);string retString = myStreamReader.ReadToEnd();myStreamReader.Close();myResponseStream.Close();return retString;}public string HttpGet(string Url, string urlParams = null){HttpWebRequest request = (HttpWebRequest)WebRequest.Create(Url + (string.IsNullOrEmpty(urlParams) ? "" : "?") + urlParams);request.Method = "GET";request.ContentType = "text/html;charset=UTF-8";HttpWebResponse response = (HttpWebResponse)request.GetResponse();Stream myResponseStream = response.GetResponseStream();StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.UTF8);string retString = myStreamReader.ReadToEnd();myStreamReader.Close();myResponseStream.Close();return retString;}}
}

具体的关于微信企业号开发文档,可参见:http://qydev.weixin.qq.com/wiki/index.php

最后的效果如下:

心跳监控程序监控效果:

手机收到异常消息:

  (《-这是企业号发出的消息)                    (《-这里短信消息,当然发短信是我公司的平台接口发出的,发短信是需要RMB的,故不建议)

好了本文就到此结束,可能功能相对简单,还有一些不足,欢迎大家评论交流,谢谢!

转载于:https://www.cnblogs.com/zuowj/p/5761011.html

利用WCF的双工通讯实现一个简单的心跳监控系统相关推荐

  1. 【转】利用WCF的双工通信

    Silverlight与WCF之间的通信(2)利用WCF的双工通信"推送"给SL数据 作者:Leon Weng  来源:博客园  发布时间:2010-06-19 23:43  阅读 ...

  2. 利用WCF的callback机制开发一个简单的多人游戏模型

    本文介绍了如何利用WCF和callback机制开发一个简单的多人在线游戏模型. 运行过程如下: 当game service 启动之后,若干个客户端便会自动连接到服务器.当某个客户端点击join gam ...

  3. 利用 C# 中的 FileSystemWatcher 制作一个文件夹监控小工具

    利用 C# 中的 FileSystemWatcher 制作一个文件夹监控小工具 独立观察员 2020 年 12 月 26 日 前一段看到微信公众号 "码农读书" 上发了一篇文章&l ...

  4. 用Python写一个简单的监控系统

    发表于 2014年9月21日 作者 root 市面上有很多开源的监控系统:Cacti.nagios.zabbix.感觉都不符合我的需求,为什么不自己做一个呢 用Python两个小时徒手撸了一个简易的监 ...

  5. 一个简单的监控系统的设计

    一个简单的监控系统的设计 # // // 为了实现上级需要一个监控的需求,设计一个小的监控系统,结构如下图. // 虽然是一个比较简单的功能,但是仍然对代码的结构的关系进行了设计,使其具备良好的可扩展 ...

  6. WCF实现双工通讯及客户端调用

    新建一个Windows窗体应用程序(即客户端Client)和一个WCF服务库(WCF双工) 在WCF双工项目下: 新建一歌ILogger接口和实现该接口的Logger类 在ILogger接口中 usi ...

  7. Labview布尔型的例子——一个简单温度监控系统的设计

    步骤 步骤一 打开Labview→文件→新建一个VI→在前面板添加一个布尔型的指示灯和一个浮点型的数值显示控件. 步骤二 打开程序框图,"函数"选项板→"编程" ...

  8. 记录一个APP跳转系统相机拍摄小问题

    记录原因:在实现一个跳转拍视频的功能时候,因为写了如下代码,录制了后返回,结果发现私有目录cacheDir的文件一直为0k,仔细一想...这肯定是0k没得跑,因此记录一下这个乌龙. val uri: ...

  9. 一个很酷的监控系统(附源码)

最新文章

  1. java实现动态上传多个文件并解决文件重名问题
  2. git 的右键快捷菜单恢复
  3. mysql对其他IP授权访问
  4. cordova打包安卓app
  5. springboot 前缀_SpringBoot配置文件的注入
  6. 我的博客今天0岁346天了,我领取了…
  7. 百度API_获取当前详细地址
  8. mikrotikROS系统的几种安装方法
  9. python xlrd读取文件报错_python中xlrd库如何实现文件读取?
  10. 工作流实战_05_flowable 流程定义的挂起与激活
  11. (计算机组成原理)第七章输入和输出系统-第一节:I/O系统基本概念和I/O控制方式简介
  12. VLC测试IPv4 IGMP/IPv6 MLD协议
  13. Linux如何检查目录inode占用,linux – 如何确定哪个文件/ inode占用给定扇区
  14. mysql锁的基本类型_Mysql的锁
  15. ipad中的active失效?
  16. 基于java技术的幼儿园管理系统答辩PPT模板
  17. Android编译判定BoardConfig.mk的宏控是否打开或者有效的验证方法
  18. Spring Cloud Alibaba Seata工作原理
  19. 我喜欢计算机作文450字,我喜欢的一种游戏作文450字(精选8篇)
  20. 旭凤锦覓虐心 恋只愿共赴鸿蒙,香蜜:锦觅与旭凤4次同床,1次酒醉灵修,1次再续前缘,1次虐心!...

热门文章

  1. 数据库mysql存储过程_[数据库]mysql存储过程的建立及使用
  2. 夸克浏览器怎么安装脚本_还你清爽流畅!这五款手机浏览器!黑马强推
  3. 城市轨道交通运营票务管理论文_解读新版《天津市轨道交通票务管理定》
  4. 自认为有必要学习的Sql 总结,积累 mybatis
  5. 51nod 1307 绳子与重物 (标记父节点更新即可)
  6. 整数反转—leetcode7
  7. linux静态库的打包及链接使用
  8. iOS Hacker 越狱后如何使用 root 运行应用
  9. 查看SecureCRT保存的密码
  10. Metro App中使用Timer