你的位置:首页 > ASP.net教程

[ASP.net教程]利用WCF的双工通讯实现一个简单的心跳监控系统

何为心跳监控系统?

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

心跳监控的目的是什么?

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

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

核心技术: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;#else      btnTestSend.Visible = false;#endif      Common.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;    }    #endregion    private 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);    }    #endregion    private 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的,故不建议)

 

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