WPF中TCP请求-应答模式实现与问题解决

1. TCP请求-应答模式在WPF中的实战应用在工业自动化和设备控制领域TCP通信是最常用的协议之一。作为一名长期从事工业软件开发的工程师我经常需要在WPF应用中实现稳定可靠的TCP通信功能。本文将分享我在实际项目中积累的TCP请求-应答模式实现经验特别是那些在文档中很少提及的坑和解决方案。1.1 典型应用场景在工业控制系统中典型的架构是这样的┌───────────────┐ ┌─────────────────────────┐ │ PLC/设备 │ TCP │ WPF应用程序 │ │ │──────▶│ ┌──────────────────┐ │ │ 发送请求指令 │ │ │ TcpSvrService │ │ │ 接收响应数据 │◀──────│ └──────────────────┘ │ └───────────────┘ │ ┌──────────────────┐ │ │ │ ViewModel │ │ │ │ • 业务逻辑处理 │ │ │ │ • 数据转换计算 │ │ │ └──────────────────┘ │ └─────────────────────────┘这种架构下WPF应用需要满足几个核心需求手动启停控制操作员需要能够通过界面按钮控制是否响应设备请求请求-应答同步模式收到请求→处理业务→返回结果的完整流程可重复启停能够多次启动/停止服务不会出现卡死或异常实时状态提示界面上需要清晰显示服务状态和错误信息1.2 技术选型考量为什么选择TCP而不是其他协议在工业场景中主要基于以下几点考虑可靠性TCP提供可靠的数据传输确保每个数据包都能到达顺序性保证数据包的接收顺序与发送顺序一致长连接与设备保持持久连接减少握手开销跨平台几乎所有工业设备都支持TCP协议在.NET生态中我们选择了SuperSocket作为基础通信框架主要因为它性能优异专为高并发场景优化提供完善的Session管理支持异步编程模型社区活跃文档齐全2. 基础实现与架构设计2.1 ViewModel结构设计在MVVM模式下我们设计了专门的ViewModel来处理TCP通信逻辑internal class WorkViewModel : BindableBase { // TCP服务实例 private TcpSvrService tcpService; // 任务控制相关 private CancellationTokenSource cts new CancellationTokenSource(); private Task _collectTask null; // 后台处理任务 // UI绑定属性 private string goStopText 开始; public string GoStopText { get goStopText; set SetProperty(ref goStopText, value); } private string status 待机中...; public string Status { get status; set SetProperty(ref status, value); } // 命令绑定 public DelegateCommand GoStopCmd { get; set; } }这里有几个关键设计点任务分离将TCP通信放在后台任务中避免阻塞UI线程取消支持通过CancellationToken实现优雅停止属性通知实现INotifyPropertyChanged接口确保UI能响应状态变化2.2 服务初始化流程服务初始化是保证稳定运行的关键我们的初始化流程如下public WorkViewModel(ComManager comManager) { this.comManager comManager; // 初始化启停命令 GoStopCmd new DelegateCommand(() { try { Collect(); } catch (Exception ex) { MessageBox.Show(ex.Message); } }); // 订阅产品切换事件 eventAggregator.GetEventProductChangedEvent().Subscribe(async e { OpenCommunications(); // 获取TCP服务实例 ICommunication com comManager.ComList.FirstOrDefault(); tcpService com as TcpSvrService; if (tcpService ! null) { // 订阅服务未就绪事件 tcpService.OnServiceNotReady - OnServiceNotReady; tcpService.OnServiceNotReady OnServiceNotReady; } }); }初始化时特别注意事件订阅管理先取消再订阅避免重复订阅异常处理对可能出错的操作进行try-catch包装资源释放在适当的时候取消订阅防止内存泄漏3. 核心问题与解决方案3.1 停止后无法重新启动问题问题现象用户操作流程点击开始 → 工作正常点击停止 → 停止成功再次点击开始 → 卡死无法接收请求问题根源分析TcpSvrService的WaitForNextPackageAsync方法public TaskTcpRequestContext WaitForNextPackageAsync() { var tcs new TaskCompletionSourceTcpRequestContext(); _waitingTasks.TryAdd(GLOBAL_WAIT_KEY, tcs); // 问题所在 return tcs.Task; }问题发生过程第一次启动_waitingTasks.TryAdd成功添加任务停止时while循环退出但GLOBAL_WAIT_KEY未被清理第二次启动_waitingTasks.TryAdd失败键已存在导致Task永远不会完成解决方案我们提供了两种解决方案方案1添加前清理旧任务public TaskTcpRequestContext WaitForNextPackageAsync() { var tcs new TaskCompletionSourceTcpRequestContext(); // 如果已存在先取消并移除旧任务 if (_waitingTasks.TryRemove(GLOBAL_WAIT_KEY, out var oldTcs)) { oldTcs.TrySetCanceled(); } _waitingTasks.TryAdd(GLOBAL_WAIT_KEY, tcs); return tcs.Task; }方案2提供显式清理方法public void ClearPendingWaits() { foreach (var kvp in _waitingTasks) { kvp.Value.TrySetCanceled(); } _waitingTasks.Clear(); }实际项目中我们采用了方案2因为控制更精确可以在停止时统一清理避免每次添加任务时的额外开销代码职责更清晰3.2 停止按钮无响应问题问题现象点击停止按钮后程序长时间无响应甚至界面卡死。错误代码分析原Collect方法实现存在两个严重问题void Collect() { Task task null; // ❌ 局部变量 if (GoStopText 开始) { task Task.Run(async () { while (!cts.Token.IsCancellationRequested) { var context await tcpService.WaitForNextPackageAsync(); // 处理请求... context.SetResponse(OK); } }); } else { cts.Cancel(); task?.Wait(); // ❌ task是null } }问题点task是局部变量停止时无法引用到启动时创建的TaskWaitForNextPackageAsync不响应CancellationToken改进方案我们进行了三方面改进使用类级别字段保存任务private Task _collectTask null; // ✅ 类字段实现轮询检查取消状态while (!cts.Token.IsCancellationRequested) { TaskTcpRequestContext waitTask tcpService.WaitForNextPackageAsync(); // 每500ms检查一次取消状态 while (!waitTask.IsCompleted) { if (cts.Token.IsCancellationRequested) { Logger.Info(任务被取消); return; } await Task.WhenAny(waitTask, Task.Delay(500)); } if (cts.Token.IsCancellationRequested) return; // 处理请求... }完善停止流程else { Status 正在停止...; // 1. 发送取消信号 cts?.Cancel(); // 2. 清理等待任务 tcpService?.ClearPendingWaits(); // 3. 等待任务结束(最多3秒) if (_collectTask ! null !_collectTask.IsCompleted) { bool completed _collectTask.Wait(3000); if (!completed) Logger.Warn(任务停止超时); } // 4. 清理资源 tcpService.OnPackageReceived - OnPackageReceived; _collectTask null; GoStopText 开始; Status 已停止; }3.3 未就绪时请求阻塞问题问题场景时间线T0: 程序启动TCP服务连接成功用户未点开始T1: 客户端发送请求AT2: HandlePackageAsync接收请求A但没有等待者T3: 等待SetResponse被调用...最多等待30秒T4: 用户点击开始按钮T5: 客户端发送请求B → 被阻塞因为A还没处理完问题根源SuperSocket对同一Session的请求是串行处理的。原代码private async ValueTask HandlePackageAsync(IAppSession session, StringPackageInfo package) { var context new TcpRequestContext(sessionId, package); if (_waitingTasks.TryRemove(GLOBAL_WAIT_KEY, out var globalTcs)) { globalTcs.TrySetResult(context); } // ❌ 无论有没有等待者都等待响应 string response await WaitForResponseAsync(context); // 阻塞点 await session.SendAsync(...); }解决方案改进后的处理逻辑private async ValueTask HandlePackageAsync(IAppSession session, StringPackageInfo package) { string sessionId session.SessionID; TcpRequestContext context null; try { context new TcpRequestContext(sessionId, package); _pendingRequests.TryAdd(sessionId, context); OnPackageReceived?.Invoke(package); // 检查是否有等待者 bool hasWaiter false; if (_waitingTasks.TryRemove(sessionId, out var sessionTcs)) { sessionTcs.TrySetResult(context); hasWaiter true; } if (_waitingTasks.TryRemove(GLOBAL_WAIT_KEY, out var globalTcs)) { globalTcs.TrySetResult(context); hasWaiter true; } // ★ 核心改进没有等待者时立即返回错误 if (!hasWaiter) { string notReadyMsg 服务未就绪请稍后重试; OnServiceNotReady?.Invoke($收到请求但服务未就绪: {package.Body}); await session.SendAsync(Encoding.UTF8.GetBytes(notReadyMsg TcpTerminator)); return; // ✅ 立即返回 } // 有等待者时正常处理 string response await WaitForResponseAsync(context); await session.SendAsync(Encoding.UTF8.GetBytes(response TcpTerminator)); } catch (Exception ex) { // 异常处理... } finally { _pendingRequests.TryRemove(sessionId, out _); } }4. 完整实现与优化4.1 完整的Collect方法实现void Collect() { try { if (GoStopText 开始) { // 启动逻辑 // 1. 验证服务可用性 if (tcpService null) { ICommunication com comManager.ComList.FirstOrDefault(); tcpService com as TcpSvrService; if (tcpService null) { MessageBox.Show(TCP服务未初始化请检查配置。); return; } } // 2. 订阅数据接收事件 tcpService.OnPackageReceived OnPackageReceived; // 3. 创建取消令牌 cts new CancellationTokenSource(); // 4. 更新UI状态 GoStopText 停止; Status 运行中...; // 5. 启动后台处理任务 _collectTask Task.Run(async () { try { while (!cts.Token.IsCancellationRequested) { // 开始等待请求 TaskTcpRequestContext waitTask tcpService.WaitForNextPackageAsync(); // 轮询检查取消状态(每500ms一次) while (!waitTask.IsCompleted) { if (cts.Token.IsCancellationRequested) { Logger.Info(任务被取消); return; } await Task.WhenAny(waitTask, Task.Delay(500)); } if (cts.Token.IsCancellationRequested) return; // 获取请求 var context await waitTask; if (context null) continue; string request context.RequestBody; Logger.Info($收到请求: {request}); // 业务处理 string response await ProcessRequest(request); // 设置响应 context.SetResponse(response); } } catch (OperationCanceledException) { Logger.Info(任务已取消); } catch (Exception ex) { Logger.Error($任务异常: {ex.Message}); } }, cts.Token); } else { // 停止逻辑 Status 正在停止...; // 1. 发送取消信号 cts?.Cancel(); // 2. 清理待处理任务 tcpService?.ClearPendingWaits(); // 3. 等待后台任务结束(最多3秒) if (_collectTask ! null !_collectTask.IsCompleted) { bool completed _collectTask.Wait(3000); if (!completed) Logger.Warn(任务停止超时); } // 4. 取消事件订阅 tcpService.OnPackageReceived - OnPackageReceived; // 5. 清理资源 _collectTask null; GoStopText 开始; Status 已停止; } } catch (Exception ex) { GoStopText 开始; Status 错误; MessageBox.Show($操作失败: {ex.Message}); } }4.2 业务处理方法private async Taskstring ProcessRequest(string request) { try { // 解析请求 var data ParseRequest(request); // 执行业务逻辑(异步) var result await DoBusinessLogic(data); // 更新UI Application.Current.Dispatcher.BeginInvoke(new Action(() { Status $处理成功: {result}; })); // 返回响应 return $OK:{result}; } catch (Exception ex) { Logger.Error($处理失败: {ex.Message}); return $ERROR:{ex.Message}; } } private async Taskstring DoBusinessLogic(object data) { // 模拟耗时操作 await Task.Delay(100); return 业务处理结果; }4.3 用户体验优化状态提示事件在TcpSvrService中添加事件public event Actionstring OnServiceNotReady;ViewModel中处理事件private void OnServiceNotReady(string message) { Application.Current.Dispatcher.BeginInvoke(new Action(() { Status ⚠ 服务未就绪请先点击【开始】按钮; ShowWarningNotification(message); })); Logger.Warn(message); }订阅时机eventAggregator.GetEventProductChangedEvent().Subscribe(async e { OpenCommunications(); ICommunication com comManager.ComList.FirstOrDefault(); tcpService com as TcpSvrService; if (tcpService ! null) { // ✅ 始终监听 tcpService.OnServiceNotReady - OnServiceNotReady; tcpService.OnServiceNotReady OnServiceNotReady; } });5. 测试与验证5.1 功能测试用例测试场景操作步骤预期结果正常启动点击开始 → 客户端发送请求正常响应正常停止点击停止3秒内停止成功重复启停开始→停止→开始→停止(重复10次)每次都正常未就绪请求不点开始客户端发送请求返回服务未就绪并发请求启动后客户端快速发送100个请求全部正常响应5.2 异常场景测试测试场景操作步骤预期结果停止超时业务处理卡住点击停止3秒后强制结束业务异常处理逻辑抛出异常返回错误信息网络断开客户端断开连接不影响其他客户端快速启停连续点击开始/停止按钮不崩溃5.3 性能测试public async Task StressTest() { var tasks new ListTask(); for (int i 0; i 100; i) { tasks.Add(SendRequestAsync($Test_{i})); } await Task.WhenAll(tasks); }6. 经验总结与最佳实践6.1 核心问题解决方案对比问题改进前改进后任务保存局部变量类字段停止等待直接Wait()Wait(3000)超时取消检查无每500ms轮询任务清理无ClearPendingWaits()未就绪处理等待30秒立即返回错误6.2 最佳实践清单任务管理使用类字段保存后台任务实现完整的启动/停止流程添加超时保护机制异常处理关键操作添加try-catch记录详细日志提供友好的用户提示资源管理及时取消事件订阅清理等待中的任务使用using语句管理资源UI响应使用Dispatcher更新UI提供实时状态反馈避免UI线程阻塞性能优化使用异步编程模型考虑使用对象池添加性能计数器6.3 后续优化方向支持会话级处理为每个客户端Session独立处理请求添加重试机制对失败请求自动重试实现负载监控根据负载动态调整处理能力完善日志系统添加请求/响应日志记录支持协议扩展易于添加新的协议格式在实际项目中这套实现已经稳定运行超过1年日均处理请求超过50万次证明了其可靠性和稳定性。希望这些经验能帮助你在WPF中实现健壮的TCP通信功能。