当前博文未提及该问题，以下是基于C知道的知识内容为您回答。 针对您的需求，我们将构建一个基于 **.NET 4.5.2** 的 WinForm 文件上传服务。该方案将严格遵循“简洁高效”的原则，整合了 **任务取消**、**超时重试**、**线程安全日志** 以及 **文件系统遍历** 等核心功能。 ### 1. 核心架构设计 为了保证界面响应流畅且逻辑清晰，我们将采用 **生产者-消费者模式** 结合 **TPL (Task Parallel Library)** 来实现。 | 模块 | 职责描述 | 关键技术 | | :--- | :--- | :--- | | **UI 层** | 显示进度、日志，管理任务状态 | `TextBox`, `ProgressBar`, `Invoke` | | **控制层** | 管理任务锁、取消令牌、文件遍历 | `CancellationTokenSource`, `Directory.GetFiles` [ref_1] | | **服务层** | 执行上传、超时控制、重试逻辑 | `Task`, `HttpClient` (或 `File.Copy`), `try-catch` | | **日志层** | 日志队列缓冲、本地文件写入 | `ConcurrentQueue`, `StreamWriter` [ref_2] | ### 2. 完整代码实现 #### 2.1 日志服务 首先实现一个高性能的日志记录器，支持实时 UI 显示和本地文件保存。 ```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(); // 启动后台写入线程 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(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(); // 限制 UI 内存占用 [ref_3] if (_uiTextBox.Lines.Length > 500) { _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); } } } public void Dispose() { _logQueue.CompleteAdding(); _cts.Cancel(); _cts.Dispose(); } } ``` #### 2.2 上传服务核心 这是处理文件遍历、重试逻辑和超时控制的核心类。 ```csharp using System; using System.IO; using System.Linq; using System.Net; using System.Threading; using System.Threading.Tasks; public class FileUploadService { private readonly Logger _logger; private readonly int _maxRetryCount = 3; private readonly int _timeoutMilliseconds = 5000; // 5秒超时 public bool IsBusy { get; private set; } public CancellationTokenSource CurrentCts { get; private set; } public FileUploadService(Logger logger) { _logger = logger; } public async Task StartUploadAsync(string sourcePath, string targetPath) { if (IsBusy) { _logger.Log("任务正在执行中，无法添加新任务。", true); return; } IsBusy = true; CurrentCts = new CancellationTokenSource(); try { _logger.Log($"开始扫描目录: {sourcePath}"); // 遍历本地文件 [ref_1] var files = Directory.GetFiles(sourcePath, "*.*", SearchOption.TopDirectoryOnly); foreach (var file in files) { CurrentCts.Token.ThrowIfCancellationRequested(); string fileName = Path.GetFileName(file); string destFile = Path.Combine(targetPath, 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); // 使用 Task.WhenAny 实现超时控制 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(() => { // 实际场景中，如果是在局域网内，直接 File.Copy 可能会阻塞，建议放入 Task.Run // 如果目标路径不存在，创建它 string destDir = Path.GetDirectoryName(destination); if (!Directory.Exists(destDir)) Directory.CreateDirectory(destDir); File.Copy(source, destination, true); // 覆盖模式 }, token); } public void CancelUpload() { CurrentCts?.Cancel(); } } ``` #### 2.3 WinForm 界面集成 在 `MainForm` 中整合上述组件，实现自动触发（无需按钮）和取消功能。 ```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(); // 窗体加载完成后自动开始任务 this.Load += (s, e) => { _logger.Log("程序启动，准备自动开始任务..."); StartAutoUpload(); }; } private void InitializeServices() { // 初始化日志 (绑定到 TextBox) _logger = new Logger(txtLog, _logPath); // 初始化上传服务 _uploadService = new FileUploadService(_logger); } private async void StartAutoUpload() { if (!Directory.Exists(_sourcePath)) { _logger.Log($"源路径不存在: {_sourcePath}", true); return; } await _uploadService.StartUploadAsync(_sourcePath, _targetPath); } // 提供手动取消的入口（虽然要求不用按钮触发上传，但通常需要按钮取消） private void btnCancel_Click(object sender, EventArgs e) { if (_uploadService.IsBusy) { _uploadService.CancelUpload(); } } protected override void OnFormClosing(FormClosingEventArgs e) { // 确保程序退出时释放日志资源 _logger?.Dispose(); base.OnFormClosing(e); } } } ``` ### 3. 关键逻辑解析 1. **自动触发机制**： 在 `MainForm` 的构造函数中订阅了 `this.Load` 事件，确保窗体初始化完毕后立即调用 `StartAutoUpload()`，无需用户点击按钮。 2. **超时与重试**： 在 `ProcessFileWithRetryAsync` 方法中，利用 `Task.WhenAny(uploadTask, timeoutTask)` 来判断是上传先完成还是超时先到达。如果超时先到达，抛出 `TimeoutException` 并触发 `catch` 块进行重试计数。重试次数由 `_maxRetryCount` 控制，超过则放弃该文件并记录错误日志。 3. **任务互斥 (IsBusy)**： `FileUploadService` 中维护了 `IsBusy` 标志位。在 `StartUploadAsync` 开始时检查，如果为 `true` 则直接返回，防止重复触发任务导致并发冲突。 4. **日志本地保存**： `Logger` 类使用 `BlockingCollection` 作为生产者-消费者队列。UI 线程或后台线程只需调用 `Log()` 将消息放入队列，后台线程专门负责将队列内容写入本地 TXT 文件，确保了 I/O 操作不会阻塞主线程，实现了日志的实时显示与持久化 [ref_2]。 ### 4. 注意事项 * **网络路径权限**：确保运行 WinForm 程序的 Windows 帐户对公共盘路径（`\\PublicServer\SharedFolder`）具有 **写入权限**。 * **.NET 4.5.2 兼容性**：代码使用了 `async/await` 语法，这是 .NET 4.5 引入的特性，完全兼容 .NET 4.5.2 环境。 * **文件遍历**：使用了 `Directory.GetFiles` 的 `SearchOption.TopDirectoryOnly` 模式。如果需要递归上传子文件夹中的文件，请将其改为 `SearchOption.AllDirectories` [ref_1]。