0

私は、2,000以上の長期的な永続的なクライアントTCP接続を維持するアプリケーションサーバーを作成しています。接続を非同期的に受け入れ、接続からデータを読み取る最も効率的な方法を知りたいです。

基本的に、次のようなパブリックフットプリントを持つクラスですべてのソケットコードをラップしたいと思います。

public partial class ApplicationClient
{
    private Socket socket;

    public ApplicationClient(Socket socket)
    {
        this.socket = socket;
    }

    public event ApplicationMessageEventHander MessageReceived;

    private void OnMessageReceived(string message)
    {
        ApplicationMessageEventHander messageReceived = this.MessageReceived;
        if (messageReceived != null)
        {
            var eventArgs = new ApplicationMessageEventArgs(message);
            messageReceived(this, eventArgs);
        }
    }
}

このアーキテクチャに適合するために.NETのソケットを使用する最良の方法は何ですか？

編集：クライアントによって渡される各メッセージは改行で終了することにも言及する価値があります。メッセージ全体が受信されるまで、イベントを発生させたくありません。

4

1 に答える 1

1

BeginReceive 関数と EndReceive 関数を使用する必要があります。AsyncCallback デリゲートへのパラメーターを受け取ります。次に、それをラップして新しい行部分を処理するコードを作成する必要があります。その後、別のデリゲートを呼び出す必要があります。

これを処理するには、次のような方法が適切だと思います。

const uint buf_len = 40;
byte[] bBuffer;
string strBuffer;

public ApplicationClient(Socket socket)
{
    this.socket = socket;
    bBuffer = new byte[buf_len];
    strBuffer = "";
    socket.BeginReceive(buffer, 0, buf_len, 0, my_callback, null);
}

protected void AsyncCallback(IAsyncResult iar)
{
    int i;
    int bytesRead;
    string[] parts;

    bytesRead = socket.EndReceive(iar);

    if(read > 0)
    {
        strBuffer += Encoding.ASCII.GetString(buffer, 0, bytesRead);
        parts = strBuffer.split("\n");
        for(i = 0; i < parts.Length - 1; ++i)
        {
            theRealCallback(parts[i]);
        }
        strBuffer = parts[i];
    }

    socket.BeginReceive(buffer, 0, buf_len, 0, my_callback, null);
}
于 2012-09-30T02:14:37.253 に答える