1

私はいくつかのネットワークをセットアップしようとしています。このため、ネットワーク経由でデータを送受信する必要があります。特に HTTP メッセージ。これを C# の非同期メソッドで実装したいと考えています。Web サーバーから HTTP 応答を受信するとき、Web サーバーが接続を閉じるまで、または (接続: キープアライブ) HTTP 応答のすべてのバイトを受信するまで、データを受信したいと考えています。私はすでにこの方法を設定しようとしましたが、失敗しました。これを実装する方法を教えてください。私はmsdnでこの例を見てきました:

    private static void Receive(Socket client) {
    try {
        // Create the state object.
        StateObject state = new StateObject();
        state.workSocket = client;

        // Begin receiving the data from the remote device.
        client.BeginReceive( state.buffer, 0, StateObject.BufferSize, 0,
            new AsyncCallback(ReceiveCallback), state);
    } catch (Exception e) {
        Console.WriteLine(e.ToString());
    }
}

private static void ReceiveCallback( IAsyncResult ar ) {
    try {
        // Retrieve the state object and the client socket 
        // from the asynchronous state object.
        StateObject state = (StateObject) ar.AsyncState;
        Socket client = state.workSocket;

        // Read data from the remote device.
        int bytesRead = client.EndReceive(ar);

        if (bytesRead > 0) {
            // There might be more data, so store the data received so far.
        state.sb.Append(Encoding.ASCII.GetString(state.buffer,0,bytesRead));

            // Get the rest of the data.
            client.BeginReceive(state.buffer,0,StateObject.BufferSize,0,
                new AsyncCallback(ReceiveCallback), state);
        } else {
            // All the data has arrived; put it in response.
            if (state.sb.Length > 1) {
                response = state.sb.ToString();
            }
            // Signal that all bytes have been received.
            receiveDone.Set();
        }
    } catch (Exception e) {
        Console.WriteLine(e.ToString());
    }
}

State オブジェクトの場合:

public class StateObject {
// Client socket.
public Socket workSocket = null;
// Size of receive buffer.
public const int BufferSize = 256;
// Receive buffer.
public byte[] buffer = new byte[BufferSize];
// Received data string.
public StringBuilder sb = new StringBuilder();
}

これと同様のコードを使用すると、すべてのスレッドが同じ状態オブジェクトを使用するため、恐ろしい副作用が発生するのではないかと心配しています。さらに、受信したデータをすぐに再送信する必要があります。

4

2 に答える 2

0

非同期の Receive メソッドを実装しようとしました。まあ、まだ完成していませんが、基本的な構造は明らかなはずです。

private void BeginReceiveFromWebserver(ClientSocket clientSocket)
    {
        try
        {
            clientSocket.CommunicationSocket.BeginReceive(clientSocket.Buffer, 0, clientSocket.Buffer.Length,
                                                         SocketFlags.None, new AsyncCallback(ReceiveFromWebserverCallback), clientSocket);

        }
        catch (Exception e)
        {
            Console.WriteLine(e.Message + "\nfrom Source: " + e.Source + "\nand Stack Trace: " + e.StackTrace);
            //XXX TODO
        }
    }

    private void ReceiveFromWebserverCallback(IAsyncResult ar)
    {            
        ClientSocket clientSocket = ar.AsyncState as ClientSocket;

        try
        {
            int bytesRead = clientSocket.CommunicationSocket.EndReceive(ar);

            if (bytesRead > 0)
            {
                if(!clientSocket.AllBytesReceived)
                {
                    // No locks needed here, because it works like a loop
                    clientSocket.TotalBytesReceived+=bytesRead;
                    clientSocket.BufferUsed++;
                    clientSocket.AddBuffer();
                    clientSocket.SendingToBrowserCompleted.WaitOne();
                    BeginSend(clientSocket, bytesRead);
                    clientSocket.CommunicationSocket.BeginReceive(clientSocket.Buffer, 0, clientSocket.Buffer.Length,
                                                        SocketFlags.None, new AsyncCallback(ReceiveFromWebserverCallback), clientSocket);
                }
                else
                {
                    // all bytes Received
                }
            }
            else
            {
                Console.WriteLine("Webserver Closed Connection");
                //XXX TODO, Webserver closed the Connection
            }
        }
        catch (Exception e)
        {
            Console.WriteLine(e.Message + "\nfrom Source: " + e.Source + "\nand Stack Trace: " + e.StackTrace);
            //XXX TODO
        }
    }

受信したメッセージのすべてのピースは、ブラウザに再送信されます。ブラウザがこれらのピースを正しい順序で取得できるようにするために、SendingToBrowserCompleted-AutoResetEvent をここに用意しました。より多くのコードに興味がある場合は、質問してください。

于 2012-11-21T12:59:17.287 に答える
0

HTTPは単純なプロトコルではありません。これを手動で行うことに固執する場合は、まだスレッドを気にせず、単一の HTTP クライアント接続から始めて、適切なメッセージ解析とプロトコル ステート マシンを理解してください。それが機能するようになると、スケーリング/拡張/その他がはるかに簡単になります。

于 2012-11-19T22:08:46.353 に答える