PHP curl_multi_init函数

示例 4：性能对比 - 顺序 vs 并行

@php
// 性能对比测试
class PerformanceComparator {
    private $urls;

    public function __construct($urlCount = 10) {
        // 生成测试URL（每个URL延迟1-3秒）
        $this->urls = [];
        for ($i = 0; $i < $urlCount; $i++) {
            $delay = rand(1, 3);
            $this->urls[] = "https://httpbin.org/delay/{$delay}";
        }
    }

    public function testSequential() {
        echo "开始顺序请求测试...\n";
        $startTime = microtime(true);
        $results = [];

        foreach ($this->urls as $i => $url) {
            echo "执行请求 {$i}/" . count($this->urls) . "...";

            $ch = curl_init();
            curl_setopt_array($ch, [
                CURLOPT_URL => $url,
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_TIMEOUT => 10
            ]);

            $response = curl_exec($ch);
            $info = curl_getinfo($ch);

            $results[] = [
                'url' => $url,
                'time' => $info['total_time'],
                'success' => ($response !== false)
            ];

            curl_close($ch);
            echo " 完成 (" . round($info['total_time'], 2) . "秒)\n";
        }

        $totalTime = microtime(true) - $startTime;

        return [
            'type' => 'sequential',
            'total_time' => $totalTime,
            'results' => $results
        ];
    }

    public function testParallel() {
        echo "开始并行请求测试...\n";
        $startTime = microtime(true);

        $mh = curl_multi_init();
        $handles = [];
        $results = [];

        // 创建所有句柄
        foreach ($this->urls as $i => $url) {
            $handles[$i] = curl_init();
            curl_setopt_array($handles[$i], [
                CURLOPT_URL => $url,
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_TIMEOUT => 10
            ]);
            curl_multi_add_handle($mh, $handles[$i]);
        }

        echo "所有请求已就绪，开始并行执行...\n";

        // 执行并行请求
        $running = null;
        do {
            curl_multi_exec($mh, $running);
            if ($running) {
                curl_multi_select($mh, 0.1);
            }
        } while ($running > 0);

        // 收集结果
        foreach ($handles as $i => $handle) {
            $info = curl_getinfo($handle);
            $response = curl_multi_getcontent($handle);

            $results[] = [
                'url' => $this->urls[$i],
                'time' => $info['total_time'],
                'success' => ($response !== false)
            ];

            curl_multi_remove_handle($mh, $handle);
            curl_close($handle);
        }

        curl_multi_close($mh);

        $totalTime = microtime(true) - $startTime;

        return [
            'type' => 'parallel',
            'total_time' => $totalTime,
            'results' => $results
        ];
    }

    public function compare() {
        echo "性能对比测试 (" . count($this->urls) . " 个请求)\n";
        echo str_repeat("=", 50) . "\n";

        $sequential = $this->testSequential();
        echo "\n";
        $parallel = $this->testParallel();

        echo "\n" . str_repeat("=", 50) . "\n";
        echo "性能对比结果:\n";
        echo "顺序请求总耗时: " . round($sequential['total_time'], 2) . " 秒\n";
        echo "并行请求总耗时: " . round($parallel['total_time'], 2) . " 秒\n";

        $improvement = (($sequential['total_time'] - $parallel['total_time']) / $sequential['total_time']) * 100;
        echo "性能提升: " . round($improvement, 1) . "%\n";

        // 计算平均请求时间
        $seqAvg = array_sum(array_column($sequential['results'], 'time')) / count($sequential['results']);
        $parAvg = array_sum(array_column($parallel['results'], 'time')) / count($parallel['results']);

        echo "平均单个请求时间:\n";
        echo "  顺序: " . round($seqAvg, 2) . " 秒\n";
        echo "  并行: " . round($parAvg, 2) . " 秒\n";

        return [
            'sequential' => $sequential,
            'parallel' => $parallel,
            'improvement' => $improvement
        ];
    }
}

// 运行性能对比测试
$comparator = new PerformanceComparator(5); // 测试5个请求
$results = $comparator->compare();
@endphp