我有以下代码想要作为服务器实现。据我了解,它是异步的。并应允许来自多个客户端的连接...
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,最好使用新的网络方法,然后允许采用async
和await
。因此,最好以我在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/