异步/等待套接字连接中的竞争条件

Question

这个send方法会周期性的失败，因为控制权返回给调用线程，并且Send会在socket打开时再次被调用。

我正在使用 Stephen Toub 的课程：http://blogs.msdn.com/b/pfxteam/archive/2011/12/15/10248293.aspx

这会导致异常：在已连接的套接字上发出了连接请求。
确保异步方法不会遭受这种命运的正确方法是什么。基本上，在建立连接之前发送实际上无法完成。

    public async Task Send(byte[] tosend)
    {
        // this code is not correct / not thread safe.
        if (this.socket.Connected)
            await this.StartSending(tosend);
        else
            await StartConnecting(tosend);
    }

    private async Task StartSending(byte[] tosend)
    {
        var args = new SocketAsyncEventArgs();
        args.SetBuffer(tosend, 0, tosend.Length);
        var awaitable = new SocketAwaitable(args);
        await this.socket.SendAsync(awaitable);
    }

    private async Task StartConnecting(byte[] tosend)
    {
        var local = Dns.GetHostEntry(Dns.GetHostName());
        var ep = new IPEndPoint(local.AddressList.First(_ => _.AddressFamily == AddressFamily.InterNetwork), this.port);
        var args = new SocketAsyncEventArgs() { RemoteEndPoint = ep };
        var awaitable = new SocketAwaitable(args);
        await this.socket.ConnectAsync(awaitable);
        await StartSending(tosend);
    }

我的测试只是很快地连续调用Send。

var sends = arrays.Select(_ => writer.Send(_)).ToArray();
Task.WaitAll(sends);

有时上面的代码可以正常工作，并且套接字已连接，socket.Connected 设置为 true 'on time'。其他时候，对this.socket.ConnectAsync 的调用不止一次。

Answer 1

应该等待对Send 的调用，这样您就知道连接已建立，而且您知道您的数据正在按顺序发送。这最好由foreach 循环处理而不是.Select。

foreach (var data in arrays)
    await writer.Send(data);

假设您创建了变量sends，以便您可以对其进行Task.WhenAll。不幸的是，由于您已经发现的原因，这不起作用。您可以使用名为Connect 的单独方法解决此问题，该方法异步连接到远程主机，但不 发送数据。然后你可以这样做：

await writer.Connect();
var sends = arrays.Select(_ => writer.Send(_)).ToArray();