Я пытаюсь выполнить тест производительности сайта, нажав на него с запросами в нескольких потоках. Каждый поток выполняет n раз. (в петле цикла)
Однако у меня проблемы. В частности, WebException ( "Не удается подключиться к удаленному серверу" ) с внутренним исключением:
Операция сокета не может быть выполнена, поскольку система не было достаточного пространства для буфера или потому, что очередь была заполнена 127.0.0.1:52395
Я пытаюсь запустить 100 потоков на 500 итераций на поток.
Изначально я использовал HttpWebRequest в System.Net, чтобы сделать запрос GET на сервер. В настоящее время я использую WebClient, поскольку я предположил, что каждая итерация использует новый сокет (так что со 100 * 500 сокетов за короткий промежуток времени). Я предположил, что WebClient (который создается один раз в потоке) будет использовать только один сокет.
Мне не нужно открывать сразу 50 000 сокетов, так как я хочу отправить запрос GET, получить ответ и закрыть сокет, освободив его для использования в следующей итерации цикла. Я понимаю, что было бы проблемой
Однако даже с помощью WebClient запрашивается куча сокетов, в результате чего создается набор сокетов в режиме TIME_WAIT (проверяется с помощью netstat). Это заставляет другие приложения (например, интернет-браузеры) висеть и перестать функционировать.
Я могу управлять своим тестом с меньшим количеством итераций и/или меньше потоков, так как кажется, что сокеты в конечном итоге выходят из этого состояния TIME_WAIT. Однако это не решение, так как оно недостаточно проверяет возможности веб-сервера.
Вопрос:
Как явным образом закрыть сокет (с клиентской стороны) после каждой итерации потока, чтобы предотвратить состояние TIME_WAIT и исчерпание сокетов?
Код:
Класс, который обертывает HttpRequest
Edit: Wrapped WebClient в использовании, поэтому новый экземпляр, используется и удаляется для каждой итерации. Проблема все еще сохраняется.
public sealed class HttpGetTest : ITest {
private readonly string m_url;
public HttpGetTest( string url ) {
m_url = url;
}
void ITest.Execute() {
using (WebClient webClient = new WebClient()){
using( Stream stream = webClient.OpenRead( m_url ) ) {
}
}
}
}
Часть моего ThreadWrapperClass, создающая новый поток:
public void Execute() {
Action Hammer = () => {
for( int i = 1; i <= m_iterations; i++ ) {
//Where m_test is an ITest injected through constructor
m_test.Execute();
}
};
ThreadStart work = delegate {
Hammer();
};
Thread thread = new Thread( work );
thread.Start();
}
