如何让TcpListener在无连接请求1分钟后退出AcceptTcpClient()阻塞？

这个问题我之前也碰到过，AcceptTcpClient()的阻塞特性确实会让定时停止的逻辑很难直接实现，不过有几个靠谱的解决方案，我给你梳理一下：

方法一：使用异步AcceptTcpClientAsync() + Task.WhenAny（推荐） #

这是.NET现代异步编程模式下最简洁高效的方案，不需要额外线程，也不会阻塞主线程：

private static async Task Listen(TcpListener listener)
{
    listener.Start();
    Console.WriteLine("Waiting for a connection...\n");

    // 创建一个1分钟的延迟任务
    var timeoutTask = Task.Delay(TimeSpan.FromMinutes(1));
    // 同时等待连接请求和延迟任务，谁先完成就执行谁
    var completedTask = await Task.WhenAny(listener.AcceptTcpClientAsync(), timeoutTask);

    if (completedTask == timeoutTask)
    {
        // 超时触发：没有收到连接请求
        Console.WriteLine("No connection received in 1 minute, stopping listener.");
        listener.Stop();
    }
    else
    {
        // 收到连接请求：获取客户端实例
        var client = await (Task<TcpClient>)completedTask;
        Console.WriteLine("Accepted a connection!");
        // 这里添加你的客户端逻辑，记得最后关闭客户端
        // client.Close();
        listener.Stop();
    }
}

为什么推荐这个方法？ #

• 异步非阻塞，不会占用额外线程资源
• 代码逻辑清晰，直接利用Task的组合特性实现“超时或连接二选一”的逻辑
• 符合.NET官方推荐的异步编程规范

方法二：后台线程定时调用Stop() + 捕获异常 #

如果你更习惯同步编程风格，可以启动一个后台线程负责超时后调用Stop()，同时捕获AcceptTcpClient()被中断时抛出的异常：

using System.Net.Sockets;

private static void Listen(TcpListener listener)
{
    listener.Start();
    Console.WriteLine("Waiting for a connection...\n");

    // 启动后台线程处理超时逻辑
    var timeoutThread = new Thread(() =>
    {
        Thread.Sleep(TimeSpan.FromMinutes(1));
        listener.Stop();
    });
    timeoutThread.IsBackground = true; // 设置为后台线程，不影响程序退出
    timeoutThread.Start();

    try
    {
        TcpClient client = listener.AcceptTcpClient();
        Console.WriteLine("Accepted a connection!");
        // 处理客户端逻辑
        // client.Close();
    }
    catch (SocketException ex)
    {
        // 当listener.Stop()调用时，AcceptTcpClient()会抛出SocketError.Interrupted异常
        if (ex.SocketErrorCode == SocketError.Interrupted)
        {
            Console.WriteLine("No connection received in 1 minute, listener stopped.");
        }
        else
        {
            // 其他Socket异常需要正常抛出处理
            throw;
        }
    }
    finally
    {
        // 确保listener最终被停止
        if (listener.Server.IsBound)
        {
            listener.Stop();
        }
    }
}

注意点： #

• 必须捕获SocketException，因为调用Stop()会强制中断阻塞的AcceptTcpClient()
• 后台线程要设置IsBackground = true，避免程序因为这个线程无法正常退出

方法三：使用Pending()轮询（不推荐） #

这种方法通过轮询检查是否有挂起的连接，虽然简单但会消耗CPU资源，适合对性能要求不高的场景：

private static void Listen(TcpListener listener)
{
    listener.Start();
    Console.WriteLine("Waiting for a connection...\n");

    DateTime startTime = DateTime.Now;
    bool connectionReceived = false;

    while (DateTime.Now - startTime < TimeSpan.FromMinutes(1))
    {
        // Pending()是非阻塞方法，检查是否有等待的连接
        if (listener.Pending())
        {
            TcpClient client = listener.AcceptTcpClient();
            Console.WriteLine("Accepted a connection!");
            // 处理客户端逻辑
            // client.Close();
            connectionReceived = true;
            break;
        }
        // 短暂休眠减少CPU占用
        Thread.Sleep(100);
    }

    if (!connectionReceived)
    {
        Console.WriteLine("No connection received in 1 minute, stopping listener.");
    }
    listener.Stop();
}

缺点： #

• 轮询间隔不好把控：间隔太短CPU占用高，太长会导致连接响应延迟
• 代码逻辑不如前两种优雅

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