TcpClient BeginConnect 超时

Question

如何在 c# 中为 BeginConnect 异步调用设置自定义超时？ 它非常有用，在连接到有可能不在给定端口上侦听的主机时。每个这样的调用在释放线程之前都会浪费大约 15 秒的时间。

我有以下代码，正如许多 stackoverflow 答案中所建议的那样：

public bool Test()
{
     using (var tcp = new TcpClient())
     {
         var c = tcp.BeginConnect(IPAddress.Parse("8.8.8.8"), 8080, null, null);
         var success = c.AsyncWaitHandle.WaitOne(TimeSpan.FromSeconds(1));

         if (!success)
         {
             Console.WriteLine("Before cleanup");
             tcp.Close();
             tcp.EndConnect(c);
             Console.WriteLine("After cleanup");
             throw new Exception("Failed to connect.");
         }
     }

     return true;
}

但是这不起作用。实际上，在调用之后，该函数进入“if”开关，但它在 tcp.Close() 调用时立即阻塞并等待提到的 15 秒。可以避免吗？

Answer 1

我编写了一个简单的测试程序，使用两种不同的技术来实现您的目标，并测试您发布的确切代码。我无法重现您描述的问题。无论我是直接使用TcpClient还是Socket，在对象上调用Close()都会导致连接操作立即完成（嗯，在不到1/10秒的时间内，在所有异步完成、异常处理、线程同步之后等）

请注意，在 TcpClient 的情况下，TcpClient 类似乎有一个错误，即它抛出 NullReferenceException 而不是（正如人们所期望的）ObjectDisposedException。这似乎是因为TcpClient 在调用Close() 时将Client 属性设置为null，但随后在调用完成委托时尝试使用该值。哎呀。

这意味着在您的代码中，调用者会看到 NullReferenceException 而不是您似乎想要抛出的 Exception。但这似乎不会导致实际的延迟。

这是我的测试程序：

class Program
{
    static void Main(string[] args)
    {
        _TestWithSocket();
        _TestWithTcpClient();

        try
        {
            _TestSOCode();
        }
        catch (Exception e)
        {
            Console.WriteLine("Exception: " + e);
        }
    }

    private static void _TestSOCode()
    {
        using (var tcp = new TcpClient())
        {
            var c = tcp.BeginConnect(IPAddress.Parse("8.8.8.8"), 8080, null, null);
            var success = c.AsyncWaitHandle.WaitOne(TimeSpan.FromSeconds(1));

            if (!success)
            {
                Console.WriteLine("Before cleanup");
                tcp.Close();
                tcp.EndConnect(c);
                Console.WriteLine("After cleanup");
                throw new Exception("Failed to connect.");
            }
        }
    }

    private static void _TestWithTcpClient()
    {
        TcpClient client = new TcpClient();
        object o = new object();

        Console.WriteLine("connecting TcpClient...");
        client.BeginConnect("8.8.8.8", 8080, asyncResult =>
        {
            Console.WriteLine("connect completed");

            try
            {
                client.EndConnect(asyncResult);
                Console.WriteLine("client connected");
            }
            catch (NullReferenceException)
            {
                Console.WriteLine("client closed before connected: NullReferenceException");
            }
            catch (ObjectDisposedException)
            {
                Console.WriteLine("client closed before connected: ObjectDisposedException");
            }

            lock (o) Monitor.Pulse(o);
        }, null);

        Thread.Sleep(1000);

        Stopwatch sw = Stopwatch.StartNew();
        client.Close();

        lock (o) Monitor.Wait(o);
        Console.WriteLine("close took {0:0.00} seconds", sw.Elapsed.TotalSeconds);
        Console.WriteLine();
    }

    private static void _TestWithSocket()
    {
        Socket socket = new Socket(SocketType.Stream, ProtocolType.Tcp);
        object o = new object();

        Console.WriteLine("connecting Socket...");
        socket.BeginConnect("8.8.8.8", 8080, asyncResult =>
        {
            Console.WriteLine("connect completed");

            try
            {
                socket.EndConnect(asyncResult);
                Console.WriteLine("socket connected");
            }
            catch (ObjectDisposedException)
            {
                Console.WriteLine("socket closed before connected");
            }

            lock (o) Monitor.Pulse(o);
        }, null);

        Thread.Sleep(1000);

        Stopwatch sw = Stopwatch.StartNew();
        socket.Close();

        lock (o) Monitor.Wait(o);
        Console.WriteLine("close took {0:0.00} seconds", sw.Elapsed.TotalSeconds);
        Console.WriteLine();
    }
}

很遗憾，您没有提供一个实际完整的代码示例来演示该问题。如果在您的环境中，上面的代码演示了您描述的问题，因为它在我的环境中没有这样做，这显然意味着您的环境有一些问题导致了问题。不同的 OS 版本，不同的 .NET 版本等。

在这种情况下，您应该具体说明您的环境中可能相关的特定方面。

如果上面的代码示例按预期工作，并且没有演示您描述的问题，那么您只需要弄清楚您的代码中有什么不同并导致问题。在这种情况下，如果您仍然无法真正找出问题所在，您应该发帖 a minimal, complete code example 来说明问题。