最后一个适合这个网站的问题。

我有一个 .NET TCP 服务器。这是我的第一台服务器，运行良好。客户端的加入、管理和可以加入聊天室等。但是，大约 30 分钟后，在建立一个客户端后，我在 NetworkStream.ReadAsync 期间收到 System.StackOverflowException。我完全不知道问题是什么。每次都会发生。

以下是有关我的 TCP 服务器的客户端类的重要详细信息，其中在客户端加入时会创建一个新的客户端。

    public class Client {

        public TcpClient tcpClient;

        public NetworkStream stream;

        public CancellationTokenSource cts = new CancellationTokenSource();

        private byte[] readBuffer = new byte[1024];

        private StringBuilder receiveString = new StringBuilder();


        public Client(TcpClient tcpClient) {
            this.tcpClient = tcpClient;
            this.stream = this.tcpClient.GetStream();
        }

        public void StartReadAsync(){
            ReadAsync(cts.Token);
        }

        private async Task ReadAsync(CancellationToken ct) {
          // Stackoverflow exception occurs on next line after 20-30 mins
            int amountRead = await stream.ReadAsync(readBuffer, 0, readBuffer.Length, ct);
            if (amountRead > 0) {
                string message = Encoding.UTF8.GetString(readBuffer, 0, amountRead);
                receiveString.Append(message);
                Console.WriteLine("Client " + name + " sent: " + message);

                if (receiveString.ToString().IndexOf(eof) > -1) {
                    // Full message received, otherwise keep reading
                    if (OnClientRead != null)
                        OnClientRead(this, new SocketEventArgs(this, receiveString.ToString()));
                    receiveString.Clear();
                }
            }
            ReadAsync(ct);
        }
    }

最佳答案

您正在进行重入调用，ReadAsync 再次调用 ReadAsync，所以是的，您将以 StackOverflow 异常结束。

将您的代码更改为:

public class Client 
{

    public TcpClient tcpClient;

    public NetworkStream stream;

    public CancellationTokenSource cts = new CancellationTokenSource();

    private byte[] readBuffer = new byte[1024];

    private StringBuilder receiveString = new StringBuilder();


    public Client(TcpClient tcpClient) {
        this.tcpClient = tcpClient;
        this.stream = this.tcpClient.GetStream();
    }

    public async void StartReadAsync(){

        while(await ReadAsync(cts.Token));
    }

    private async Task<bool> ReadAsync(CancellationToken ct) 
    {

        try
        {
            int amountRead = await stream.ReadAsync(readBuffer, 0, readBuffer.Length, ct);
            if (amountRead > 0)
            {
                string message = Encoding.UTF8.GetString(readBuffer, 0, amountRead);
                receiveString.Append(message);
                Console.WriteLine("Client " + name + " sent: " + message);

                if (receiveString.ToString().IndexOf(eof) > -1)
                {
                    // Full message received, otherwise keep reading
                    if (OnClientRead != null)
                        OnClientRead(this, new SocketEventArgs(this, receiveString.ToString()));
                    receiveString.Clear();
                }

                return true;
            }

            return false;
        }
        catch { return false; }

    }
}

关于c# - 异步 TCP 读取期间的 Stackoverflow，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/32281114/