从 NetworkStream 异步读取时出错

Question

我制作了一个与 IP 摄像机通信的应用程序。这被配置为在预定义的地址上建立连接。 TCP 侦听器正在该地址上运行并接受来自摄像头的连接。当相机连接时，我发送命令以从相机获取 MJpeg 流，相机开始发送流以响应命令。

我正在使用异步方法从套接字读取流。但是一段时间后，我的应用程序在从网络流中读取数据时卡住了。

我正在使用此代码从网络流中读取数据，并且我在屏幕上写了一些消息以获取相机连接的状态。

    private void ReadData()
    {
        try
        {
            string msg = "Reading Data... client connected " + _camClient.Connected.ToString() +
                         "... netStream Readable " +
                         _netStream.CanRead.ToString();
            Console.WriteLine(msg);

            _callback = new AsyncCallback(GetData);
            _buffer = new byte[Buffersize];
            _async = _netStream.BeginRead(_buffer, 0, Buffersize, _callback, null);
        }
        catch (Exception ex) { Console.WriteLine("ReadData: " + ex.Message); }
    }

    private void GetData(IAsyncResult result)
    {
        try
        {
            int read = _netStream.EndRead(result);
            if (read > 0)
            {
                _data = new byte[read];
                Array.Copy(_buffer, 0, _data, 0, read);
                ProcessData();
            }
            ReadData();
        }
        catch (Exception ex) { Console.WriteLine("GetData: " + ex.Message); }
    }

Answer 1

首先，网络流上的异步方法以丢失数据或从不返回数据而闻名！ 在您的情况下，可能是 ProcessData 调用被阻塞。

您应该做的是使用阻塞侦听器（非异步）生成一个新的后台线程，然后在侦听器继续侦听时使用新线程读取数据。 我这里有一个例子。

private static Socket s_chatListener;
public static void Listen(IPAddress LocalIPAddress, int Port)
    {
            IPEndPoint ipend = new IPEndPoint(LocalIPAddress, Port);
            s_chatListener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            s_chatListener.Bind(ipend);
            s_chatListener.Listen(10);


            while (true)
            {
                Socket handler = s_chatListener.Accept();

                ParameterizedThreadStart pst = new ParameterizedThreadStart(loadMessageFromSocket);
                Thread t = new Thread(pst);
                t.Start(handler);


            }
    }


 private static  void loadMessageFromSocket(object socket)
    {
        Socket handler = (Socket)socket;
        string data = "";
        while (true)
        {
            byte[] butes = new byte[1024];
            int rec = handler.Receive(butes);

            data += ASCIIEncoding.ASCII.GetString(butes);

            if (data.IndexOf("\0") > -1)
                break;
        }

        handler.Shutdown(SocketShutdown.Both);
        handler.Close();


        Console.Write(data);
    }

现在只需从主窗体或调用者类中的新线程调用 Listen 方法。 希望这会有所帮助。