C#多线程写日志

由于程序是3层架构的,所有多线程记录日志成了比较棘手的问题,以前还真就没有在意过写日志的问题,认为不过是写文件罢了~~!如今发现原来要实现文件共享,并且能够使多线程同时操作日志还不能相互冲突,真的很麻烦。当然要实现它我首先想到的是在网上搜,结果可能是我搜的不得其法,没发现结果,多数都是用lock,mutx等线程锁或互斥的方式写日志,偶想这样和单线程有啥区别吗?还是没能起到多线程应该有的效率!

后来问朋友,发现个log4net的东西,不过此物依然用到了线程互斥,看了源码发现的!

网络不行,朋友不知道,只好自己想办法。想了几种方法如下:

1、写多个文件,然后找个机会把这些文件合并!

2、干脆放弃写文件,改写数据库!

3、把文件看成一个表结构,实现行级锁。也就是一个线程写一行。

4、把文件看成内存块,每块写完再合并!

以上几种方法缺点:

1、多个文件。。。想起来就恶心!

2、写数据库?太没技术含量咱不干!

3、行级锁?我一个线程要写入多行不是看起来很乱?

4、没想到啥缺点,实现它吧!

以下是偶经过了10000线程并发测试,也没发现问题的代码!

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Text;
  4. namespace MTW
  5. {
  6. public class MTWFile
  7. {
  8. private string _fileName;
  9. private static Dictionary<long, long> lockDic = new Dictionary<long, long>();
  10. /// <summary>
  11. /// 获取或设置文件名称
  12. /// </summary>
  13. public string FileName
  14. {
  15. get { return _fileName; }
  16. set { _fileName = value; }
  17. }
  18. /// <summary>
  19. /// 构造函数
  20. /// </summary>
  21. /// <param name="byteCount">每次开辟位数大小,这个直接影响到记录文件的效率</param>
  22. /// <param name="fileName">文件全路径名</param>
  23. public MTWFile(string fileName)
  24. {
  25. _fileName = fileName;
  26. }
  27. /// <summary>
  28. /// 创建文件
  29. /// </summary>
  30. /// <param name="fileName"></param>
  31. public void Create(string fileName)
  32. {
  33. if (!System.IO.File.Exists(fileName))
  34. {
  35. using (System.IO.FileStream fs = System.IO.File.Create(fileName))
  36. {
  37. fs.Close();
  38. }
  39. }
  40. }
  41. /// <summary>
  42. /// 写入文本
  43. /// </summary>
  44. /// <param name="content">文本内容</param>
  45. private void Write(string content, string newLine)
  46. {
  47. if (string.IsNullOrEmpty(_fileName))
  48. {
  49. throw new Exception("FileName不能为空!");
  50. }
  51. using (System.IO.FileStream fs = new System.IO.FileStream(_fileName, System.IO.FileMode.OpenOrCreate, System.IO.FileAccess.ReadWrite, System.IO.FileShare.ReadWrite, 8, System.IO.FileOptions.Asynchronous))
  52. {
  53. //Byte[] dataArray = System.Text.Encoding.ASCII.GetBytes(System.DateTime.Now.ToString() + content + "/r/n");
  54. Byte[] dataArray = System.Text.Encoding.Default.GetBytes(content + newLine);
  55. bool flag = true;
  56. long slen = dataArray.Length;
  57. long len = 0;
  58. while (flag)
  59. {
  60. try
  61. {
  62. if (len >= fs.Length)
  63. {
  64. fs.Lock(len, slen);
  65. lockDic[len] = slen;
  66. flag = false;
  67. }
  68. else
  69. {
  70. len = fs.Length;
  71. }
  72. }
  73. catch (Exception ex)
  74. {
  75. while (!lockDic.ContainsKey(len))
  76. {
  77. len += lockDic[len];
  78. }
  79. }
  80. }
  81. fs.Seek(len, System.IO.SeekOrigin.Begin);
  82. fs.Write(dataArray, 0, dataArray.Length);
  83. fs.Close();
  84. }
  85. }
  86. /// <summary>
  87. /// 写入文件内容
  88. /// </summary>
  89. /// <param name="content"></param>
  90. public void WriteLine(string content)
  91. {
  92. this.Write(content, System.Environment.NewLine);
  93. }
  94. /// <summary>
  95. /// 写入文件
  96. /// </summary>
  97. /// <param name="content"></param>
  98. public void Write(string content)
  99. {
  100. this.Write(content, "");
  101. }
  102. }
  103. }

调用起来很简单,实例化,然后随便调用一个write或writeLine方法!

上一篇:Spring + mybatis整合方案总结 结合实例应用


下一篇:理解 Nova 架构 - 每天5分钟玩转 OpenStack(23)