NetworkStream.ReadByte随机卡顿致Unity+Hokuyo传感器应用冻结求助

问题背景 #

在Unity应用中使用Hokuyo UAM-05LP-T301以太网传感器，传感器每帧通过以太网发送数据。Unity Profiler显示NetworkStream.ReadByte()正常情况下仅耗时10-20ms，但偶尔会耗时2000-6000ms，直接导致应用冻结无法操作。卡顿现象随机出现，在与传感器交互时频率更高。

当前读取代码 #

static string ReadLine(NetworkStream stream)
{
    if (stream.CanRead)
    {
        StringBuilder sb = new();
        bool is_NL2 = false;
        bool is_NL = false;
        do
        {
            profMarker.Begin();
            char buf = (char)stream.ReadByte();
            profMarker.End();
            if (buf == '\n')
            {
                if (is_NL)
                {
                    is_NL2 = true;
                }
                else
                {
                    is_NL = true;
                }
            }
            else
            {
                is_NL = false;
            }
            sb.Append(buf);
        } while (!is_NL2);

        return sb.ToString();
    }
    else
    {
        return null;
    }
}

已尝试的无效方案 #

• 将ReadLine函数放入线程：应用不再冻结，但传感器输入仍会中断2-6秒
• 设置TCP Client的ReceiveTimeout：冻结情况减少，但输入仍中断，且触发如下错误：

  SocketException: 连接尝试失败，因为连接方在一段时间后未正确响应，或已建立的连接失败，因为连接的主机未能响应。
  
  Rethrow as IOException: 无法从传输连接读取数据：连接尝试失败，因为连接方在一段时间后未正确响应，或已建立的连接失败，因为连接的主机未能响应。
  

问题分析与解决方案 #

1. 替换单字节读取为批量读取 #

ReadByte()每次仅读取一个字节，频繁调用会放大网络IO开销，且极易因网络延迟触发阻塞。改用NetworkStream.Read()批量读取缓冲区：

static string ReadLine(NetworkStream stream)
{
    if (!stream.CanRead) return null;

    StringBuilder sb = new StringBuilder();
    byte[] buffer = new byte[1024]; // 可根据传感器数据量调整缓冲区大小
    bool is_NL = false;
    bool is_NL2 = false;

    while (!is_NL2 && stream.DataAvailable)
    {
        profMarker.Begin();
        int bytesRead = stream.Read(buffer, 0, buffer.Length);
        profMarker.End();

        if (bytesRead <= 0) break;

        for (int i = 0; i < bytesRead; i++)
        {
            char c = (char)buffer[i];
            if (c == '\n')
            {
                if (is_NL)
                {
                    is_NL2 = true;
                    break;
                }
                is_NL = true;
            }
            else
            {
                is_NL = false;
            }
            sb.Append(c);
        }
    }

    return is_NL2 ? sb.ToString() : null;
}

2. 使用异步IO+队列调度避免主线程阻塞 #

单纯将读取逻辑放入线程仍可能因数据处理不及时导致中断，改用NetworkStream.ReadAsync()结合Unity主线程队列调度：

// 在MonoBehaviour脚本中维护线程安全队列，用于传递传感器数据
private readonly ConcurrentQueue<string> _sensorDataQueue = new ConcurrentQueue<string>();
private NetworkStream _stream;

async Task ReadSensorDataAsync()
{
    if (_stream == null || !_stream.CanRead) return;

    byte[] buffer = new byte[1024];
    StringBuilder sb = new StringBuilder();
    bool is_NL = false;
    bool is_NL2 = false;

    while (true)
    {
        try
        {
            int bytesRead = await _stream.ReadAsync(buffer, 0, buffer.Length);
            if (bytesRead <= 0) break;

            for (int i = 0; i < bytesRead; i++)
            {
                char c = (char)buffer[i];
                if (c == '\n')
                {
                    if (is_NL)
                    {
                        is_NL2 = true;
                        break;
                    }
                    is_NL = true;
                }
                else
                {
                    is_NL = false;
                }
                sb.Append(c);
            }

            if (is_NL2)
            {
                _sensorDataQueue.Enqueue(sb.ToString());
                sb.Clear();
                is_NL = false;
                is_NL2 = false;
            }
        }
        catch (IOException ex)
        {
            Debug.LogError($"传感器读取异常: {ex.Message}");
            await ReconnectSensorAsync();
        }
    }
}

// 在Update中处理队列数据，确保逻辑在主线程执行
void Update()
{
    while (_sensorDataQueue.TryDequeue(out string data))
    {
        ProcessSensorData(data); // 替换为你的数据处理逻辑
    }
}

// 实现传感器自动重连逻辑
async Task ReconnectSensorAsync()
{
    _stream?.Close();
    await Task.Delay(1000); // 等待1秒后尝试重连
    // 此处补充TCP连接重建代码
}

3. 优化TCP连接参数 #

• 禁用Nagle算法：设置TcpClient.NoDelay = true，减少小数据包的传输延迟
• 调整接收缓冲区：设置TcpClient.ReceiveBufferSize = 8192（可根据传感器实际数据量调整）
• 合理设置超时时间：避免过短的ReceiveTimeout，建议设置为1000ms以上，防止正常网络波动触发连接断开

4. 排查硬件与网络环境 #

• 检查传感器以太网连接是否松动，尝试更换高品质网线
• 确保传感器与计算机处于同一局域网，避免跨网段或网络拥堵
• 查看传感器官方固件更新，升级到最新版本修复潜在的通信问题

内容的提问来源于stack exchange，提问作者PontusDiinTeam