refactor(RobotJob): 移除HandleClientAsync方法中未使用的robotCrane参数
简化客户端处理方法签名,移除未被使用的机器人状态参数,使接口更清晰
| | |
| | | /// <param name="clientId">客户端标识(通常是 IP 地址)</param> |
| | | /// <param name="cancellationToken">取消令牌</param> |
| | | /// <param name="robotCrane">机器人状态对象</param> |
| | | Task HandleClientAsync(TcpClient client, string clientId, CancellationToken cancellationToken, RobotSocketState robotCrane); |
| | | Task HandleClientAsync(TcpClient client, string clientId, CancellationToken cancellationToken); |
| | | } |
| | | } |
| | |
| | | |
| | | // 异步启动客户端消息处理循环 |
| | | // 使用 TaskContinuationOptions.OnlyOnFaulted 捕获异常情况 |
| | | _ = _tcpSocket.HandleClientAsync(tcpClient, robotCrane.IPAddress, _tcpSocket._cts.Token, latestStateForSubscribe) |
| | | _ = _tcpSocket.HandleClientAsync(tcpClient, robotCrane.IPAddress, _tcpSocket._cts.Token) |
| | | .ContinueWith(t => |
| | | { |
| | | // 如果处理出现异常 |
| | |
| | | /// <param name="cancellationToken">取消令牌</param> |
| | | /// <param name="robotCrane">机器人状态</param> |
| | | /// <returns>任务</returns> |
| | | public Task HandleClientAsync(TcpClient client, string clientId, CancellationToken cancellationToken, RobotSocketState robotCrane) |
| | | public Task HandleClientAsync(TcpClient client, string clientId, CancellationToken cancellationToken) |
| | | { |
| | | return _tcpSocket.HandleClientAsync(client, clientId, cancellationToken, robotCrane); |
| | | return _tcpSocket.HandleClientAsync(client, clientId, cancellationToken); |
| | | } |
| | | } |
| | | } |
| | |
| | | /// <param name="client">TCP 客户端连接</param> |
| | | /// <param name="clientId">客户端唯一标识</param> |
| | | /// <param name="cancellationToken">取消令牌</param> |
| | | /// <param name="robotCrane">机器人状态</param> |
| | | public async Task HandleClientAsync(TcpClient client, string clientId, CancellationToken cancellationToken, RobotSocketState robotCrane) |
| | | public async Task HandleClientAsync(TcpClient client, string clientId, CancellationToken cancellationToken) |
| | | { |
| | | using (client) |
| | | using (NetworkStream networkStream = client.GetStream()) |