我有以下代码想要作为服务器实现。据我了解,它是异步的。并应允许来自多个客户端的连接...

public void Start()
{
    TcpListener listener = new TcpListener(IPAddress.Any, 10250);
    listener.Start();
    Console.WriteLine("Listening...");

    while (true)
    {
        IAsyncResult res = listener.BeginAcceptTcpClient(HandleAsyncConnection, listener);
        connectionWaitHandle.WaitOne();
    }
}

private void HandleAsyncConnection(IAsyncResult res)
{
    TcpListener listener = (TcpListener)res.AsyncState;
    TcpClient client = listener.EndAcceptTcpClient(res);
    connectionWaitHandle.Set();

    StringBuilder sb = new StringBuilder();
    var data = new byte[client.ReceiveBufferSize];

    using (NetworkStream ns = client.GetStream())
    {
        // Test reply
        Byte[] replyData = System.Text.Encoding.ASCII.GetBytes(DateTime.Now.ToString());
        ns.Write(replyData, 0, replyData.Length);
        ns.Flush();
        ns.Close();
    }

    client.Close();
}

我有一个测试应用程序,可以简单地将请求发送到我的服务器。正如您在代码中看到的那样,服务器仅使用其日期/时间进行答复。测试应用会发送20条请求,这些请求只是测试字符串。对于这些请求中的每一个,它都会打开一个套接字,将数据发送到我的服务器,然后再次关闭该套接字。

在运行一个测试应用程序时,这可以正常工作。但是,如果我打开两个测试应用程序,则第二个无法连接到服务器。我以为是因为我正在处理异步请求。并且因为我的测试应用程序打开,然后在每次调用之前可以关闭套接字,所以我可以处理来自多个客户端的请求?

最佳答案

编辑

如果使用> =。Net4.5,最好使用新的网络方法,然后允许采用asyncawait。因此,最好以我在this post中提供的示例为起点。

原始帖子

下面的代码演示了如何异步接受多个客户端,而又不断开每个连接的新线程。

private TcpListener listener;
public void Start()
{
    listener = new TcpListener(IPAddress.Any, 10250);
    listener.Start();
    Console.WriteLine("Listening...");
    StartAccept();

}
private void StartAccept()
{
    listener.BeginAcceptTcpClient(HandleAsyncConnection, listener);
}
private void HandleAsyncConnection(IAsyncResult res)
{
    StartAccept(); //listen for new connections again
    TcpClient client = listener.EndAcceptTcpClient(res);
    //proceed

}

您可以将此模式用于大多数异步操作。

关于C#套接字处理多个客户端,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/5742577/

10-11 12:02