C#自定义WebSocketServer写入报Broken pipe错误咨询

• 运行自定义WebSocket服务时抛出异常：Unable to write data to the transport connection: Broken pipe
• 实现方案：基于System.Net.Sockets开发，通过NetworkStream.BeginRead、NetworkStream.EndRead实现异步数据接收，现有连接状态判断逻辑显示Socket未断开
• 触发流程：客户端向服务端发送消息，服务端将消息转发至另一客户端后，向最初发起请求的客户端回发消息时触发写入失败
• 核心疑问：
  1. 写入操作失败的根本原因
  2. 报错信息中提到的pipe是否指代网络流管道

对应SendData方法实现代码如下：

private void SendData(byte[] data, PayloadDataType opcode)
    {
        byte[] sendData;
        BitArray firstByte = new(new bool[] {
                // opcode
                opcode == PayloadDataType.Text || opcode == PayloadDataType.Ping,
                opcode == PayloadDataType.Binary || opcode == PayloadDataType.Pong,
                false,
                opcode == PayloadDataType.ConnectionClose || opcode == PayloadDataType.Ping
                    || opcode == PayloadDataType.Pong,
                false,  //Reserved bit 3
                false,  //Reserved bit 2
                false,  //Reserved bit 1
                true,   //Final bit
            });

        if (data.Length < 126)
        {
            sendData = new byte[data.Length + 2];
            firstByte.CopyTo(sendData, 0);
            sendData[1] = (byte)data.Length;    
            data.CopyTo(sendData, 2);
        }
        else
        {
            sendData = new byte[data.Length + 4];
            firstByte.CopyTo(sendData, 0);
            sendData[1] = 126;
            var lengthData = BitConverter.GetBytes((ushort)data.Length);
            if (BitConverter.IsLittleEndian)
            {
                Array.Reverse(lengthData);
            }

            Array.Copy(lengthData, 0, sendData, 2, 2);
            data.CopyTo(sendData, 4);
        }

        NetworkStream? stream = null;
        stream = _tcpClient.GetStream();
        if (stream is null)
        {
            Logger.Error($"stream is null ??. [{GetIDAndHash()}]");
            return;
        }
        string? log;
        if (stream.CanWrite)
        {
            stream.Write(sendData, 0, sendData.Length);
            LastTransferPacket = DateTime.Now;
            log = $"send completed, length: {sendData.Length}, sendData: {Environment.NewLine}";
            log += $"------------------------------------{Environment.NewLine}";
            log += $"{Encoding.UTF8.GetString(sendData)}{Environment.NewLine}";
            log += $"------------------------------------{Environment.NewLine}";
        }
        else
        {
            log = $"It's a not writable. {GetIDAndHash()}";
        }
        
        Logger.Info(log);
    }

1. 写入失败的根本原因 #

Broken pipe错误的核心触发逻辑是：TCP连接的对端已经主动关闭/异常重置了连接，本地端仍尝试向连接写入数据。你判断Socket未断开的结论是不准确的，.NET中Socket.Connected、NetworkStream.CanWrite属性仅反映上一次IO操作完成时的连接状态，不会主动实时探测对端存活情况，连接在两次IO操作间隙被对端关闭时，这两个属性仍会返回true。
结合你的业务场景和代码，具体触发原因大概率是以下几种：

• 客户端提前断开连接：你转发消息到其他客户端的处理耗时过长，首个客户端等待超时主动断开、客户端进程意外退出、客户端收到非法数据触发主动断连，都会先向服务端发送FIN/RST包，此时服务端的异步读操作还没感知到连接断开，执行写入就会触发异常。
• WebSocket帧构造存在缺陷，触发客户端主动断连：
  • 现有代码未处理载荷长度超过65535的场景：按照WebSocket协议，载荷长度>=65536时第二个字节应设为127，后续跟随8字节的64位长度值，你的代码只要长度>=126就统一按2字节长度处理，发送大载荷时会生成非法帧，客户端解析失败会直接断开连接。
  • 未做发送并发控制：你使用异步接收+同步发送的逻辑，若多个线程同时调用SendData向同一个NetworkStream写入数据，会出现WebSocket帧交错，客户端收到不符合格式的帧会直接断连。
  • 控制帧处理逻辑缺失：如果客户端发送了Ping/Close等控制帧，你没有按协议要求回复对应Pong/Close帧，直接发送业务消息，也会触发客户端断开。
• 首次写入触发RST返回：当对端已经关闭连接时，第一次写入操作会收到对端返回的RST包，第二次写入就会直接抛出Broken pipe异常。

2. 报错中pipe的含义 #

这里的pipe不是指代C#中的网络流管道、Pipeline或者命名管道，是操作系统内核层面对于TCP连接传输通道的通用抽象：内核为每个TCP连接维护独立的发送/接收缓冲区，逻辑上类似一个双向传输管道，当对端关闭连接后，这个内核层面的传输通道被销毁，就会返回Broken pipe错误，这个错误是Windows、类Unix系统Socket层的通用错误码，和上层的流封装无关。

• 补全WebSocket帧构造逻辑：增加载荷长度超过65535时的8字节长度处理，严格按RFC6455规范构造帧头。
• 替换连接状态判断逻辑：不要依赖Connected/CanWrite属性判断连接可用性，异步读操作返回0字节时直接判定为对端正常断开，主动清理连接资源；所有发送、接收操作都要包裹try/catch，捕获到Socket/IO异常时及时释放对应连接。
• 为发送逻辑加并发锁：同一个NetworkStream同一时间只允许一个线程写入，避免帧交错。
• 补全WebSocket控制帧处理逻辑：收到Ping帧立即回复Pong，收到Close帧按协议回复Close帧后再关闭连接，连接进入关闭流程后禁止发送业务数据。

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