PHP负载测试工具开发 用PHP实现简单压力测试系统的完整教程

file_get_contents

curl_exec

curl_multi_exec

<?php

// 简单配置
$targetUrl = 'http://localhost/test_api.php'; // 你的目标URL
$concurrency = 50; // 并发数
$totalRequests = 500; // 总请求数

$requestCount = 0;
$activeHandles = 0;
$mh = curl_multi_init();
$handles = [];
$results = [
    'total_requests' => 0,
    'successful_requests' => 0,
    'failed_requests' => 0,
    'total_time' => 0,
    'max_time' => 0,
    'min_time' => PHP_INT_MAX,
    'errors' => [],
];

echo "开始压力测试...\n";

// 填充初始并发请求
for ($i = 0; $i < min($concurrency, $totalRequests); $i++) {
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $targetUrl);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_HEADER, false);
    curl_setopt($ch, CURLOPT_NOBODY, false); // 获取响应体
    curl_setopt($ch, CURLOPT_TIMEOUT_MS, 5000); // 5秒超时
    // curl_setopt($ch, CURLOPT_POST, true); // 如果是POST请求
    // curl_setopt($ch, CURLOPT_POSTFIELDS, ['key' => 'value']); // POST数据

    curl_multi_add_handle($mh, $ch);
    $handles[(string)$ch] = $ch; // 用句柄的字符串表示作为键
    $requestCount++;
}

$startTime = microtime(true);

do {
    // 执行批处理cURL请求
    curl_multi_exec($mh, $activeHandles);

    // 等待活动句柄
    // 如果没有活动句柄，或者没有新的请求可以添加，则不需要select
    if ($activeHandles > 0 || $requestCount < $totalRequests) {
        curl_multi_select($mh, 0.1); // 等待最多0.1秒
    }

    // 检查已完成的请求
    while (($info = curl_multi_info_read($mh)) !== false) {
        $ch = $info['handle'];
        $requestInfo = curl_getinfo($ch);
        $response = curl_multi_getcontent($ch);

        $results['total_requests']++;
        $requestTime = $requestInfo['total_time'];
        $results['total_time'] += $requestTime;
        $results['max_time'] = max($results['max_time'], $requestTime);
        $results['min_time'] = min($results['min_time'], $requestTime);

        if ($info['result'] === CURLE_OK && $requestInfo['http_code'] >= 200 && $requestInfo['http_code'] < 300) {
            $results['successful_requests']++;
        } else {
            $results['failed_requests']++;
            $error = curl_error($ch) ?: "HTTP Code: " . $requestInfo['http_code'];
            $results['errors'][] = [
                'url' => $requestInfo['url'],
                'error' => $error,
                'time' => $requestTime,
                'http_code' => $requestInfo['http_code']
            ];
        }

        // 移除已完成的句柄
        curl_multi_remove_handle($mh, $ch);
        curl_close($ch);
        unset($handles[(string)$ch]);

        // 如果还有请求需要发送，就添加新的句柄
        if ($requestCount < $totalRequests) {
            $newCh = curl_init();
            curl_setopt($newCh, CURLOPT_URL, $targetUrl);
            curl_setopt($newCh, CURLOPT_RETURNTRANSFER, true);
            curl_setopt($newCh, CURLOPT_HEADER, false);
            curl_setopt($newCh, CURLOPT_NOBODY, false);
            curl_setopt($newCh, CURLOPT_TIMEOUT_MS, 5000);

            curl_multi_add_handle($mh, $newCh);
            $handles[(string)$newCh] = $newCh;
            $requestCount++;
        }
    }

} while ($activeHandles > 0 || $requestCount < $totalRequests); // 循环直到所有请求完成

curl_multi_close($mh);
$endTime = microtime(true);
$totalExecutionTime = $endTime - $startTime;

// 输出报告
echo "\n--- 压力测试报告 ---\n";
echo "总请求数: " . $results['total_requests'] . "\n";
echo "成功请求数: " . $results['successful_requests'] . "\n";
echo "失败请求数: " . $results['failed_requests'] . "\n";
echo "总耗时: " . sprintf("%.2f", $totalExecutionTime) . " 秒\n";
echo "平均响应时间: " . sprintf("%.4f", $results['total_time'] / $results['successful_requests']) . " 秒\n";
echo "最高响应时间: " . sprintf("%.4f", $results['max_time']) . " 秒\n";
echo "最低响应时间: " . sprintf("%.4f", $results['min_time']) . " 秒\n";
echo "吞吐量 (QPS): " . sprintf("%.2f", $results['total_requests'] / $totalExecutionTime) . " 请求/秒\n";

if (!empty($results['errors'])) {
    echo "\n--- 错误详情 ---\n";
    foreach ($results['errors'] as $error) {
        echo "URL: " . $error['url'] . ", 错误: " . $error['error'] . ", HTTP状态码: " . $error['http_code'] . ", 耗时: " . sprintf("%.4f", $error['time']) . "秒\n";
    }
}

?>

curl_multi

curl_multi_exec

curl_multi

curl_exec

curl_multi_exec

curl_getinfo()

total_time

http_code

url

curl_error()

// 假设 $results 数组结构如下
$results = [
    'total_requests' => 0,
    'successful_requests' => 0,
    'failed_requests' => 0,
    'total_time' => 0, // 累加所有请求的total_time
    'max_time' => 0,
    'min_time' => PHP_INT_MAX,
    'errors' => [], // 记录详细的错误信息
    // 还可以考虑增加：
    // 'http_codes' => [], // 统计各个HTTP状态码出现的次数
    // 'latency_distribution' => [], // 响应时间分布，比如落在0-100ms, 100-200ms的请求数
];

// 在处理每个完成的cURL句柄时
// ...
$requestInfo = curl_getinfo($ch);
$requestTime = $requestInfo['total_time'];

$results['total_requests']++;
$results['total_time'] += $requestTime;
$results['max_time'] = max($results['max_time'], $requestTime);
$results['min_time'] = min($results['min_time'], $requestTime);

if ($info['result'] === CURLE_OK && $requestInfo['http_code'] >= 200 && $requestInfo['http_code'] < 300) {
    $results['successful_requests']++;
} else {
    $results['failed_requests']++;
    $error = curl_error($ch) ?: "HTTP Code: " . $requestInfo['http_code'];
    $results['errors'][] = [
        'url' => $requestInfo['url'],
        'error' => $error,
        'time' => $requestTime,
        'http_code' => $requestInfo['http_code']
    ];
}
// ...

sum

max

min

avg

// 假设 $successfulTimes 数组存储了所有成功请求的响应时间
// array_push($successfulTimes, $requestTime);

// 计算P90, P95, P99
// sort($successfulTimes);
// $count = count($successfulTimes);
// $p90Index = (int)($count * 0.90) - 1;
// $p95Index = (int)($count * 0.95) - 1;
// $p99Index = (int)($count * 0.99) - 1;
// $p90 = $successfulTimes[$p90Index] ?? 0;
// $p95 = $successfulTimes[$p95Index] ?? 0;
// $p99 = $successfulTimes[$p99Index] ?? 0;