-
C#教程之C#实现线程安全的简易日志记录方法
一般在实际项目的开发中,会要求涉及日志记录的问题,比较常用的有Log4Net,NLog等几个,而小项目小工具的话,则无需费此大驾。而譬如串口开发的话,需要记录串口过来的数据等等,这时候就要考虑日志记录上线程的问题。对此,为了方便后续使用,封装了下代码:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
|
using System; using System.Diagnostics; using System.IO; using System.Text; using System.Threading; namespace CSharpUtilHelpV2 { /// <summary> /// 日志类型枚举 /// </summary> public enum LogType { /// <summary> /// 一般输出 /// </summary> Trace, /// <summary> /// 警告 /// </summary> Warning, /// <summary> /// 错误 /// </summary> Error, /// <summary> /// SQL /// </summary> SQL } /// <summary> /// 基于.NET 2.0日志工具类 /// </summary> public class LogToolV2 { private static readonly Thread LogTask; private static readonly ThreadSafeQueueV2< string > LogColQueue; //自定义线程安全的Queue private static readonly object SyncRoot; private static readonly string FilePath; private static readonly long BackFileSize_MB = 2; //超过2M就开始备份日志文件 static LogToolV2() { SyncRoot = new object (); FilePath = AppDomain.CurrentDomain.SetupInformation.ApplicationBase + "Log\\" ; LogTask = new Thread(WriteLog); LogColQueue = new ThreadSafeQueueV2< string >(); LogTask.Start(); Debug.WriteLine( "Log Start......" ); } /// <summary> /// 记录日志 /// </summary> /// <param name="msg">日志内容</param> public static void Log( string msg) { string _msg = string .Format( "{0} : {2}" , DateTime.Now.ToString( "HH:mm:ss" ), msg); LogColQueue.Enqueue(msg); } /// <summary> /// 记录日志 /// </summary> /// <param name="msg">日志内容</param> /// <param name="type">日志类型</param> public static void Log( string msg, LogType type) { string _msg = string .Format( "{0} {1}: {2}" , DateTime.Now.ToString( "HH:mm:ss" ), type, msg); LogColQueue.Enqueue(_msg); } /// <summary> /// 记录日志 /// </summary> /// <param name="ex">异常</param> public static void Log(Exception ex) { if (ex != null ) { string _newLine = Environment.NewLine; StringBuilder _builder = new StringBuilder(); _builder.AppendFormat( "{0}: {1}{2}" , DateTime.Now.ToString( "HH:mm:ss" ), ex.Message, _newLine); _builder.AppendFormat( "{0}{1}" , ex.GetType(), _newLine); _builder.AppendFormat( "{0}{1}" , ex.Source, _newLine); _builder.AppendFormat( "{0}{1}" , ex.TargetSite, _newLine); _builder.AppendFormat( "{0}{1}" , ex.StackTrace, _newLine); LogColQueue.Enqueue(_builder.ToString()); } } private static void WriteLog() { while ( true ) { if (LogColQueue.Count() > 0) { string _msg = LogColQueue.Dequeue(); Monitor.Enter(SyncRoot); if (!CreateDirectory()) continue ; string _path = string .Format( "{0}{1}.log" , FilePath, DateTime.Now.ToString( "yyyyMMdd" )); Monitor.Exit(SyncRoot); lock (SyncRoot) { if (CreateFile(_path)) ProcessWriteLog(_path, _msg); //写入日志到文本 } ProcessBackLog(_path); //日志备份 } } } private static void ProcessBackLog( string path) { lock (SyncRoot) { if (FileToolV2.GetMBSize(path) > BackFileSize_MB) { FileToolV2.CopyToBak(path); } } } private static void ProcessWriteLog( string path, string msg) { try { StreamWriter _sw = File.AppendText(path); _sw.WriteLine(msg); _sw.Flush(); _sw.Close(); } catch (Exception ex) { Debug.WriteLine( string .Format( "写入日志失败,原因:{0}" , ex.Message)); } } private static bool CreateFile( string path) { bool _result = true ; try { if (!File.Exists(path)) { FileStream _files = File.Create(path); _files.Close(); } } catch (Exception) { _result = false ; } return _result; } private static bool CreateDirectory() { bool _result = true ; try { if (!Directory.Exists(FilePath)) { Directory.CreateDirectory(FilePath); } } catch (Exception) { _result = false ; } return _result; } } } |
测试代码如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
using CSharpUtilHelpV2; using System; using System.Diagnostics; using System.Threading; namespace LogUtilHelpV2Test { class Program { static void Main( string [] args) { try { Debug.WriteLine( "-------------" ); Action _writeLog = delegate () { for ( int i = 0; i < 10000; i++) LogToolV2.Log(Guid.NewGuid().ToString(), LogType.Trace); }; Thread _wireteLogTask1 = new Thread( new ThreadStart(_writeLog)); _wireteLogTask1.Start(); Thread _wireteLogTask2 = new Thread( new ThreadStart(_writeLog)); _wireteLogTask2.Start(); //throw new Exception("test aaa bb cc"); } catch (Exception ex) { LogToolV2.Log(ex); Console.WriteLine(ex.Message.Trim()); } finally { Console.WriteLine( "ok" ); Console.ReadLine(); } } } } |
代码运行效果如下所示:
感兴趣的读者可以自己测试运行一下,希望能对大家起到一点帮助!
栏目列表
最新更新
nodejs爬虫
Python正则表达式完全指南
爬取豆瓣Top250图书数据
shp 地图文件批量添加字段
爬虫小试牛刀(爬取学校通知公告)
【python基础】函数-初识函数
【python基础】函数-返回值
HTTP请求:requests模块基础使用必知必会
Python初学者友好丨详解参数传递类型
如何有效管理爬虫流量?
SQL SERVER中递归
2个场景实例讲解GaussDB(DWS)基表统计信息估
常用的 SQL Server 关键字及其含义
动手分析SQL Server中的事务中使用的锁
openGauss内核分析:SQL by pass & 经典执行
一招教你如何高效批量导入与更新数据
天天写SQL,这些神奇的特性你知道吗?
openGauss内核分析:执行计划生成
[IM002]Navicat ODBC驱动器管理器 未发现数据
初入Sql Server 之 存储过程的简单使用
这是目前我见过最好的跨域解决方案!
减少回流与重绘
减少回流与重绘
如何使用KrpanoToolJS在浏览器切图
performance.now() 与 Date.now() 对比
一款纯 JS 实现的轻量化图片编辑器
关于开发 VS Code 插件遇到的 workbench.scm.
前端设计模式——观察者模式
前端设计模式——中介者模式
创建型-原型模式