何為心跳監(jiān)控系統(tǒng)？

故名思義，就是監(jiān)控某個(gè)或某些個(gè)程序的運(yùn)行狀態(tài)，就好比醫(yī)院里面的心跳監(jiān)視儀一樣，能夠隨時(shí)顯示病人的心跳情況。

心跳監(jiān)控的目的是什么？

與醫(yī)院里面的心跳監(jiān)視儀目的類似，監(jiān)控程序運(yùn)行狀態(tài)，一旦出現(xiàn)問題（比如：一些自動(dòng)運(yùn)行的服務(wù)、程序等突然停止運(yùn)行了），那么心跳監(jiān)控系統(tǒng)就能“感知到”并及時(shí)的顯示在監(jiān)控界面上，同時(shí)可以通過微信、短信告之相關(guān)的人員，以便他們及時(shí)處理程序異常，從而避免一些自動(dòng)運(yùn)行的服務(wù)、程序等突然停止運(yùn)行而造成的一系列損失

心跳監(jiān)控系統(tǒng)實(shí)現(xiàn)的思路是怎樣的？

核心技術(shù)：WCF的雙工通訊

實(shí)現(xiàn)步驟：

1.定義WCF的服務(wù)契約接口以及回調(diào)接口，服務(wù)方法主要包括：Start（被監(jiān)控的程序啟動(dòng)時(shí)調(diào)用，即通知監(jiān)控系統(tǒng)，我已經(jīng)啟動(dòng)了）、Stop（被監(jiān)控的程序停止時(shí)調(diào)用，即通知監(jiān)控系統(tǒng)，我已經(jīng)停止了）、ReportRunning（被監(jiān)控的程序運(yùn)行中定時(shí)調(diào)用，即通知監(jiān)控系統(tǒng)，我是正常的并在運(yùn)行中，同時(shí)還起到檢測監(jiān)控系統(tǒng)是否在運(yùn)行的一個(gè)功能，一舉兩得），回調(diào)服務(wù)方法應(yīng)有：Listen（這個(gè)是給監(jiān)控系統(tǒng)主動(dòng)去定時(shí)回調(diào)被監(jiān)控的程序（心跳），如果被監(jiān)控的程序能正常的返回狀態(tài)，那么就是正常的，否則有可能已經(jīng)“死了”，這時(shí)監(jiān)控系統(tǒng)就需要按照預(yù)設(shè)指令作出相應(yīng)的操作，比如：監(jiān)控主界面顯示異常的程序，同時(shí)發(fā)送異常通知消息給相關(guān)人員）

2.建立一個(gè)心跳監(jiān)控系統(tǒng)Winform項(xiàng)目，并實(shí)現(xiàn)WCF服務(wù)，即集成實(shí)現(xiàn)WCF服務(wù)宿主程序，同時(shí)每一個(gè)WCF服務(wù)方法均需關(guān)聯(lián)界面，即：程序啟動(dòng)了、停止了、運(yùn)行中均會(huì)在界面實(shí)時(shí)顯示出來或做一些實(shí)時(shí)統(tǒng)計(jì)；

3.其它被監(jiān)控的程序（指自動(dòng)運(yùn)行的服務(wù)、程序等）需要集成實(shí)現(xiàn)WCF回調(diào)接口及開啟WCF服務(wù)通訊的功能；

心跳監(jiān)控系統(tǒng)的運(yùn)行順序是怎樣的？如何保證監(jiān)控方與被監(jiān)控方實(shí)時(shí)不間斷通訊？

運(yùn)行順序：

1.開啟心跳監(jiān)控系統(tǒng)（即：同時(shí)開啟WCF服務(wù)宿主程序），確保監(jiān)控服務(wù)正常運(yùn)行；

2.開啟其它被監(jiān)控的程序，確保開啟客戶端與監(jiān)控系統(tǒng)的WCF雙工通訊服務(wù)正常；

注意：一定要先開啟心跳監(jiān)控系統(tǒng)，否則其它被監(jiān)控的程序因無法與監(jiān)控系統(tǒng)的WCF雙工通訊服務(wù)正常連接而報(bào)錯(cuò)或多次嘗試重連；

保證監(jiān)控方與被監(jiān)控方實(shí)時(shí)不間斷通訊：

在保證按照上面所說的運(yùn)行順序依次開啟心跳監(jiān)控系統(tǒng)，再開啟其它被監(jiān)控的程序，正常建立一次通訊后，后續(xù)只要任何一方出現(xiàn)通訊中斷，均會(huì)自動(dòng)嘗試重連（主要是客戶端重連，心跳監(jiān)控系統(tǒng)除非停止運(yùn)行，否則不會(huì)中斷，若因停止運(yùn)行造成雙方通訊中斷，只需重啟心跳監(jiān)控系統(tǒng)即可）

通訊模式：

推模式：被監(jiān)控的程序通過主動(dòng)的調(diào)用WCF服務(wù)方法：Start、Stop、ReportRunning 向心跳監(jiān)控系統(tǒng)告之運(yùn)行狀態(tài)，若通訊失敗，則自動(dòng)嘗試重連，直至連接成功；

拉模式：心跳監(jiān)控系統(tǒng)主動(dòng)回調(diào)Listen方法，向被監(jiān)控的程序索取運(yùn)行狀態(tài)，若通訊失敗，則會(huì)在指定時(shí)間內(nèi)多次重試回調(diào)客戶端，若客戶端在規(guī)定的時(shí)間范圍內(nèi)仍無法返回消息，則視為客戶端異常，那么心跳監(jiān)控系統(tǒng)則會(huì)進(jìn)行異常的處理；

實(shí)現(xiàn)源代碼：

ProgramMonitor.Core 類庫項(xiàng)目：主要是定義WCF服務(wù)的相關(guān)接口以及實(shí)現(xiàn)回調(diào)的接口（因?yàn)槊總€(gè)客戶端都需實(shí)現(xiàn)一遍回調(diào)接口，故統(tǒng)一實(shí)現(xiàn)，客戶端集成后直接可以用，簡化集成客戶端的開發(fā)成本），心跳監(jiān)控系統(tǒng)及需要被監(jiān)控的程序均需要依賴該DLL；

ProgramMonitor WINFORM項(xiàng)目：心跳監(jiān)控系統(tǒng)

整個(gè)解決方案如下圖示：

注：由于源代碼相對較多，故不再一一說明，只對重點(diǎn)的代碼作解釋

ProgramMonitor.Core

IListenService：（心跳監(jiān)控WCF服務(wù)契約接口）

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：（監(jiān)聽回調(diào)服務(wù)接口，主用被心跳監(jiān)控系統(tǒng)調(diào)用）

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：（程序信息類，主要用于獲取被監(jiān)控程序的基本信息）

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>/// 運(yùn)行狀態(tài)，-1:表示停止，0表示啟動(dòng)，1表示運(yùn)行中/// </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：（監(jiān)聽客戶端類，實(shí)現(xiàn)WCF回調(diào)服務(wù)接口，主要用于被監(jiān)控的程序）

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方法，因?yàn)樾奶O(jiān)控系統(tǒng)主要是依據(jù)ProgramId來識別每個(gè)不同的程序，故ProgramId非常重要，而我這里采用的是文件的 MD5值+進(jìn)程數(shù)作為ProgramId，有些人可能要問，為什么要加進(jìn)程數(shù)呢？原因很簡單，因?yàn)橛行┏绦蚴窃试S開啟多個(gè)的實(shí)例的，如果不加進(jìn)程數(shù)，那么心跳監(jiān)控系統(tǒng)就無法識別多個(gè)同一個(gè)程序到底是哪個(gè)。

?ProgramMonitor

ListenService：（WCF心跳監(jiān)控服務(wù)接口實(shí)現(xiàn)類）

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:（通用業(yè)務(wù)邏輯類，主要用于WCF與UI實(shí)時(shí)溝通與聯(lián)動(dòng)）

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}，已啟動(dòng)運(yùn)行", 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}，已停止運(yùn)行", 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}，正在運(yùn)行中", 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分鐘，則發(fā)一次短信{SendNoticeSms(programInfo);SendNoticeWeiXin(programInfo);programInfo.RunState = -1;//重新刷新狀態(tài)}if (oldRunState != programInfo.RunState){needUpdateStatInfo = true;WriteLog(string.Format("程序名：{0}，版本：{1}，運(yùn)行狀態(tài)變更為：{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}，已停止運(yùn)行了，請盡快處理！",programInfo.Name, programInfo.Version, programInfo.InstalledLocation)).AddParameter("@SendTime", DateTime.Now).AddParameter("@KndType", "監(jiān)控異常通知").ToParameterArray();da.ExecuteCommand("insert into OutBox(Mbno,Msg,SendTime,KndType) values(@Mbno,@Msg,@SendTime,@KndType)", paramObjs: parameters);}da.Commit();WriteLog(string.Format("程序名：{0}，版本：{1}，已停止運(yùn)行超過5分鐘，成功發(fā)送短信通知到：{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}，已停止運(yùn)行了，請盡快處理！",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}，已停止運(yùn)行超過5分鐘，成功發(fā)送微信通知到：{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：（心跳監(jiān)控系統(tǒng)窗體類）

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 自定義方法區(qū)域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) //當(dāng)屬于正常關(guān)閉的程序在指定時(shí)間后從監(jiān)控列表中移除{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}個(gè)", runCount);labStopCount.Text = string.Format("{0}個(gè)", 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 "程序已停止運(yùn)行";}else if (runState == 0){msgColor = Color.Blue;return "程序已啟動(dòng)運(yùn)行";}else{msgColor = Color.Black;return "程序已在運(yùn)行中";}}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 = "停止監(jiān)控";panel1.Enabled = false;panel2.Enabled = false;}else{labSericeState.BackColor = Color.Red;txtRefreshInterval.Enabled = true;txtListenInterval.Enabled = true;btnExec.Tag = "S";btnExec.Text = "開啟監(jiān)控";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("運(yùn)行路徑");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("數(shù)據(jù)庫測試連接失敗，原因：" + 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("未找到相應(yīng)的程序監(jiān)控記錄！");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("您確定要退出嗎？退出后將無法正常監(jiān)控各程序的運(yùn)行狀況", "退出提示", 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", "測試消息，有程序停止運(yùn)行了，趕緊處理！");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("只有被監(jiān)控的程序處于已停止?fàn)顟B(tài)的監(jiān)控項(xiàng)才能移除，除外情況請務(wù)必保持正常！");return;}RemoveListenItem(programId);}} }

窗體類中主要是用到了幾個(gè)更新UI上控件信息的方法以及開啟、關(guān)閉WCF服務(wù)的方法，很簡單，一看就明白，無需多講。

FrmMain.Designer.cs：（Form窗體設(shè)計(jì)類，系統(tǒng)自動(dòng)生成的，再此貼出是便于大家可以直接COPY到自己的代碼中直接用）

namespace ProgramMonitor {partial class FrmMain{/// <summary>/// 必需的設(shè)計(jì)器變量。/// </summary>private System.ComponentModel.IContainer components = null;/// <summary>/// 清理所有正在使用的資源。/// </summary>/// <param name="disposing">如果應(yīng)釋放托管資源，為 true；否則為 false。</param>protected override void Dispose(bool disposing){if (disposing && (components != null)){components.Dispose();}base.Dispose(disposing);}#region Windows 窗體設(shè)計(jì)器生成的代碼/// <summary>/// 設(shè)計(jì)器支持所需的方法 - 不要/// 使用代碼編輯器修改此方法的內(nèi)容。/// </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 = "監(jiān)控基本信息";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 = "測試發(fā)送消息";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 = "開啟監(jiān)控";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個(gè)";// // 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個(gè)";// // 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 = "運(yùn)行中：";// // 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 = "監(jiān)聽探測間隔（分）：";// // 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 = "正常停止清除列表時(shí)長（分）：";// // 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 = "消息通知設(shè)置";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 = "數(shù)據(jù)庫：";// // 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 = "服務(wù)器：";// // 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 = "通知手機(jī)號（多個(gè)請用，分隔）：";// // 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（多個(gè)請用|分隔）：";// // 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 = "移除監(jiān)控";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 = "程序運(yùn)行狀態(tài)監(jiān)控系統(tǒng)";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;} }

被監(jiān)控的客戶端程序集成WCF監(jiān)聽客戶端很簡單，只需引用ProgramMonitor.Core，然后實(shí)例化ListenClient，最后就可以通過該ListenClient與心跳監(jiān)控系統(tǒng)進(jìn)行雙工通訊，在此就不貼出源代碼了。

上述代碼中還有用到兩個(gè)類：

DataAccess：數(shù)據(jù)訪問類，這個(gè)我之前的文章有介紹，詳見：DataAccess通用數(shù)據(jù)庫訪問類，簡單易用，功能強(qiáng)悍

WeChat：微信企業(yè)號發(fā)送消息類，注意是微信企業(yè)號，不是公眾號，這里我也貼出源代碼來，供大家了解：

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是企業(yè)號的標(biāo)識，每個(gè)企業(yè)號擁有一個(gè)唯一的CorpID";_secret = "secret是管理組憑證密鑰，系統(tǒng)管理員在企業(yè)號管理后臺創(chuàng)建管理組時(shí)，企業(yè)號后臺為該管理組分配一個(gè)唯一的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;}} }

具體的關(guān)于微信企業(yè)號開發(fā)文檔，可參見：http://qydev.weixin.qq.com/wiki/index.php

最后的效果如下：

心跳監(jiān)控程序監(jiān)控效果：

手機(jī)收到異常消息：

? （《-這是企業(yè)號發(fā)出的消息） ? ? ? ? ? ? ? ? ? ?（《-這里短信消息，當(dāng)然發(fā)短信是我公司的平臺接口發(fā)出的，發(fā)短信是需要RMB的，故不建議）

?

好了本文就到此結(jié)束，可能功能相對簡單，還有一些不足，歡迎大家評論交流，謝謝！

?

轉(zhuǎn)載于:https://www.cnblogs.com/zuowj/p/5761011.html

總結(jié)

以上是生活随笔為你收集整理的利用WCF的双工通讯实现一个简单的心跳监控系统的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。