Redis分布式队列解决文件并发的问题

1.首先将捕获的异常写到Redis的队列中

 

 1  public class MyExceptionAttribute : HandleErrorAttribute  2  {  3         public static IRedisClientsManager clientManager = new PooledRedisClientManager(new string[] { "127.0.0.1:6379", "192.168.1.2:6379" });  4         public static IRedisClient redisClent = clientManager.GetClient();  5         public override void OnException(ExceptionContext filterContext)  6  {  7             base.OnException(filterContext);  8             Exception ex = filterContext.Exception;  9             //接下来就是得加入到队列中进行处理
10             redisClent.EnqueueItemOnList("errorMsg", ex.ToString()); 11             //跳转到错误页面
12             filterContext.HttpContext.Response.Redirect("/Error.html"); 13  } 14     }

2.而后单独开启一个线程对捕获的数据写到文件中去

  public void StartDealLog() { string filePath = Server.MapPath("/Log/"); ThreadPool.QueueUserWorkItem((a) => { while (true) { if (MyExceptionAttribute.redisClent.GetListCount("errorMsg")>0) { // Exception ex = MyExceptionAttribute.MyExceptionQueue.Dequeue();
                        string ex=MyExceptionAttribute .redisClent.DequeueItemFromList("errorMsg"); if (ex != null) { //将错误写到日志中取
                            ILog logger = LogManager.GetLogger("errorMsg"); logger.Error(ex); } else { Thread.Sleep(3000); } } else {//将当前线程挂起（就近）
                        Thread.Sleep(3000); } } },filePath); }

3.关于上面的代码的思考

对于每个错误，IIS所在的服务器都会启动一个线程，这对程序服务器压力仍是很大的，因此能够考虑使用Redis的分布式，将上面的处理代码单独放到一台异常处理服务器上，能够是一个控制台程序或者网站程序，只要把上面的代码复制过去就能够了