C# Tcp BeginAcceptTcpClient抛出ObjectDisposedException

基础概念

BeginAcceptTcpClient 是 C# 中用于异步接受 TCP 客户端连接的方法。它属于 System.Net.Sockets.TcpListener 类。当调用此方法时，它会启动一个异步操作来接受传入的连接请求。

异常原因

ObjectDisposedException 异常通常表示对象已经被释放或关闭，但你仍然尝试访问它。在 BeginAcceptTcpClient 的上下文中，这通常是因为 TcpListener 对象已经被关闭或释放。

解决方法

确保 TcpListener 未被关闭：在调用 BeginAcceptTcpClient 之前，确保 TcpListener 对象没有被关闭。例如：
确保 TcpListener 未被关闭：在调用 BeginAcceptTcpClient 之前，确保 TcpListener 对象没有被关闭。例如：
检查异步操作的生命周期：确保在异步操作完成之前，TcpListener 对象没有被关闭。例如：
检查异步操作的生命周期：确保在异步操作完成之前，TcpListener 对象没有被关闭。例如：
正确关闭 TcpListener：在关闭 TcpListener 时，确保所有异步操作都已经完成。例如：
正确关闭 TcpListener：在关闭 TcpListener 时，确保所有异步操作都已经完成。例如：

应用场景

BeginAcceptTcpClient 通常用于构建高性能的 TCP 服务器，特别是在需要处理大量并发连接的情况下。例如，一个在线游戏服务器或一个实时通信应用。

示例代码

以下是一个简单的示例，展示了如何使用 BeginAcceptTcpClient 来接受客户端连接：

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;

class TcpServer
{
    private TcpListener listener;

    public TcpServer(int port)
    {
        listener = new TcpListener(IPAddress.Any, port);
        listener.Start();
    }

    public void StartAccepting()
    {
        listener.BeginAcceptTcpClient(new AsyncCallback(AcceptCallback), listener);
    }

    private void AcceptCallback(IAsyncResult ar)
    {
        if (ar == null || ar.AsyncState == null)
            return;

        TcpListener listener = (TcpListener)ar.AsyncState;
        if (listener != null && !listener.Server.IsBound)
            return;

        TcpClient client = listener.EndAcceptTcpClient(ar);
        Console.WriteLine("Client connected");

        // 处理客户端连接
        Task.Run(() => HandleClient(client));

        // 继续接受新的连接
        listener.BeginAcceptTcpClient(new AsyncCallback(AcceptCallback), listener);
    }

    private void HandleClient(TcpClient client)
    {
        NetworkStream stream = client.GetStream();
        byte[] buffer = new byte[1024];
        int bytesRead;

        while ((bytesRead = stream.Read(buffer, 0, buffer.Length)) != 0)
        {
            string message = Encoding.ASCII.GetString(buffer, 0, bytesRead);
            Console.WriteLine("Received: " + message);

            byte[] response = Encoding.ASCII.GetBytes("Message received");
            stream.Write(response, 0, response.Length);
        }

        client.Close();
    }
}

class Program
{
    static void Main(string[] args)
    {
        TcpServer server = new TcpServer(8080);
        server.StartAccepting();

        Console.WriteLine("Server started. Press any key to exit.");
        Console.ReadKey();
    }
}