Этот инструмент стресс-тестирования использует расширение сопрограммы PHP Swoole и пул соединений Swoole для достижения количества одновременных запросов через пул соединений. Это только для тестирования вашего собственного сайта, незаконное использование запрещено, в противном случае вы будете нести ответственность за последствия!
Метод запроса:
GETстресс-тест:http://серверIP:9000/?url={проситьURLадрес}&action=get&time={Время испытания давлением}&num={Количество параллелизма}
POSTстресс-тест:http://серверIP:9000/?url={проситьURLадрес}&action=post&time={Время испытания давлением}&num={Количество параллелизма}&data={urlencodeпозжеpostданные}
//Изменяем текущий лимит ресурсов файла
shell_exec("ulimit -n 100960");
$http = new Swoole\Http\Server("0.0.0.0", 9000, SWOOLE_BASE);
$http->on("start", function (\Swoole\Http\Server $server) {
swoole_set_process_name("test");
echo "start success!\n";
});
$http->set(['daemonize' => 1]);
$http->on("request", function (\Swoole\Http\Request $request, \Swoole\Http\Response $response) {
$response->header("Content-Type", "text/plain");
$url = (string)$request->get['url'];
$action = strtolower((string)$request->get['action']);
$time = (int)$request->get['time'] + time(); //Если это время меньше текущего времени, значит, оно истекло.
$num = (int)$request->get['num'];
$data = urldecode((string)$request->get['data']);
if ($action != "get" && $action != "post") {
$response->end("action error");
return;
}
\Swoole\Coroutine::create(function () use ($data, $action, $num, $url, $time) {
$connectionPool = new \Swoole\ConnectionPool(function () use ($url, $time) {
return new Request($url);
}, $num);
$connectionPool->fill();
$i = 1;
while (true) {
if ($time < time()) {
$connectionPool->close();
break;
}
$request = $connectionPool->get();
if ($request instanceof Request) {
\Swoole\Coroutine::create(function () use ($data, $action, $connectionPool, $i, $request) {
try {
if ($action == 'get') {
$request->get();
} else if ($action == 'post') {
$request->post($data);
}
$connectionPool->put($request);
} catch (Exception $e) {
$connectionPool->put($request);
}
});
}
$i++;
}
});
$message = sprintf('stress tests url:%s - thread:%s - expire:%s', $url, $num, date("Y/m/d H:i:s", $time));
@$response->end((string)$message);
});
$http->start();