使用windows服务和MSMQ和进行日志管理（解决高并发问题）

/// <summary>
/// 接收来自MSMQ的消息，并保存到数据库
/// </summary>
public class MessageQueueService
{
    public static bool blnStopThread;
    public static string exTemp = string.Empty;

    public MessageQueueService()
    {
        //
        // TODO: 在此处添加构造函数逻辑
        //
    }

    public static void Start()
    {
        string queuePath = ".\\Private$\\zzl";
        IsQueueExists(queuePath);
        MessageQueue myQueue = new MessageQueue(queuePath);

        myQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(Log) });

        do
        {
            try
            {
                // Receive and format the message.
                Message myMessage = myQueue.Receive(); //当消息队列空时，线程会挂起
                Log log = (Log)myMessage.Body;

                if (log == null) return;

                Save(log);//保存到数据库，此处略详细代码
            }
            catch (System.Exception ex)
            {
                //异常处理
                //……
            }
        } while (blnStopThread == false);
    }

    private static void IsQueueExists(string path)
    {
        if (!MessageQueue.Exists(path))
        {
            MessageQueue.Create(path);
        }
    }

  

private static void Save(Log entity)
      {
          using (SqlConnection sqlconn = new SqlConnection(System.Configuration.ConfigurationManager.ConnectionStrings["conn"].ToString()))
          {
              using (SqlCommand sqlcomm = new SqlCommand(
                  "INSERT INTO [Web_Logs]([LogID],[FromURL],[ExeSQL],[FromSystem],[HttpMethod],[OccurTime],[info]) VALUES (@LogID,@FromURL,@ExeSQL,@FromSystem,@HttpMethod,@OccurTime,@Info);"
                  , sqlconn))
              {
                  SqlParameter parameter = new SqlParameter("@ExceptionID", SqlDbType.VarChar, 36);
                  parameter.Value = Guid.NewGuid().ToString();
                  sqlcomm.Parameters.Add(parameter);

                  parameter = new SqlParameter("@LogID", SqlDbType.VarChar, 36);
                  parameter.Value = entity.ID;
                  sqlcomm.Parameters.Add(parameter);

                  parameter = new SqlParameter("@FromURL", SqlDbType.VarChar, 200);
                  parameter.Value = string.Empty;
                  sqlcomm.Parameters.Add(parameter);

                  parameter = new SqlParameter("@ExeSQL", SqlDbType.VarChar, 1000);
                  parameter.Value = string.Empty;
                  sqlcomm.Parameters.Add(parameter);

                  parameter = new SqlParameter("@FromSystem", SqlDbType.Int);
                  parameter.Value = 1;
                  sqlcomm.Parameters.Add(parameter);

                  parameter = new SqlParameter("@HttpMethod", SqlDbType.VarChar, 50);
                  parameter.Value = string.Empty;
                  sqlcomm.Parameters.Add(parameter);

                  parameter = new SqlParameter("@Info", SqlDbType.VarChar, 50);
                  parameter.Value = entity.Info;
                  sqlcomm.Parameters.Add(parameter);

                  parameter = new SqlParameter("@OccurTime", SqlDbType.DateTime);
                  parameter.Value = entity.OccerTime;
                  sqlcomm.Parameters.Add(parameter);

                  sqlconn.Open();
                  sqlcomm.ExecuteNonQuery();
                  sqlconn.Close();
              }
          }
      }

public class Log
{
    public string ID { get; set; }

    public string Info { get; set; }

    public DateTime OccerTime { get; set; }

    public void PrintAll()
    {
        Console.WriteLine("{0}  {1}  {2}", ID, Info, OccerTime);
    }
}

      this.timer1 = new System.Timers.Timer();
      this.timer1.Start();
      this.timer1.Interval = 1000;
      this.timer1.Elapsed += new System.Timers.ElapsedEventHandler(this.timer1_Elapsed);

    /// <summary>
    /// 日志实体
    /// 可以被序列化
    /// </summary>
    [Serializable()]
    public sealed class Log
    {
        public string ID { get; set; }

        public string Info { get; set; }

        public DateTime OccerTime { get; set; }
    }

    /// <summary>
    /// ＭＳＭＱ消息功能密封类
    /// 向消息队列中写入日志信息
    /// </summary>
    public sealed class MSMQLog
    {
        private static object sync = new object();
        private static object syncWrite = new object();
        static volatile MessageQueue writer = null;

        private static MessageQueue MSQWriter
        {
            get
            {
                if (writer == null)
                {
                    lock (sync)
                    {
                        if (writer == null)
                        {
                            string queuePath = ".\\Private$\\zzl";
                            IsQueueExists(queuePath);
                            writer = new MessageQueue(queuePath);
                        }
                    }
                }
                return writer;
            }
        }

        private static void IsQueueExists(string path)
        {
            if (!MessageQueue.Exists(path))
            {
                MessageQueue.Create(path);
            }
        }

        public static void Write(Log log)
        {
            lock (syncWrite)
            {
                MSQWriter.Send(log);
            }
        }
    }