利用多线程实现对网站状态的监控

     如果有200个站点，通过Ping 测试站点是否正常，如果每次ping用时为0.5秒，那么至少要花掉100秒，这是个漫长的等待时间，所以可以考虑用多线程来实现。

    注意：使用C#的PingReply 即使返回结果不是IPStatus.Success，站点也有可能访问，因为空间商有可能关闭ICMP服务，或者有防火墙阻止了ping的包。最好是再使用WebClient做一起请求，看是否成功。

   核心代码如下：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.NetworkInformation;
using System.Collections;
using Super.Ft.IDAL;
using Super.Ft.DBFactory;
using Super.Ft.Entity;
using System.Data;
using System.Threading;
using System.Net;
using System.IO;

namespace Super.Ft.BLL
{
    public class ThreadPing
    {
        public SiteConditionEntity SCEntity { get; set; }

        public SiteInfoEntity SiteEntity { get; set; }

        public ThreadPing(SiteInfoEntity s)
        {
            SiteEntity = s;
            SCEntity = new SiteConditionEntity();
        }

        public void search()
        {
            Ping p = new Ping();
            SCEntity.Siteinfoid = SiteEntity.SiteInfoID;
            SCEntity.SiteUrl = SiteEntity.SiteUrl;
            SCEntity.SiteName = SiteEntity.SiteName;
            SCEntity.MonitorDate = DateTime.Now;
            SCEntity.ADDTIME = DateTime.Now;
            try
            {
                PingReply reply = p.Send(SiteEntity.SiteUrl.Replace("http://", string.Empty).Replace(" ", ""));
                StringBuilder sbuilder = new StringBuilder();
                if (reply.Status == IPStatus.Success)
                {
                    SCEntity.Delaytime = reply.RoundtripTime;//延时
                    SCEntity.MonitorCondition = reply.RoundtripTime  "正常";
                }
                else
                {
                    SCEntity.Delaytime = 0;
                    SCEntity.MonitorCondition = "ping不通";
                    ////异常记录
                    //try
                    //{
                    //    WebClient web = new WebClient();
                    //    Stream data = web.OpenRead(SiteEntity.SiteUrl);
                    //    SCEntity.Delaytime = 0;
                    //    SCEntity.MonitorCondition = "正常";
                    //}
                    //catch (Exception)
                    //{

                    //    SCEntity.Delaytime = -1;
                    //    SCEntity.MonitorCondition = "异常";
                    //}
                 
                   // byte[] buffer = web.DownloadData(SiteEntity.SiteUrl);
                  //  string aa = System.Text.Encoding.GetEncoding("gb2312").GetString(buffer);
                    //if (aa.Length > 0)
                    //{
                    //    SCEntity.Delaytime = 0;
                    //    SCEntity.MonitorCondition = "正常";
                    //}
                    //else
                    //{
                    //    SCEntity.Delaytime = -1;
                    //    SCEntity.MonitorCondition = "异常";
                    //}
                }
            }
            catch
            {
                //异常记录
                SCEntity.Delaytime = -1;
                SCEntity.MonitorCondition = "异常";
            }
        }
    }

    public class ThreadManage
    {
        Thread[] t;
        public List<SiteInfoEntity> SiteEntityList { get; set; }

        public List<SiteConditionEntity> SCEntityList { get; set; }
        public ThreadManage(List<SiteInfoEntity> list)
        {
            t = new Thread[list.Count];
            SiteEntityList = list;
            SCEntityList = new List<SiteConditionEntity>();

        }

        public void Start()
        {
            ThreadPing wp;
            for (int lIdx = 0; lIdx < SiteEntityList.Count; lIdx++)
            {
                wp = new ThreadPing(SiteEntityList[lIdx]);

                SCEntityList.Add(wp.SCEntity);
                t[lIdx] = new Thread(new ThreadStart(wp.search));
                // start the Thread object, which executes the search().
                t[lIdx].Start();
            }

            for (int lIdx = 0; lIdx < SiteEntityList.Count; lIdx++)
            {
                // waiting for all the Threads to finish.
                t[lIdx].Join();
            }
        }
    }


}

    前段调用如下：

   public static List<SiteConditionEntity> LiveMeshPingSiteInfo()
        {
           
            List<SiteInfoEntity> SiteEntityList = SiteInfoBLL.LoadSiteList();
            DateTime lStarted = DateTime.Now;
            ThreadManage tm = new ThreadManage(SiteEntityList);
        
            tm.Start();
         
            TimeSpan _timeSpent = DateTime.Now.Subtract(lStarted);
            return tm.SCEntityList;


          
        }