C# TCP通讯实战：如何用代码控制Trigger与网络调试助手高效通讯

1次阅读

没有评论

共计 2285 个字符，预计需要花费 6 分钟才能阅读完成。

在开发 TCP 通讯应用时，手动调试常常遇到以下问题：

重复操作：每次测试都需要手动输入数据、点击发送按钮
不稳定因素：网络波动导致连接中断时，需要人工干预重新连接
调试效率低：无法快速模拟大量测试场景和边界条件
数据验证困难：接收到的二进制数据需要人工解析验证

这些问题严重影响了开发效率和测试覆盖率，我们需要一种自动化方案来解决这些痛点。

通过代码控制 Trigger 的核心思路是：

建立稳定的 TCP 连接管理机制
实现自动化的数据发送和接收验证
加入智能重连和异常处理
集成数据解析和日志记录

这种方案相比手动调试有以下优势：

可重复执行测试用例
能模拟各种网络异常情况
自动验证通讯结果
生成详细的测试报告

// 创建 TCP 客户端实例
TcpClient client = new TcpClient();

// 设置连接超时时间（毫秒）int connectTimeout = 5000;

// 异步连接服务器
var connectTask = client.ConnectAsync(ipAddress, port);
if (await Task.WhenAny(connectTask, Task.Delay(connectTimeout)) != connectTask)
{throw new TimeoutException("连接服务器超时");
}

// 获取网络流
NetworkStream stream = client.GetStream();

// 设置读写超时（毫秒）stream.ReadTimeout = 3000;
stream.WriteTimeout = 3000;

// 封装发送方法
public async Task SendTriggerCommand(NetworkStream stream, byte[] command)
{
    try
    {
        // 发送数据长度前缀（4 字节）byte[] lengthPrefix = BitConverter.GetBytes(command.Length);
        await stream.WriteAsync(lengthPrefix, 0, 4);

        // 发送实际数据
        await stream.WriteAsync(command, 0, command.Length);

        // 刷新缓冲区确保数据发出
        await stream.FlushAsync();}
    catch (Exception ex)
    {
        // 记录错误日志
        Logger.Error($"发送数据失败: {ex.Message}");
        throw;
    }
}

public async Task<byte[]> ReceiveDataAsync(NetworkStream stream)
{
    // 读取长度前缀
    byte[] lengthBuffer = new byte[4];
    int bytesRead = await stream.ReadAsync(lengthBuffer, 0, 4);

    if (bytesRead != 4)
    {throw new InvalidDataException("接收长度前缀不完整");
    }

    int dataLength = BitConverter.ToInt32(lengthBuffer, 0);

    // 读取实际数据
    byte[] dataBuffer = new byte[dataLength];
    int totalRead = 0;

    while (totalRead < dataLength)
    {
        bytesRead = await stream.ReadAsync(
            dataBuffer, 
            totalRead, 
            dataLength - totalRead);

        if (bytesRead == 0)
        {throw new EndOfStreamException("连接被对方关闭");
        }

        totalRead += bytesRead;
    }

    return dataBuffer;
}

缓冲区大小 ：根据数据包大小调整
小数据包：4KB 缓冲区
大数据流：64KB-256KB 缓冲区
超时设置 ：
连接超时：3- 5 秒
读写超时：根据业务需求设置

KeepAlive：保持长连接

client.Client.SetSocketOption(
    SocketOptionLevel.Socket, 
    SocketOptionName.KeepAlive, 
    true);

对于高并发场景，建议使用线程池处理接收数据：

ThreadPool.QueueUserWorkItem(state => 
{while (isRunning)
    {
        try
        {var data = ReceiveDataAsync(stream).Result;
            ProcessReceivedData(data);
        }
        catch (Exception ex)
        {HandleReceiveError(ex);
        }
    }
});