一步步开发自己的博客 番外篇（7、异步记录日志 和 文章阅读量统计）

离前一篇《 一步步开发自己的博客  .NET版（6、手机端的兼容） 》都个把月了。

当时写完第六篇，很多人问“剧终”了？你还有好多实现没有讲解分析呢。我说没呢，后期还会有第二版、第三版...至于还没有分析到，后期补上。你看，我今天不就来了么。

前段时间写代码，手都写的酸痛酸痛的，歇息了几天，好多了。然后，又捣鼓了一下webapi。这也是个没有接触过的知识。跌跌撞撞的整了点东西出来。有兴趣写移动端的同学可以联系我，大家一起学习。API文档和测试地址： http://haojima.net/SwaggerUI

using System; using System.Collections.Generic; using System.ComponentModel; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Web; namespace CommonLib.HiLog {  /// <summary>  /// 日志模型  /// </summary>  internal class LogModel  {      #region logFileName   private string _logFileName;   /// <summary>   /// 日志文件名字   /// </summary>   public string logFileName   {    get { return _logFileName + "_" + DateTime.Now.ToString("yyyyMMdd"); }    set { _logFileName = value; }   }   #endregion   #region logMessg   private string _logMessg;   /// <summary>   /// 日志内容   /// </summary>   public string logMessg   {    get    {     return "----begin-------" + DateTime.Now.ToString() + "----Queue.Count：" + LogHelper.LogQueue.Count + "-----------------------------------/r/n/r/n"      + _logMessg      + "/r/n/r/n----end----------" + DateTime.Now.ToString() + "----Queue.Count：" + LogHelper.LogQueue.Count + "-----------------------------------"      + "/r/n/r/n/r/n";    }    set { _logMessg = value; }   }   #endregion  } } 

using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks; namespace CommonLib.HiLog {  /// <summary>  /// 日志操作辅助类  /// zhaopeiym@163.com  /// 创建20150104 修改20151003  /// </summary>  internal class LogHelper  {   /// <summary>   /// 消息队列   /// </summary>   private static Queue<LogModel> logQueue = new Queue<LogModel>();   /// <summary>   /// 消息队列 对外只读   /// </summary>   public static Queue<LogModel> LogQueue   {    get { return LogHelper.logQueue; }   }   /// <summary>   /// 标志锁   /// </summary>   static string myLock = "true";   /// <summary>   /// 写入日志文件（异步单线程 记录日志）   /// </summary>   /// <param name="logmede"></param>   public static void logWrite(LogModel logmede)   {    // 这里需要锁上 不然会出现：源数组长度不足。请检查 srcIndex 和长度以及数组的下限。异常       //网上有资料说 http://blog.csdn.net/greatbody/article/details/26135057  不能多线程同时写入队列    //其实  不仅仅 不能同时写入队列 也不能同时读和写如队列  所以  在Dequeue 取的时候也要锁定一个对象    lock (myLock)     logQueue.Enqueue(logmede);    logStartWrite();   }   /// <summary>   /// 文件编码格式   /// </summary>   public static Encoding encoding = Encoding.Default;   /// <summary>   /// 是否开始自动记录日志   /// </summary>   private static bool isStart = false;   /// <summary>   /// 用来 标识 最好一次 检测是否 需要 清理 日志文件 时间   /// </summary>   private static DateTime time = DateTime.MinValue;   /// <summary>   /// 每个日志文件夹 对应的文件下标   /// </summary>   private static Dictionary<string, int> logFileNum = new Dictionary<string, int>();   /// <summary>   /// 开始把队列消息写入文件   /// </summary>   private static void logStartWrite()   {    if (isStart)     return;    isStart = true;    Task.Run(() =>    {     while (true)     {      if (LogHelper.logQueue.Count >= 1)      {       LogModel m = null;       lock (myLock)        m = LogHelper.logQueue.Dequeue();       if (m == null)        continue;       if (string.IsNullOrEmpty(LogConfig.logFilePath))        throw new Exception("请先初始化日志保存路径LogModel._logFilePath");       TestingInvalid();       if (!Directory.Exists(LogConfig.logFilePath + m.logFileName + @"/"))        Directory.CreateDirectory(LogConfig.logFilePath + m.logFileName + @"/");       // int i = m.logFileNum;       if (!logFileNum.Keys.Contains(m.logFileName))        logFileNum.Add(m.logFileName, 0);       //部分 日志 文件路径       string SectionfileFullName = LogConfig.logFilePath + m.logFileName + @"/" + m.logFileName + "_" + logFileNum[m.logFileName].ToString("000") + ".txt";       //最新的写了内容的 部分 日志文件路径       string TopSectionfileFullName = SectionfileFullName;       // 需要实时更新的 最新日志文件 路径       string LogfileFullNqme = LogConfig.logFilePath + m.logFileName + @"/" + m.logFileName + ".txt";       FileInfo file = new FileInfo(SectionfileFullName);       while (file.Exists && file.Length >= LogConfig.SectionlogFileSize)       {        TopSectionfileFullName = SectionfileFullName;        logFileNum[m.logFileName]++;        SectionfileFullName = LogConfig.logFilePath + m.logFileName + @"/" + m.logFileName + "_" + logFileNum[m.logFileName].ToString("000") + ".txt";        file = new FileInfo(SectionfileFullName);       }       try       {        if (!file.Exists)//如果不存在 这个文件 就说明需要 创建新的部分日志文件了        {         //因为SectionfileFullName路径的文件不存在 所以创建         File.WriteAllText(SectionfileFullName, m.logMessg, encoding);         FileInfo Logfile = new FileInfo(LogfileFullNqme);         if (Logfile.Exists && Logfile.Length >= LogConfig.FileSize)          //先清空  然后加上 上一个部分文件的内容          File.WriteAllText(LogfileFullNqme, File.ReadAllText(TopSectionfileFullName, encoding), encoding);//如果存在则覆盖                 }        else         File.AppendAllText(SectionfileFullName, m.logMessg, encoding);//累加        //追加这次内容 到动态更新的日志文件        File.AppendAllText(LogfileFullNqme, m.logMessg, encoding);       }       catch (Exception ex)       {        throw ex;       }      }      else      {       isStart = false;//标记下次可执行       break;//跳出循环      }     }    });   }   /// <summary>   /// 检测 并删除 之前之外的 日志文件   /// </summary>   public static void TestingInvalid()   {    #region 检测 并删除 之前之外的 日志文件    if (time.AddMinutes(LogConfig.TestingInterval) <= DateTime.Now)// 时间内 检测一次    {     try     {      time = DateTime.Now;      List<string> keyNames = new List<string>();      foreach (var logFileName in logFileNum.Keys)      {       CreatePath(LogConfig.logFilePath + logFileName + @"/");       DirectoryInfo dir = new DirectoryInfo(LogConfig.logFilePath + logFileName + @"/");       if (dir.CreationTime.AddMinutes(LogConfig.DelInterval) <= DateTime.Now)//删除 设定时间 之前的日志        foreach (var fileInfo in dir.GetFiles())        {         if (fileInfo.LastWriteTime.AddMinutes(LogConfig.DelInterval) <= DateTime.Now)//最后修改时间算起          File.Delete(fileInfo.FullName);        }       if (dir.GetFiles().Length == 0)        keyNames.Add(logFileName);//临时存储没有日志文件的文件夹      }      foreach (var key in keyNames)//删除没有日志文件的文件夹      {       logFileNum.Remove(key);       Directory.Delete(LogConfig.logFilePath + key + @"/", false);      }     }     catch (Exception ex)     {      LogSave.ErrLogSave("手动捕获[检测并删除日志出错！]", ex, "记录日志出错");     }        }    #endregion   }   #region  创建路径   /// <summary>   /// 创建路径   /// </summary>   /// <param name="paht"></param>   /// <returns></returns>   public static bool CreatePath(string paht)   {    if (!Directory.Exists(paht))    {     Directory.CreateDirectory(paht);     return true;    }    return false;   }   #endregion  } } 

using System; using System.Collections.Generic; using System.Configuration; using System.Data; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Web; namespace CommonLib.HiLog {  /// <summary>  /// 日志相关配置   /// </summary>  public static class LogConfig  {   #region 辅助方法   /// <summary>   /// GetAppSettings   /// </summary>   /// <param name="key"></param>   /// <returns></returns>   public static string GetAppSettings(string key)   {    if (ConfigurationManager.AppSettings.AllKeys.Contains(key))     return ConfigurationManager.AppSettings[key].ToString();    return string.Empty;   }   /// <summary>   /// 计算字符串 转 计算结果   /// </summary>   /// <param name="v"></param>   /// <returns></returns>   public static string toCompute(this string v)   {    return new DataTable().Compute(v, "").ToString();   }   #endregion   #region 静态属性和字段   #region logFilePath 路径   /// <summary>   /// 日志要存的路径 默认路径：网站根目录 + Log 文件夹   /// 在程序第一次启动是设置   /// </summary>       private static string _logFilePath;   /// <summary>   /// 日志要存的路径 默认路径：网站根目录 + Log 文件夹   /// 在程序第一次启动是设置   /// </summary>      public static string logFilePath   {    get    {     if (string.IsNullOrEmpty(_logFilePath))     {      try      {       _logFilePath = HttpContext.Current.Server.MapPath("~/");      }      catch (Exception)      {       try       {        _logFilePath = System.Windows.Forms.Application.StartupPath + @"/";       }       catch (Exception)       {        throw new Exception("请先初始化要保存的路径：LogModel._logFilePath");       }      }     }     return _logFilePath;    }    set    {     _logFilePath = value;    }   }   #endregion   #region 检测间隔时间（分钟）   private static int _TestingInterval;   /// <summary>   /// 检测间隔时间（分钟） 默认：一天   /// 配置：appSettings->Log_TestingInterval 单位：秒   /// </summary>   public static int TestingInterval   {    get    {     if (_TestingInterval <= 0)     {      var Log_TestingInterval = GetAppSettings("Log_TestingInterval");      if (string.IsNullOrEmpty(Log_TestingInterval))       _TestingInterval = 1 * 60 * 24;      else       _TestingInterval = Convert.ToInt32(Log_TestingInterval.toCompute());     }     return _TestingInterval;    }   }   #endregion   #region 删除 N分钟（最后修改时间）之前的的日志   private static int _DelInterval;   /// <summary>   /// 删除 N分钟（最后修改时间）之前的的日志 默认：15天   /// 配置：appSettings->Log_DelInterval 单位：秒   /// </summary>   public static int DelInterval   {    get    {     if (_DelInterval <= 0)     {      var Log_DelInterval = GetAppSettings("Log_DelInterval");      if (string.IsNullOrEmpty(Log_DelInterval))       _DelInterval = 1 * 60 * 24 * 15;      else       _DelInterval = Convert.ToInt32(Log_DelInterval.toCompute());     }     return _DelInterval;    }   }   #endregion   #region 部分日志文件大小(Byte)   private static int _SectionlogFileSize;   /// <summary>   /// 部分日志文件大小(Byte) 默认：1024Byte * 1024 * 1 = 1MB   /// 配置：appSettings->Log_SectionlogFileSize 单位：Byte   /// </summary>   public static int SectionlogFileSize   {    get    {     if (_SectionlogFileSize <= 0)     {      var Log_SectionlogFileSize = GetAppSettings("Log_SectionlogFileSize");      if (string.IsNullOrEmpty(Log_SectionlogFileSize))       _SectionlogFileSize = 1024 * 1024 * 1;      else       _SectionlogFileSize = Convert.ToInt32(Log_SectionlogFileSize.toCompute());     }     return _SectionlogFileSize;    }   }   #endregion   #region 变动文件大小(Byte)   private static int _FileSize;   /// <summary>   /// 变动文件大小(Byte) 默认：1024 * 1024 * 4 = 4M   /// 配置：appSettings->Log_FileSize 单位：Byte   /// </summary>   public static int FileSize   {    get    {     if (_FileSize <= 0)     {      var Log_FileSize = GetAppSettings("Log_FileSize");      if (string.IsNullOrEmpty(Log_FileSize))       _FileSize = 1024 * 1024 * 4;      else       _FileSize = Convert.ToInt32(Log_FileSize.toCompute());     }     return _FileSize;    }   }   #endregion   #endregion  } } 

using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Web; namespace CommonLib.HiLog {  /// <summary>  /// 异步单线程  /// </summary>  public class LogSave  {   /// <summary>   /// 获得Exception 的详细信息   /// </summary>   /// <param name="ex"></param>   /// <returns></returns>   public static string GetExceptionInfo(Exception ex)   {    StringBuilder str = new StringBuilder();    str.Append("错误信息：" + ex.Message);    str.Append("/r/n错误源：" + ex.Source);    str.Append("/r/n异常方法：" + ex.TargetSite);    str.Append("/r/n堆栈信息：" + ex.StackTrace);    return str.ToString();   }   /// <summary>   /// 系统 自动 捕捉异常   /// 保存异常详细信息    /// 包括： 浏览器  浏览器版本 操作系统 页面  Exception   /// </summary>   /// <param name="ex"></param>   /// <param name="fileName">文件名 默认：SysErr</param>   public static void SysErrLogSave(Exception ex, string fileName = null)   {    StringBuilder str = new StringBuilder();    string ip = "";    if (HttpContext.Current.Request.ServerVariables.Get("HTTP_X_FORWARDED_FOR") != null)     ip = HttpContext.Current.Request.ServerVariables.Get("HTTP_X_FORWARDED_FOR").ToString().Trim();    else     ip = HttpContext.Current.Request.ServerVariables.Get("Remote_Addr").ToString().Trim();    str.Append("Ip:" + ip);    str.Append("/r/n浏览器:" + HttpContext.Current.Request.Browser.Browser.ToString());    str.Append("/r/n浏览器版本:" + HttpContext.Current.Request.Browser.MajorVersion.ToString());    str.Append("/r/n操作系统:" + HttpContext.Current.Request.Browser.Platform.ToString());    str.Append("/r/n页面：" + HttpContext.Current.Request.Url.ToString());    str.Append("/r/n" + GetExceptionInfo(ex));    LogHelper.logWrite(new LogModel()    {     logFileName = "SysErr" + fileName ?? string.Empty,     logMessg = str.ToString()    });   }   /// <summary>   /// 异常日志记录   /// </summary>   /// <param name="strmes"></param>   /// <param name="ex"></param>   public static void ErrLogSave(string strmes, Exception ex, string fileName = null)   {    StringBuilder str = new StringBuilder();    str.Append(strmes);    if (ex != null)     str.Append("/r/n" + GetExceptionInfo(ex));    LogHelper.logWrite(new LogModel()    {     logFileName = fileName ?? "Err",     logMessg = str.ToString()    });   }   /// <summary>   /// 警告日志记录   /// </summary>   /// <param name="str"></param>   public static void WarnLogSave(string str, string fileName = null)   {    if (str != null && !string.IsNullOrEmpty(str.Trim()))     LogHelper.logWrite(new LogModel()     {      logFileName = fileName ?? "Warn",      logMessg = str     });   }   /// <summary>   /// 追踪日志记录   /// </summary>   /// <param name="str"></param>   public static void TrackLogSave(string str, string fileName = null)   {    if (str != null && !string.IsNullOrEmpty(str.Trim()))     LogHelper.logWrite(new LogModel()     {      logFileName = fileName ?? "Track",      logMessg = str     });   }   /// <summary>   /// 追踪日志记录   /// </summary>   /// <param name="str"></param>   public static void TrackLogSave(string str)   {    if (!string.IsNullOrEmpty(str.Trim()))     LogHelper.logWrite(new LogModel()     {      logFileName = "SqlTrack",      logMessg = str     });   }  } } 

如果您对本篇文章感兴趣，那就麻烦您点个赞，您的鼓励将是我的动力。

当然您还可以加入QQ群: 469075305 讨论。

如果您有更好的处理方式，希望不要吝啬赐教。

一步步开发自己的博客 .NET版系列： http://www.cnblogs.com/zhaopei/tag/Hi-Blogs/

本文链接： http://www.cnblogs.com/zhaopei/p/4887573.html