Redis——Redis与Log4Net完成了分布式日志记录

一，思路

           为了单独记录我们程序中各种异常，我们这样做：创建一个队列，当出现异常的时候，将异常放入到队列中，另外，我们在程序启动时，开启一个线程，用来从存放异常的队列中取得异常信息，进行写入文件。

        模拟代码：

                自定义异常出现时候的处理类：

                       public class MyExceptionAttribute:System.Web.Mvc.HandleErrorAttribute
{
//存放异常的队列
public static Queue<Exception> exceptionQueue = new Queue<Exception>();

/*处理异常信息*/
public override void OnException(System.Web.Mvc.ExceptionContext filterContext)
{

exceptionQueue.Enqueue(filterContext.Exception); //将异常信息入队
filterContext.HttpContext.Response.Redirect("/error.html");//跳转到错误页
base.OnException(filterContext);
}
}

           修改filterConfig中的方法（当出现异常时候，将异常交给我们的自定义类进行处理）：

public static void RegisterGlobalFilters(GlobalFilterCollection filters)
{
// filters.Add(new HandleErrorAttribute());
filters.Add(new MyExceptionAttribute());
}
        

     修改应用程序入口方法：

         protected void Application_Start()
{
AreaRegistration.RegisterAllAreas();

WebApiConfig.Register(GlobalConfiguration.Configuration);
FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
RouteConfig.RegisterRoutes(RouteTable.Routes);
BundleConfig.RegisterBundles(BundleTable.Bundles);

//通过线程池开启一个线程，然后不停地从队列中获取数据
String logPath = Server.MapPath("/Log/");
ThreadPool.QueueUserWorkItem(o => {
while (true)
{
try
{
if (MyExceptionAttribute.exceptionQueue.Count > 0)
{
Exception e=MyExceptionAttribute.exceptionQueue.Dequeue();//从队列中拿出数据
if (e != null)
{
//构建日志的完整路径
String fileName = logPath + DateTime.Now.ToString("yyyy-MM-dd")+".txt";

string errorMsg = e.ToString();
File.AppendAllText(fileName,errorMsg,Encoding.Default);//异常写入文件

}
else
{
Thread.Sleep(30);
}
}
else
{
Thread.Sleep(30);//避免cpu空转
}
}
catch(Exception e)
{
MyExceptionAttribute.exceptionQueue.Enqueue(e);
}

}
}, logPath);
}
}

二，使用redis做异常信息队列，使用log4net进行日志处理

   在大型网站中，我们将异常信息队列从应用程序服务器中分离开来，在这里，使用redis存放我们的异常信息，但产生异常信息之后，将异常信息交给我们的log4net处理。
     

      修改队列：

public class MyExceptionAttribute:System.Web.Mvc.HandleErrorAttribute
{
//存放异常的队列
// public static Queue<Exception> exceptionQueue = new Queue<Exception>();
public static IRedisClientsManager clientManager = new PooledRedisClientManager(new String[]{"127.0.0.1:6379"});

public static IRedisClient reidsClient = clientManager.GetClient();

/*处理异常信息*/
public override void OnException(System.Web.Mvc.ExceptionContext filterContext)
{

//exceptionQueue.Enqueue(filterContext.Exception); //将异常信息入队

reidsClient.EnqueueItemOnList("exception", filterContext.Exception.ToString());//将异常信息存储到redis队列中
filterContext.HttpContext.Response.Redirect("/error.html");//跳转到错误页
base.OnException(filterContext);
}
}

   

        改用log4net处理错误信息：

       protected void Application_Start()
{
log4net.Config.XmlConfigurator.Configure();//获取log4net配置信息（具体配置在web.config中）

AreaRegistration.RegisterAllAreas();

WebApiConfig.Register(GlobalConfiguration.Configuration);
FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
RouteConfig.RegisterRoutes(RouteTable.Routes);
BundleConfig.RegisterBundles(BundleTable.Bundles);

//通过线程池开启一个线程，然后不停地从队列中获取数据
String logPath = Server.MapPath("/Log/");
ThreadPool.QueueUserWorkItem(o => {
while (true)
{
try
{
// if (MyExceptionAttribute.exceptionQueue.Count > 0)
if (MyExceptionAttribute.reidsClient.GetListCount("exception") > 0)
{
//Exception e=MyExceptionAttribute.exceptionQueue.Dequeue();//从队列中拿出数据
String errorMsg = MyExceptionAttribute.reidsClient.DequeueItemFromList("exception"); //从redis中取出异常信息数据
if (errorMsg != null)
{
//构建日志的完整路径
// String fileName = logPath + DateTime.Now.ToString("yyyy-MM-dd")+".txt";

// string errorMsg = e.ToString();
// File.AppendAllText(fileName, errorMsg, Encoding.Default);//异常写入文件

/*使用log4net进行写入错误信息*/
ILog logger = LogManager.GetLogger("appError");
logger.Error(errorMsg);//将异常信息写入log4net中

}
else
{
Thread.Sleep(30);
}
}
else
{
Thread.Sleep(30);//避免cpu空转
}
}
catch(Exception e)
{
MyExceptionAttribute.reidsClient.EnqueueItemOnList("exception", e.ToString());//将异常信息存储到redis队列中
}

}
}, logPath);
}
}

ps:log4net配置文件：

<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>

处理节点配置：

<section name="log4net" type="log4net.Config.Log4NetConfigurationSectionHandler,log4net"/>
<!--Log4Net配置-->

   在网站正常使用中，我们的redis服务器一般是跟我们的应用服务器分离开的，这样我们的队列就不占用应用服务器的资源了，再扩展，我们的日志也可以单独从应用服务器剥离开来，做到服务器专用。