如何为TcpClient设置超时？

Question

我有一个TcpClient，用于将数据发送到远程计算机上的侦听器。远程计算机有时打开，有时关闭。因此，TCP客户端将经常无法连接。我希望TcpClient在一秒钟后超时，这样当它无法连接到远程计算机时就不会花费太多时间。目前，我对TcpClient使用以下代码：

try
{
    TcpClient client = new TcpClient("remotehost", this.Port);
    client.SendTimeout = 1000;

    Byte[] data = System.Text.Encoding.Unicode.GetBytes(this.Message);
    NetworkStream stream = client.GetStream();
    stream.Write(data, 0, data.Length);
    data = new Byte[512];
    Int32 bytes = stream.Read(data, 0, data.Length);
    this.Response = System.Text.Encoding.Unicode.GetString(data, 0, bytes);

    stream.Close();
    client.Close();    

    FireSentEvent();  //Notifies of success
}
catch (Exception ex)
{
    FireFailedEvent(ex); //Notifies of failure
}

这对于处理任务来说已经足够好了。如果可以，它会发送它，如果无法连接到远程计算机，它会捕获异常。然而，当它无法连接时，抛出异常需要10到15秒。我需要它在一秒钟内超时？我将如何更改超时时间？

Answer 1

另一种替代方法使用https://stackoverflow.com/a/25684549/3975786:

var timeOut = TimeSpan.FromSeconds(5);     
var cancellationCompletionSource = new TaskCompletionSource<bool>();
try
{
    using (var cts = new CancellationTokenSource(timeOut))
    {
        using (var client = new TcpClient())
        {
            var task = client.ConnectAsync(hostUri, portNumber);

            using (cts.Token.Register(() => cancellationCompletionSource.TrySetResult(true)))
            {
                if (task != await Task.WhenAny(task, cancellationCompletionSource.Task))
                {
                    throw new OperationCanceledException(cts.Token);
                }
            }

            ...

        }
    }
}
catch(OperationCanceledException)
{
    ...
}

Answer 2

从开始。NET 4.5中，TcpClient有一个很酷的ConnectAsync方法，我们可以这样使用，所以现在非常简单：

var client = new TcpClient();
if (!client.ConnectAsync("remotehost", remotePort).Wait(1000))
{
    // connection failure
}

Answer 3

您需要使用TcpClient的异步BeginConnect方法，而不是尝试同步连接，这正是构造函数所做的。类似这样：

var client = new TcpClient();
var result = client.BeginConnect("remotehost", this.Port, null, null);

var success = result.AsyncWaitHandle.WaitOne(TimeSpan.FromSeconds(1));

if (!success)
{
    throw new Exception("Failed to connect.");
}

// we have connected
client.EndConnect(result);