文件並發(日志處理)--隊列--Redis+Log4Net

多線程操作同一個文件時會出現並發問題。解決的一個辦法就是給文件加鎖(lock),但是這樣的話，一個線程操作文件時，其它的都得等待，這樣的話性能非常差。另外一個解決方案，就是先將數據放在隊列中，然后開啟一個線程，負責從隊列中取出數據，再寫到文件中。

在這之前，有必要先了解下Redis，關於Redis的介紹可以參考我的這篇博文：ASP.NET Redis 開發

Redis工具和所需資料代碼全下載，地址：http://pan.baidu.com/s/155F6A

下面我們講解一個實際項目中應用的案例，關於日志的處理.這里是使用ASP.NET MVC項目作為Demo。

方式一：使用隊列

思路：把所有產生的日志信息存放到一個隊列里面，然后通過新建一個線程，不斷的從這個隊列里面讀取異常信息，然后往日志里面寫。也就是所謂的生產者、消費者模式。

1、新建一個類MyErrorAttribute,

using System.Web.Mvc;
    public class MyErrorAttribute : HandleErrorAttribute
    {
        public static Queue<Exception> ExceptionQueue = new Queue<Exception>();
        public override void OnException(ExceptionContext filterContext)
        {
            ExceptionQueue.Enqueue(filterContext.Exception);
            filterContext.HttpContext.Response.Redirect("~/Error.html");
            base.OnException(filterContext);
        }
}

2、在FilterConfig類中進行如下修改：

public class FilterConfig
  {
      public static void RegisterGlobalFilters(GlobalFilterCollection filters)
      {
          //filters.Add(new HandleErrorAttribute());

          filters.Add(new MyErrorAttribute());
      }

string filePath = Server.MapPath("~/Logs/");
           ThreadPool.QueueUserWorkItem(o => {
           while(true)
           {
               if (MyErrorAttribute.ExceptionQueue.Count > 0)
               {
                   Exception ex = MyErrorAttribute.ExceptionQueue.Dequeue();
                   if (ex != null)
                   {
                       string fileName = filePath + DateTime.Now.ToString("yyyy-MM-dd") + ".txt";
                       File.AppendAllText(fileName, ex.Message);
                   }
                   else
                   {
                       Thread.Sleep(50);
                   }
               }
               else
               {
                   Thread.Sleep(50);
               }
           }
           });

方式二：使用Redis與Log4Net完成分布式日志記錄

Log4Net是用來記錄日志的，可以將程序運行過程中的信息輸出到一些地方（文件、數據庫、EventLog等），日志就是程序的黑匣子，可以通過

日志查看系統的運行過程，從而發現系統的問題。日志的作用：將運行過程的步驟、成功失敗記錄下來，將關鍵性的數據記錄下來分析系統問題所在。

對於網站來講，不能把異常信息顯示給用戶，異常信息只能記錄到日志，出了問題把日志文件發給開發人員，就能知道問題所在。

配置Log4Net環境

(1)新建一個WebApplication

(2)添加對log4net.dll的引用（bin\net\2.0\release 不能引用debug版本）(把相應的dll文件拷貝到項目中的lib文件夾下。)

(3)在Web.Config （或App.Config）添加配置

(4)初始化：在程序最開始加入log4net.Config.XmlConfigurator.Configure()

在要打印日志的地方LogManager.GetLogger(typeof(Program)).Debug(“信息”); 。通過LogManager.GetLogger傳遞要記錄的日志類類名獲得這個類的ILog（這樣在日志文件中就能看到這條日志是哪個類輸出的了），然后調用Debug方法輸出消息。因為一個類內部不止一個地方要打印日志，所以一般把ILog聲明為一個static字段。

Private static ILog logger=LogManager.GetLogger(typeof(Test))

輸出錯誤信息用ILog.Error方法，第二個參數可以傳遞Exception對象。log.Error("***錯誤"+ex)，log.Error("***錯誤",ex)

Appender：可以將日志輸出到不同的地方，不同的輸出目標對應不同的Appender：RollingFileAppender（滾動文件）、AdoNetAppender（數據庫）、SmtpAppender （郵件）等。

level（級別）：標識這條日志信息的重要級別None>Fatal>ERROR>WARN>DEBUG>INFO>ALL，設定一個

Level，那么低於這個Level的日志是不會被寫到Appender中的.

Log4Net還可以設定多個Appender，可以實現同時將日志記錄到文件、數據、發送郵件等；可以設定不同的Appender的不同的Level，可以實現普通級別都記錄到文件，Error以上級別發送郵件；可以實現對不同的類設定不同的Appender；還可以自定義Appender，這樣可以自己實現將Error信息發短信等.

示例：

1、配置Log4Net，在Web.config中添加如下配置：

<configSections>
    <!-- For more information on Entity Framework configuration, visit http://go.microsoft.com/fwlink/?LinkID=237468 -->
    <section name="entityFramework" type="System.Data.Entity.Internal.ConfigFile.EntityFrameworkSection, EntityFramework, Version=5.0.0.0,
Culture=neutral, PublicKeyToken=b77a5c561934e089" requirePermission="false" />
    <section name="log4net" type="log4net.Config.Log4NetConfigurationSectionHandler, log4net"/>
  </configSections>
  <log4net>
    <!-- OFF, FATAL, ERROR, WARN, INFO, DEBUG, ALL -->
    <!-- Set root logger level to ERROR and its appenders -->
    <root>
      <level value="ALL"/>
      <appender-ref ref="SysAppender"/>
    </root>
    <!-- Print only messages of level DEBUG or above in the packages -->
    <logger name="WebLogger">
      <level value="DEBUG"/>
    </logger>
    <appender name="SysAppender" type="log4net.Appender.RollingFileAppender,log4net" >
      <param name="File" value="App_Data/" />
      <param name="AppendToFile" value="true" />
      <param name="RollingStyle" value="Date" />
      <param name="DatePattern" value=""Logs_"yyyyMMdd".txt"" />
      <param name="StaticLogFileName" value="false" />
      <layout type="log4net.Layout.PatternLayout,log4net">
        <param name="ConversionPattern" value="%d [%t] %-5p %c - %m%n" />
        <param name="Header" value="----------------------header--------------------------" />
        <param name="Footer" value="----------------------footer--------------------------" />
      </layout>
    </appender>
    <appender name="consoleApp" type="log4net.Appender.ConsoleAppender,log4net">
      <layout type="log4net.Layout.PatternLayout,log4net">
        <param name="ConversionPattern" value="%d [%t] %-5p %c - %m%n" />
      </layout>
    </appender>
  </log4net>

2、添加ServiceStack.dll、ServiceStack.Interfaces.dll、ServiceStack.ServiceInterface.dll、log4net.dll的引用，然后新建一個類MyErrorAttribute,

using System.Web.Mvc;
using ServiceStack.Redis;
 public static IRedisClientsManager clientsManager = new PooledRedisClientManager(new string[] { "127.0.0.1:6379"});
        public static IRedisClient redisClient = clientsManager.GetClient();

        public override void OnException(ExceptionContext filterContext)
        {
            redisClient.EnqueueItemOnList("errorMsg", filterContext.Exception.ToString());
            filterContext.HttpContext.Response.Redirect("~/Error.html");
            base.OnException(filterContext);
        }

3、在FilterConfig類中進行如下修改：

 public class FilterConfig
    {
        public static void RegisterGlobalFilters(GlobalFilterCollection filters)
        {
            //filters.Add(new HandleErrorAttribute());

            //filters.Add(new MyErrorAttribute());
            filters.Add(new MyExceptionAttribute());
        }
}

4、在Gobal.asax.cs中的Application_Start事件里添加如下代碼：

log4net.Config.XmlConfigurator.Configure(); //獲取Log4Net配置信息
            ThreadPool.QueueUserWorkItem(o =>
            {
                while (true)
                {
                    if (MyExceptionAttribute.redisClient.GetListCount("errorMsg") > 0)
                    {
                        string msg = MyExceptionAttribute.redisClient.DequeueItemFromList("errorMsg");
                        if (!string.IsNullOrEmpty(msg))
                        {
                            ILog logger=LogManager.GetLogger("testError");
                            logger.Error(msg); //將異常信息寫入Log4Net中
                        }
                        else
                        {
                            Thread.Sleep(50);
                        }
                    }
                    else
                    {
                        Thread.Sleep(50);
                    }
                }
            });