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 回答