我创建了简单的 TCP 服务器 - 它运行得很好。
当我们切换到压力测试时,问题就开始了 - 因为我们的服务器应该处理许多并发的打开套接字 - 我们创建了一个压力测试来检查这一点。 不幸的是,当并发打开的套接字数量在 100 左右时,看起来服务器很卡,无法及时响应新的连接请求。
我们已经尝试了几种类型的服务器 - 并且所有服务器都产生相同的行为。
服务器:可以类似于本文中的示例(都产生相同的行为)
这是我们正在使用的代码 - 当客户端连接时 - 服务器将挂起以保持套接字处于活动状态。
enter code here
公共课服务器
{
private static readonly TcpListener listener = new TcpListener(IPAddress.Any, 2060);
public Server()
{
listener.Start();
Console.WriteLine("Started.");
while (true)
{
Console.WriteLine("Waiting for connection...");
var client = listener.AcceptTcpClient();
Console.WriteLine("Connected!");
// each connection has its own thread
new Thread(ServeData).Start(client);
}
}
private static void ServeData(object clientSocket)
{
Console.WriteLine("Started thread " + Thread.CurrentThread.ManagedThreadId);
var rnd = new Random();
try
{
var client = (TcpClient)clientSocket;
var stream = client.GetStream();
byte[] arr = new byte[1024];
stream.Read(arr, 0, 1024);
Thread.Sleep(int.MaxValue);
}
catch (SocketException e)
{
Console.WriteLine("Socket exception in thread {0}: {1}", Thread.CurrentThread.ManagedThreadId, e);
}
}
}
压力测试客户端:是一个简单的tcp客户端,循环并打开一个接一个的sockets
class Program
{
static List<Socket> sockets;
static private void go(){
Socket newsock = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp);
IPEndPoint iep = new IPEndPoint(IPAddress.Parse("11.11.11.11"), 2060);
try
{
newsock.Connect(iep);
}
catch (SocketException ex)
{
Console.WriteLine(ex.Message );
}
lock (sockets)
{
sockets.Add(newsock);
}
}
static void Main(string[] args)
{
sockets = new List<Socket>();
//int start = 1;// Int32.Parse(Console.ReadLine());
for (int i = 1; i < 1000; i++)
{
go();
Thread.Sleep(200);
}
Console.WriteLine("press a key");
Console.ReadKey();
}
}
}
有没有简单的方法来解释这种行为?也许C++实现如果TCP服务器会产生更好的结果?也许这实际上是客户端问题?
欢迎任何评论!
提供
首先,每个连接一个线程的设计不太可能具有特别的可扩展性,您最好将您的设计基于异步服务器模型,该模型在后台使用 IO 完成端口。然而,在这种情况下,这不太可能成为问题,因为您并没有真正给服务器带来太大压力。
其次,聆听积压是一个转移注意力的问题。侦听积压用于为等待接受的连接提供队列。在此示例中,您的客户端使用同步连接调用,这意味着客户端在任何时候都不会有超过 1 次未完成的连接尝试。如果您在客户端中使用异步连接尝试,那么您也许应该考虑调整监听积压。
第三,鉴于客户端代码没有显示它发送任何数据,您可以简单地发出读取调用并删除其后面的睡眠,读取调用将被阻塞。睡眠只会让事情变得混乱。
您是否在同一台计算机上运行客户端和服务器?
这是客户端和服务器中的所有代码吗?
您可以尝试使用我的免费 TCP 测试客户端来消除问题空间中的客户端:http://www.lenholgate.com/blog/2005/11/windows-tcpip-server-performance.html
同样,您可以针对我的一个简单的免费服务器测试您的测试客户端,如下所示:http://www.lenholgate.com/blog/2005/11/simple-echo-servers.html
我看不出代码有任何明显的错误(除了整体设计)。
我将 MTU 从 1500 降低到 1300,似乎有帮助。