Redis处理文件日志并发(2)

多线程操作同一个文件时会出现并发问题。解决的一个办法就是给文件加锁(lock),但是这样的话,一个线程操作文件时,其它的都得等待,这样的话性能非常差。另外一个解决方案,就是先将数据放在队列中,然后开启一个线程,负责从队列中取出数据,再写到文件中。
 public class MyExceptionAttribute : HandleErrorAttribute
{
public static IRedisClientsManager ClientManager = new PooledRedisClientManager(new string[] {"127.0.0.1:6379"});
public static IRedisClient RedisClient = ClientManager.GetClient();
public override void OnException(ExceptionContext filterContext)
{
RedisClient.EnqueueItemOnList("errorException", filterContext.Exception.ToString());//将异常信息存储到Redis队列中了。
filterContext.HttpContext.Response.Redirect("/error.html");
base.OnException(filterContext);
}
}
 [MyException]
public class HomeController : Controller
{
//
// GET: /Default1/ public ActionResult Index()
{
int a = ;
int b = ;
int c = a / b;
return View();
} }

Global文件

 protected void Application_Start()
{
AreaRegistration.RegisterAllAreas(); WebApiConfig.Register(GlobalConfiguration.Configuration);
FilterConfig.RegisterGlobalFilters(GlobalFilters.Filters);
RouteConfig.RegisterRoutes(RouteTable.Routes);
BundleConfig.RegisterBundles(BundleTable.Bundles); //通过线程开启一个线程,然后不停的从队列中或数据
string filePath = Server.MapPath("/Log/");
ThreadPool.QueueUserWorkItem(x =>
{
while (true)
{
try
{ if (MyExceptionAttribute.RedisClient.GetListCount("errorException") > )
{
string errorMsg = MyExceptionAttribute.RedisClient.DequeueItemFromList("errorException");//从Redis队列中取出异常数据
if(!string.IsNullOrEmpty(errorMsg))
{
//构建成一个完整的路径
string fileName = filePath + DateTime.Now.ToString("yyyy-MM-dd").ToString() + ".txt";
File.AppendAllText(fileName, errorMsg, Encoding.Default);//将异常写到文件中。
}
else
{
Thread.Sleep();
}
}
else
{
Thread.Sleep();//避免了CPU空转。
}
}
catch (Exception ex)
{ MyExceptionAttribute.RedisClient.EnqueueItemOnList("errorException", ex.ToString());
}
}
});
}
上一篇:windows安装mysql示例


下一篇:Windows安装MySQL免安装版