我正在编写一个 C# NUnit 测试,它与服务器建立 100 个并发 TCP 连接。测试的目的是给服务器施加压力。
为此,测试创建了 100 个新线程,循环它们并调用thread.Start()
,然后再次循环它们并调用thread.Join()
。
每个线程将执行一个建立 TCP 连接的方法,请求一些数据,检查接收到的数据是否为空,然后打印完成所需的时间。
我注意到,对于 100 个连接,每个线程完成其任务所需的时间从 2 秒上升到 50 秒,对于稍后写入控制台的线程。但是,当我在每次调用之间引入 2 秒延迟thread.Start()
时,每个线程所需的时间是 2 秒。
在无延迟情况下,我想知道所需时间的增加是否可能是由于运行单元测试的机器(即我的开发箱)出现问题。例如,也许 .NET/Windows 7 由于资源原因,不允许一个接一个地创建 100 个 TCP 连接。
请有TCP编程知识的人发表评论吗?我可以使用哪些工具来确定我的开发盒是否是瓶颈?
目标是了解结果是否实际上是服务器的有效压力测试结果。
public void ServerStressTest()
{
const int NUMBER_OF_REQUESTS = 10;
const int DELAY_BETWEEN_REQUESTS = 0;
var threads = new System.Collections.Generic.List<Thread>();
var urls = new StaticDataUrls();
Console.WriteLine(string.Format("Requesting static data from the server {0} times with {1} seconds delay between subsequent requests...", NUMBER_OF_REQUESTS, DELAY_BETWEEN_REQUESTS));
for (int i = 0; i < NUMBER_OF_REQUESTS; i++)
{
var callNumber = i; // prevent access to modified closure
threads.Add(new Thread(() => FetchStaticData(urls, callNumber)));
}
threads.Apply(t =>
{
Thread.Sleep(DELAY_BETWEEN_REQUESTS * 1000);
t.Start();
});
threads.Apply(t => t.Join());
}
private void FetchStaticData(StaticDataUrls urls, int callNumber)
{
var restAdapter = new RestAdapter(true, new Log4NetLogger(GetType()));
var stopwatch = Stopwatch.StartNew();
var underlyingResults = restAdapter.Get(urls.UnderlyingUrl);
var clientResults = restAdapter.Get(urls.ClientUrl);
stopwatch.Stop();
var missingData = new System.Collections.Generic.List<string>();
if(string.IsNullOrEmpty(clientResults.ResponseData)) missingData.Add("client");
if(string.IsNullOrEmpty(underlyingResults.ResponseData)) missingData.Add("underlying");
Console.WriteLine(missingData.Count > 0
? string.Format("Call {0}: No {1} data received in {2} seconds", callNumber, string.Join(", ", missingData.ToArray()), stopwatch.Elapsed.Seconds)
: string.Format("Call {0}: Completed with all data in {1} seconds", callNumber, stopwatch.Elapsed.Seconds));
}