针对“将 OnLog 日志实时保存至本地”的需求，我们需要在现有的 WinForm 架构中引入 **持久化存储机制**。优化的核心在于平衡 **I/O 性能** 与 **数据完整性**：既要避免每行日志都进行一次磁盘写入（导致性能瓶颈），又要确保在程序异常崩溃时关键日志不丢失。 以下是结合了 **异步双缓冲队列** 与 **定时刷盘策略** 的深度优化方案。 ### 1. 技术方案设计 在多线程环境下，直接在 UI 线程或后台线程进行同步文件写入会阻塞线程，导致界面卡顿或上传任务延迟。建议采用 **生产者-消费者模式**： | 模块 | 职责 | 技术选型 | | :--- | :--- | :--- | | **日志采集** | 接收所有日志消息，不阻塞业务线程 | `ConcurrentQueue` (线程安全队列) | | **日志持久化** | 后台线程定时从队列取出并写入文件 | `Task.Run` + `StreamWriter` | | **异常恢复** | 确保程序关闭时剩余日志写入磁盘 | `Flush` 机制 + `Dispose` 模式 | ### 2. 核心代码实现 #### 2.1 日志服务层 创建一个独立的 `FileLogger` 类，专门负责处理日志的队列缓冲和文件写入。该类支持单例模式或静态实例，确保全局统一管理日志文件。 ```csharp using System; using System.Collections.Concurrent; using System.IO; using System.Text; using System.Threading; using System.Threading.Tasks; namespace WinFormApp.Services { public class FileLogger : IDisposable { private readonly BlockingCollection<string> _logQueue; private readonly CancellationTokenSource _cts; private readonly Task _consumerTask; private readonly string _logFilePath; private readonly int _flushIntervalMs = 1000; // 每1秒刷盘一次，或队列积压时立即写入 public FileLogger(string directoryPath) { if (!Directory.Exists(directoryPath)) { Directory.CreateDirectory(directoryPath); } // 按日期生成日志文件名，例如：Logs_20231027.txt _logFilePath = Path.Combine(directoryPath, $"Logs_{DateTime.Now:yyyyMMdd_HHmmss}.txt"); _logQueue = new BlockingCollection<string>(1000); // 限制队列长度防止内存溢出 _cts = new CancellationTokenSource(); // 启动后台消费者线程 _consumerTask = Task.Run(() => ConsumeLogsAsync(_cts.Token)); } // 外部调用：写入日志 public void EnqueueLog(string logText) { if (!_logQueue.IsAddingCompleted) { // 尝试添加，如果队列满则丢弃或等待（此处选择TryAdd避免阻塞） _logQueue.TryAdd(logText); } } // 后台线程：消费队列并写入文件 private async Task ConsumeLogsAsync(CancellationToken token) { using (var fileStream = new FileStream(_logFilePath, FileMode.Append, FileAccess.Write, FileShare.Read)) using (var writer = new StreamWriter(fileStream, Encoding.UTF8)) { // 开启自动刷盘缓冲区，提高性能 writer.AutoFlush = false; try { foreach (var log in _logQueue.GetConsumingEnumerable(token)) { await writer.WriteLineAsync(log); // 策略：如果队列积压严重，立即刷新，否则依赖定时或自然缓冲 if (_logQueue.Count > 100) { await writer.FlushAsync(); } } } catch (OperationCanceledException) { // 任务取消是正常行为 } finally { // 确保最后的数据写入磁盘 await writer.FlushAsync(); } } } public void Dispose() { _logQueue.CompleteAdding(); // 通知队列不再添加新数据 _cts.Cancel(); // 取消消费线程 try { // 等待消费线程处理完剩余日志 _consumerTask.Wait(TimeSpan.FromSeconds(5)); } catch (AggregateException) { // 忽略等待中的超时或错误 } _cts.Dispose(); } } } ``` #### 2.2 集成到 MainForm 在主窗体中实例化 `FileLogger`，并在原有的 `UploadService_Log` 事件中调用日志队列。 ```csharp public partial class MainForm : Form { private FileUploadService _uploadService; private FileLogger _fileLogger; // 新增日志文件实例 public MainForm() { InitializeComponent(); InitializeCustomControls(); // 初始化日志保存路径，建议放在程序目录下的 Logs 文件夹 string appDir = AppDomain.CurrentDomain.BaseDirectory; string logDir = Path.Combine(appDir, "Logs"); _fileLogger = new FileLogger(logDir); } // 优化：同时更新 UI 和写入文件 private void UploadService_Log(object sender, FileUploadService.LogEventArgs e) { // 1. 格式化日志文本 string timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); string logLine = $"[{timestamp}] {(e.IsError ? "[ERROR]" : "[INFO]")} {e.LogText}"; // 2. 异步写入本地文件（非阻塞，极速返回） _fileLogger.EnqueueLog(logLine); // 3. 更新 UI（需判断线程） if (txtLog.InvokeRequired) { txtLog.Invoke(new Action(() => UpdateUiLog(logLine, e.IsError))); } else { UpdateUiLog(logLine, e.IsError); } } private void UpdateUiLog(string logLine, bool isError) { if (txtLog.IsDisposed) return; txtLog.SuspendLayout(); try { // 根据错误类型设置颜色 if (isError) { txtLog.SelectionStart = txtLog.TextLength; txtLog.SelectionLength = 0; txtLog.SelectionColor = Color.Red; txtLog.AppendText(logLine + Environment.NewLine); txtLog.SelectionColor = txtLog.ForeColor; // 恢复颜色 } else { txtLog.AppendText(logLine + Environment.NewLine); } txtLog.ScrollToCaret(); // UI 内存保护逻辑（保持不变） if (txtLog.Lines.Length > 500) { txtLog.Text = txtLog.Text.Substring(txtLog.Text.IndexOf('\n') + 1); } } finally { txtLog.ResumeLayout(); } } // 窗体关闭时释放资源，确保日志全部落盘 protected override void OnFormClosing(FormClosingEventArgs e) { _fileLogger?.Dispose(); // 关键：触发 Flush 和队列清理 base.OnFormClosing(e); } } ``` ### 3. 关键优化点解析 1. **BlockingCollection vs ConcurrentQueue**： 代码中使用了 `BlockingCollection`，它是对 `ConcurrentQueue` 的封装。其优势在于 `GetConsumingEnumerable` 方法，当队列为空时，消费者线程会自动挂起（不占用 CPU），一旦有新日志加入立即唤醒。这比 `Timer` 轮询检查队列效率更高 [ref_1]。 2. **异步 I/O (Async/Await)**： 在 `ConsumeLogsAsync` 中使用 `StreamWriter.WriteLineAsync`。传统的同步写入在大量日志时（例如每秒几百条）会占用线程池资源，导致界面响应变慢。异步 I/O 利用 I/O 完成端口，几乎不消耗 CPU 线程等待时间。 3. **AutoFlush 策略**： 设置 `writer.AutoFlush = false` 是性能优化的关键。每次写入都调用 `Flush` 会强制操作系统将缓冲区内容物理写入磁盘，速度极慢。我们的策略是：仅在队列积压过多（>100）或程序关闭（`Dispose`）时强制刷盘，平时让操作系统决定最佳刷盘时机。 4. **资源释放保证**： 在 `MainForm` 的 `OnFormClosing` 事件中调用 `_fileLogger.Dispose()`。这一步至关重要，它调用 `CompleteAdding` 停止队列接收，并等待后台线程处理完剩余日志后再退出，防止用户关闭窗口后丢失最后几条日志。 ### 4. 扩展建议 * **日志分级**：如果需要更精细的控制，可以重载 `EnqueueLog` 方法，增加 `LogLevel` 参数，并在文件名或内容中区分。 * **日志滚动**：为了防止单个日志文件过大，可以在 `FileLogger` 中检查文件大小，超过 10MB 时自动创建新的日志文件（如 `Logs_001.txt`, `Logs_002.txt`）。 通过此方案，您的程序将拥有**企业级的日志记录能力**，既保证了前端的流畅体验，又实现了后台数据的可靠持久化。