3 
private void ProcessReceive(SocketAsyncEventArgs e)
{
    // Check if the remote host closed the connection.
    if (e.BytesTransferred > 0)
    {
        if (e.SocketError == SocketError.Success)
        {
            Token token = e.UserToken as Token;
            token.SetData(e);

            Socket s = token.Connection;
            if (s.Available == 0)
            {
                Boolean willRaiseEvent = false;
                // GET DATA TO SEND
                byte[] sendBuffer = token.GetRetBuffer();
                // this.bufferSize IS SocketAsyncEventArgs buffer SIZE
                byte[] tempBuffer = new byte[this.bufferSize];
                int offset = 0;
                int size = (int)Math.Ceiling((double)sendBuffer.Length / (double)this.bufferSize);
                for (int i = 0; i < size - 1; i++)
                {
                    Array.Clear(tempBuffer, 0, this.bufferSize);
                    Array.Copy(sendBuffer, offset, tempBuffer, 0, this.bufferSize);
                    e.SetBuffer(tempBuffer, 0, this.bufferSize);
                    willRaiseEvent = s.SendAsync(e);
                    offset += this.bufferSize;
                }
                int remainSize = sendBuffer.Length - this.bufferSize * (size - 1);
                Array.Clear(tempBuffer, 0, this.bufferSize);
                Array.Copy(sendBuffer, offset, tempBuffer, 0, remainSize);
                e.SetBuffer(tempBuffer, 0, remainSize);
                willRaiseEvent = s.SendAsync(e);

                if (!willRaiseEvent)
                {
                    this.ProcessSend(e);
                }
            }
            else if (!s.ReceiveAsync(e))
            {
                // Read the next block of data sent by client.
                this.ProcessReceive(e);
            }
        }
        else
        {
            this.ProcessError(e);
        }
    }
    else
    {
        this.CloseClientSocket(e);
    }
}

このコードは MSDN から変更されています

なぜ流通しているのかs.SendAsync(e)、2回目に実行するとエラーになる

例外: この SocketAsyncEventArgs インスタンスを使用して、非同期ソケット操作が既に進行中です

大きなデータを送信するにはどうすればよいですか?

4

3 に答える 3

7

Completed別の非同期送信を行う前に、イベントが発生するのを待つ必要があります。コールバックを取得するために、独自のイベント ハンドラーを追加することを忘れないでください。

e.Completed += new EventHandler<SocketAsyncEventArgs>(SendCallback);

非同期 HTTP クライアントの例を使用して、自分のクライアントをモデル化できます。

private void BeginSend()
{
    _clientState = EClientState.Sending;
    byte[] buffer = GetSomeData(); // gives you data for the buffer

    SocketAsyncEventArgs e = new SocketAsyncEventArgs();
    e.SetBuffer(buffer, 0, buffer.Length);
    e.Completed += new EventHandler<SocketAsyncEventArgs>(SendCallback);

    bool completedAsync = false;

    try
    {
        completedAsync = _socket.SendAsync(e);
    }
    catch (SocketException se)
    {
        Console.WriteLine("Socket Exception: " + se.ErrorCode + " Message: " + se.Message);
    }

    if (!completedAsync)
    {
        // The call completed synchronously so invoke the callback ourselves
        SendCallback(this, e);
    }

}

コールバック メソッドは次のとおりです。

private void SendCallback(object sender, SocketAsyncEventArgs e)
{
    if (e.SocketError == SocketError.Success)
    {
        // You may need to specify some type of state and 
        // pass it into the BeginSend method so you don't start
        // sending from scratch
        BeginSend();
    }
    else
    {
        Console.WriteLine("Socket Error: {0} when sending to {1}",
               e.SocketError,
               _asyncTask.Host);
    }
}

BeginSendコールバックが完了したら、データの送信が完了するまで、別の呼び出しを再度行うことができます。

于 2012-02-07T02:19:41.087 に答える
1

問題は、 が発生するまで待たなければならないことではありませんCompleted。イベントを待つことも非同期プログラミングの目的ではないと思います。

ただし、SocketAsyncEventArgs最後のアクションが完了した場合にのみ再利用できます。したがって、SocketAsyncEventArgs各ループ内で新しいを作成するだけで問題を解決できます。

于 2013-04-19T01:48:31.350 に答える
0

別の解決策: ブロックされたソケットを使用できます。これは、完了またはエラーの後に返されますが、別のスレッドにある必要があります。

于 2012-02-07T02:21:58.307 に答える