当前博文未提及该问题，以下是基于C知道的知识内容为您回答。 针对您在 .NET 4.5.2 WinForm 环境下实现文件上传（含进度条、超时重试、日志记录）的需求，以下提供一个完整的解决方案。该方案基于生产者-消费者模式，结合 `Task` 异步编程，确保界面响应流畅且逻辑严谨。 ### 1. 核心功能架构设计 为了满足“简洁高效”及“任务互斥”的要求，我们将系统划分为三个核心模块： | 模块 | 职责描述 | 关键技术点 | | :--- | :--- | :--- | | **UI 交互层** | 负责进度条更新、日志显示、取消操作 | `ProgressBar`, `TextBox`, `Invoke` [ref_3] | | **逻辑控制层** | 负责任务调度、超时检测、重试策略、状态锁定 | `CancellationTokenSource`, `Task.WhenAny` [ref_4] | | **日志持久层** | 负责日志队列缓冲、异步写入本地文件 | `BlockingCollection`, `StreamWriter` [ref_2] | ### 2. 完整代码实现 #### 2.1 日志服务组件 该组件实现了日志的实时 UI 显示和本地文件保存，采用生产者-消费者模式防止 I/O 阻塞主线程。 ```csharp using System; using System.Collections.Concurrent; using System.IO; using System.Threading; using System.Threading.Tasks; using System.Windows.Forms; public class Logger : IDisposable { private readonly TextBox _uiTextBox; private readonly BlockingCollection<string> _logQueue; private readonly CancellationTokenSource _cts; private readonly string _logFilePath; public Logger(TextBox textBox, string logDirectory) { _uiTextBox = textBox; if (!Directory.Exists(logDirectory)) Directory.CreateDirectory(logDirectory); // 按日期创建日志文件，便于管理 [ref_2] _logFilePath = Path.Combine(logDirectory, $"UploadLog_{DateTime.Now:yyyyMMdd}.txt"); _logQueue = new BlockingCollection<string>(); _cts = new CancellationTokenSource(); // 启动后台线程专门负责写文件，不阻塞 UI Task.Run(() => WriteLogLoop(_cts.Token)); } public void Log(string message, bool isError = false) { string logEntry = $"[{DateTime.Now:HH:mm:ss}] {(isError ? "[ERROR] " : "")}{message}"; // 1. 加入写入队列 if (!_logQueue.IsAddingCompleted) _logQueue.TryAdd(logEntry); // 2. 尝试更新 UI (使用 WinForm 线程模型) try { if (_uiTextBox != null && !_uiTextBox.IsDisposed) { if (_uiTextBox.InvokeRequired) { _uiTextBox.Invoke(new Action(() => AppendText(logEntry, isError))); } else { AppendText(logEntry, isError); } } } catch { /* 忽略 UI 关闭时的异常 */ } } private void AppendText(string text, bool isError) { _uiTextBox.SelectionStart = _uiTextBox.TextLength; _uiTextBox.SelectionLength = 0; _uiTextBox.SelectionColor = isError ? System.Drawing.Color.Red : _uiTextBox.ForeColor; _uiTextBox.AppendText(text + Environment.NewLine); _uiTextBox.ScrollToCaret(); // 限制 TextBox 行数，防止内存溢出 [ref_3] if (_uiTextBox.Lines.Length > 1000) { _uiTextBox.Text = _uiTextBox.Text.Substring(_uiTextBox.Text.IndexOf('\n') + 1); } } private void WriteLogLoop(CancellationToken token) { using (var writer = new StreamWriter(_logFilePath, true, System.Text.Encoding.UTF8)) { foreach (var log in _logQueue.GetConsumingEnumerable(token)) { writer.WriteLine(log); writer.Flush(); // 确保实时写入 } } } public void Dispose() { _logQueue.CompleteAdding(); _cts.Cancel(); _cts.Dispose(); } } ``` #### 2.2 上传服务核心逻辑 包含文件遍历、进度计算、超时控制及重试机制。 ```csharp using System; using System.IO; using System.Linq; using System.Threading; using System.Threading.Tasks; public class FileUploadService { private readonly Logger _logger; private readonly int _maxRetryCount = 3; private readonly int _timeoutMilliseconds = 10000; // 单个文件上传超时时间 10秒 public bool IsBusy { get; private set; } public CancellationTokenSource CurrentCts { get; private set; } // 定义进度报告事件 public event Action<int, int, string> ProgressChanged; // (current, total, fileName) public FileUploadService(Logger logger) { _logger = logger; } public async Task StartUploadAsync(string sourcePath, string targetPath) { // 1. 任务互斥检查 if (IsBusy) { _logger.Log("任务正在执行中，无法添加新任务。", true); return; } IsBusy = true; CurrentCts = new CancellationTokenSource(); try { _logger.Log($"开始扫描目录: {sourcePath}"); // 获取所有文件列表 [ref_1] var files = Directory.GetFiles(sourcePath, "*.*", SearchOption.TopDirectoryOnly); int totalFiles = files.Length; int processedFiles = 0; foreach (var file in files) { CurrentCts.Token.ThrowIfCancellationRequested(); string fileName = Path.GetFileName(file); string destFile = Path.Combine(targetPath, fileName); // 更新进度条状态 processedFiles++; ProgressChanged?.Invoke(processedFiles, totalFiles, fileName); await ProcessFileWithRetryAsync(file, destFile, CurrentCts.Token); } _logger.Log("所有文件上传完成。"); } catch (OperationCanceledException) { _logger.Log("用户取消了任务。", true); } catch (Exception ex) { _logger.Log($"任务发生严重错误: {ex.Message}", true); } finally { IsBusy = false; CurrentCts?.Dispose(); CurrentCts = null; } } private async Task ProcessFileWithRetryAsync(string sourceFile, string destFile, CancellationToken token) { int retryCount = 0; bool success = false; while (!success && retryCount <= _maxRetryCount) { try { token.ThrowIfCancellationRequested(); _logger.Log($"正在上传: {Path.GetFileName(sourceFile)} (尝试 {retryCount + 1}/{_maxRetryCount + 1})"); // 创建上传任务 var uploadTask = UploadFileAsync(sourceFile, destFile, token); // 创建超时控制任务 [ref_4] var timeoutTask = Task.Delay(_timeoutMilliseconds, token); // 竞赛：看谁先完成 var completedTask = await Task.WhenAny(uploadTask, timeoutTask); if (completedTask == timeoutTask) { throw new TimeoutException("上传超时"); } // 等待实际任务抛出可能的异常 await uploadTask; success = true; _logger.Log($"上传成功: {Path.GetFileName(sourceFile)}"); } catch (Exception ex) { retryCount++; if (retryCount > _maxRetryCount) { _logger.Log($"上传失败: {Path.GetFileName(sourceFile)} (达到最大重试次数)。原因: {ex.Message}", true); } else { _logger.Log($"上传失败，准备重试... 原因: {ex.Message}", true); await Task.Delay(1000, token); // 延迟 1 秒后重试 } } } } private async Task UploadFileAsync(string source, string destination, CancellationToken token) { // 模拟文件上传操作 // 如果是局域网共享，使用 File.Copy；如果是 HTTP，使用 WebClient await Task.Run(() => { string destDir = Path.GetDirectoryName(destination); if (!Directory.Exists(destDir)) Directory.CreateDirectory(destDir); // 大文件复制建议使用 FileStream 逐块复制以支持更精确的进度， // 这里为了演示超时逻辑，使用 File.Copy。 File.Copy(source, destination, true); }, token); } public void CancelUpload() { CurrentCts?.Cancel(); } } ``` #### 2.3 WinForm 界面集成 将服务与界面控件绑定，实现进度条和取消功能。 ```csharp using System; using System.IO; using System.Windows.Forms; namespace WinFormUploader { public partial class MainForm : Form { private FileUploadService _uploadService; private Logger _logger; // 配置路径 private readonly string _sourcePath = @"C:\LocalFiles"; private readonly string _targetPath = @"\\PublicServer\SharedFolder"; // 公共盘路径 private readonly string _logPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Logs"); public MainForm() { InitializeComponent(); InitializeServices(); } private void InitializeServices() { // 初始化日志 _logger = new Logger(txtLog, _logPath); // 初始化上传服务 _uploadService = new FileUploadService(_logger); // 订阅进度事件 _uploadService.ProgressChanged += UpdateProgress; } private void btnStart_Click(object sender, EventArgs e) { if (!Directory.Exists(_sourcePath)) { _logger.Log($"源路径不存在: {_sourcePath}", true); return; } // 异步启动，不阻塞 UI _uploadService.StartUploadAsync(_sourcePath, _targetPath); } private void btnCancel_Click(object sender, EventArgs e) { if (_uploadService.IsBusy) { _uploadService.CancelUpload(); } } private void UpdateProgress(int current, int total, string fileName) { // 确保在 UI 线程执行 if (this.InvokeRequired) { this.Invoke(new Action<int, int, string>(UpdateProgress), current, total, fileName); return; } if (total > 0) { progressBar1.Maximum = total; progressBar1.Value = current; lblStatus.Text = $"正在处理 ({current}/{total}): {fileName}"; } } protected override void OnFormClosing(FormClosingEventArgs e) { _logger?.Dispose(); base.OnFormClosing(e); } } } ``` ### 3. 关键技术点解析 1. **进度条显示 (ProgressBar)**： 通过定义 `ProgressChanged` 事件，在 `FileUploadService` 遍历文件时触发。主窗体订阅该事件并更新 `ProgressBar` 的 `Value` 和 `Maximum` 属性，利用 `Invoke` 确保跨线程安全更新 UI [ref_3]。 2. **超时与重试机制**： 使用 `Task.WhenAny(uploadTask, timeoutTask)` 模式。`timeoutTask` 是一个使用 `Task.Delay` 创建的任务。如果 `timeoutTask` 先完成，说明上传操作在规定时间内未完成，抛出 `TimeoutException` 触发 `catch` 块进行重试逻辑 [ref_4]。 3. **任务互斥**： `IsBusy` 标志位在任务开始时置为 `true`，结束时（无论成功、失败还是取消）在 `finally` 块中重置为 `false`。在开始新任务前检查该标志，防止并发执行导致的逻辑混乱。 4. **日志本地保存**： `Logger` 类使用 `BlockingCollection` 作为缓冲队列。UI 线程调用 `Log` 仅是将字符串放入内存队列，非常快速。后台线程单独负责从队列取出并写入磁盘，有效解决了高频日志写入造成的界面卡顿问题 [ref_2]。 ### 4. 应用说明 * **环境兼容性**：代码使用了 .NET 4.5 引入的 `async/await`，完全兼容 .NET 4.5.2。 * **公共盘权限**：请确保运行该程序的 Windows 账户对 `\\PublicServer\SharedFolder` 具有读写权限。 * **大文件优化**：对于特别大的文件，建议将 `File.Copy` 替换为 `FileStream` 读写循环，并在循环中报告更细粒度的进度。