我正在使用 VSTS 2008 + C# + .Net 3.5 开发控制台应用程序,并将请求发送到另一台服务器(Windows Server 2008 上的 IIS 7.0)。我发现当请求线程数很大(例如 2000 个线程)时,客户端在调用 response = (HttpWebResponse)request.GetResponse() 时会收到错误“无法连接到远程服务器失败”。我的困惑是 - 我有将超时设置为一个很大的值,但我在一分钟内收到这样的失败消息。我认为即使连接确实大于 IIS 可以服务的连接,客户端也不应该这么快收到此类失败消息,它应该在超时后收到此类消息。任何意见?任何想法有什么问题吗?有什么想法可以让 IIS 7.0 提供更多的并发连接吗?
这是我的代码,
class Program
{
private static int ClientCount = 2000;
private static string TargetURL = "http://labtest/abc.wmv";
private static int Timeout = 3600;
static void PerformanceWorker()
{
Stream dataStream = null;
HttpWebRequest request = null;
HttpWebResponse response = null;
StreamReader reader = null;
try
{
request = (HttpWebRequest)WebRequest.Create(TargetURL);
request.Timeout = Timeout * 1000;
request.Proxy = null;
response = (HttpWebResponse)request.GetResponse();
dataStream = response.GetResponseStream();
reader = new StreamReader(dataStream);
// 1 M at one time
char[] c = new char[1000 * 10];
while (reader.Read(c, 0, c.Length) > 0)
{
Console.WriteLine(Thread.CurrentThread.ManagedThreadId);
}
}
catch (Exception ex)
{
Console.WriteLine(ex.Message + "\n" + ex.StackTrace);
}
finally
{
if (null != reader)
{
reader.Close();
}
if (null != dataStream)
{
dataStream.Close();
}
if (null != response)
{
response.Close();
}
}
}
static void Main(string[] args)
{
Thread[] workers = new Thread[ClientCount];
for (int i = 0; i < ClientCount; i++)
{
workers[i] = new Thread((new ThreadStart(PerformanceWorker)));
}
for (int i = 0; i < ClientCount; i++)
{
workers[i].Start();
}
for (int i = 0; i < ClientCount; i++)
{
workers[i].Join();
}
return;
}
}
Kev 已经回答了你的问题,我只是想补充一点,创建这么多线程并不是真正好的设计解决方案(只是上下文切换开销是一个很大的负数)而且它不会很好地扩展。
快速的答案是:使用异步操作来读取数据,而不是创建一堆线程。或者至少使用线程池(和较低的工作线程数)。请记住,与一个来源的更多连接只会在某种程度上加快速度。尝试对其进行基准测试,您会发现可能 3-5 个连接会比您现在使用的 2000 个连接运行得更快。
您可以在此处阅读有关异步客户端/服务器架构(IOCP - 输入/输出完成端口)及其优点的更多信息。您可以从这里开始:
MSDN - 使用异步服务器套接字 http://msdn.microsoft.com/en-us/library/5w7b7x5f.aspx
MSDN - 异步服务器套接字示例 http://msdn.microsoft.com/en-us/library/fx6588te.aspx
CodeProject - 多线程 .NET TCP 服务器示例 http://www.codeproject.com/KB/IP/dotnettcp.aspx
所有这些示例都使用较低级别的 TCP 对象,但它也可以应用于 WebRequest/WebResponse。
UPDATE
要尝试线程池版本,您可以执行以下操作:
ManualResetEvent[] events = new ManualResetEvent[ClientCount];
for (uint cnt = 0; cnt < events.Length; cnt++)
{
events[cnt] = new ManualResetEvent(false);
ThreadPool.QueueUserWorkItem(obj => PerformanceWorker());
}
WaitHandle.WaitAll(events);
未测试,可能需要一些调整。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)