PHP curl_multi_info_read函数

示例 4：高级监控与性能分析

@php
class AdvancedMultiMonitor {
    private $multiHandle;
    private $requests = [];
    private $results = [];
    private $startTime;
    private $monitoringData = [];

    public function __construct() {
        $this->multiHandle = curl_multi_init();
        $this->startTime = microtime(true);
    }

    public function addRequest($url, $id = null, $metadata = []) {
        if ($id === null) {
            $id = uniqid('req_');
        }

        $ch = curl_init();
        curl_setopt_array($ch, [
            CURLOPT_URL => $url,
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_TIMEOUT => 30,
            CURLOPT_HEADER => true, // 包含头部信息用于分析
            CURLOPT_NOPROGRESS => false,
            CURLOPT_PROGRESSFUNCTION => function($resource, $download_size, $downloaded, $upload_size, $uploaded) use ($id) {
                $this->recordProgress($id, $download_size, $downloaded);
                return 0;
            }
        ]);

        $this->requests[$id] = [
            'handle' => $ch,
            'url' => $url,
            'metadata' => $metadata,
            'start_time' => microtime(true),
            'progress' => []
        ];

        curl_multi_add_handle($this->multiHandle, $ch);

        return $id;
    }

    private function recordProgress($id, $totalSize, $downloaded) {
        if ($totalSize > 0) {
            $progress = round(($downloaded / $totalSize) * 100, 1);
            $this->requests[$id]['progress'][] = [
                'time' => microtime(true) - $this->startTime,
                'progress' => $progress,
                'downloaded' => $downloaded,
                'total_size' => $totalSize
            ];
        }
    }

    public function execute() {
        echo "开始高级监控执行...\n";

        $active = null;
        $lastMonitorTime = 0;

        do {
            // 执行多句柄
            $status = curl_multi_exec($this->multiHandle, $active);

            // 处理完成信息
            $this->monitorCompletedRequests();

            // 定期输出监控信息（每秒一次）
            $currentTime = microtime(true);
            if ($currentTime - $lastMonitorTime >= 1.0) {
                $this->outputMonitoringInfo();
                $lastMonitorTime = $currentTime;
            }

            // 等待活动
            if ($active > 0) {
                curl_multi_select($this->multiHandle, 0.1);
            }

        } while ($active > 0 || !empty($this->requests));

        // 最终处理
        $this->monitorCompletedRequests(true);

        $totalTime = microtime(true) - $this->startTime;
        echo "\n执行完成！总耗时: " . round($totalTime, 2) . " 秒\n";

        return $this->generateReport();
    }

    private function monitorCompletedRequests($final = false) {
        $msgsInQueue = null;

        while ($info = curl_multi_info_read($this->multiHandle, $msgsInQueue)) {
            $this->processRequestCompletion($info);
        }
    }

    private function processRequestCompletion($info) {
        $handle = $info['handle'];
        $id = $this->findRequestId($handle);

        if ($id === null) {
            return;
        }

        $request = $this->requests[$id];
        $completionTime = microtime(true);
        $duration = $completionTime - $request['start_time'];

        // 获取完整响应（包含头部）
        $fullResponse = curl_multi_getcontent($handle);
        $curlInfo = curl_getinfo($handle);
        $error = curl_error($handle);

        // 分离头部和主体
        $headerSize = $curlInfo['header_size'];
        $headers = substr($fullResponse, 0, $headerSize);
        $body = substr($fullResponse, $headerSize);

        $result = [
            'success' => ($info['result'] === CURLE_OK),
            'result_code' => $info['result'],
            'headers' => $headers,
            'body' => $body,
            'info' => $curlInfo,
            'error' => $error,
            'duration' => $duration,
            'progress_data' => $request['progress'],
            'metadata' => $request['metadata'],
            'completed_at' => $completionTime
        ];

        // 分析性能数据
        $this->analyzePerformance($id, $result);

        $this->results[$id] = $result;

        // 清理资源
        curl_multi_remove_handle($this->multiHandle, $handle);
        curl_close($handle);
        unset($this->requests[$id]);

        $this->recordCompletion($id, $result);
    }

    private function findRequestId($handle) {
        foreach ($this->requests as $id => $request) {
            if ($request['handle'] === $handle) {
                return $id;
            }
        }
        return null;
    }

    private function analyzePerformance($id, &$result) {
        $progress = $result['progress_data'];

        if (count($progress) > 1) {
            // 计算平均下载速度
            $first = $progress[0];
            $last = end($progress);

            $timeDiff = $last['time'] - $first['time'];
            $dataDiff = $last['downloaded'] - $first['downloaded'];

            if ($timeDiff > 0) {
                $result['avg_speed_kbps'] = round(($dataDiff / $timeDiff) / 1024, 2);
            }

            // 检测下载阶段
            $result['download_phases'] = $this->detectDownloadPhases($progress);
        }
    }

    private function detectDownloadPhases($progress) {
        if (count($progress) < 3) {
            return ['数据不足分析阶段'];
        }

        $phases = [];
        $lastProgress = 0;

        foreach ($progress as $point) {
            $currentProgress = $point['progress'];

            if ($currentProgress - $lastProgress > 20) {
                $phases[] = "阶段: {$lastProgress}% → {$currentProgress}%";
                $lastProgress = $currentProgress;
            }
        }

        return $phases ?: ['稳定下载'];
    }

    private function outputMonitoringInfo() {
        $elapsed = microtime(true) - $this->startTime;
        $completed = count($this->results);
        $remaining = count($this->requests);
        $active = 0;

        // 计算活动请求数（粗略估计）
        foreach ($this->requests as $request) {
            if (!empty($request['progress'])) {
                $active++;
            }
        }

        echo sprintf(
            "[%.1fs] 完成: %d, 进行中: %d, 活动: %d, 总进度: %.1f%%\n",
            $elapsed, $completed, $remaining, $active,
            $completed > 0 ? ($completed / ($completed + $remaining)) * 100 : 0
        );

        // 显示最近完成的请求
        $recentResults = array_slice($this->results, -3);
        foreach ($recentResults as $id => $result) {
            $status = $result['success'] ? '✓' : '✗';
            $speed = isset($result['avg_speed_kbps']) ? $result['avg_speed_kbps'] . ' KB/s' : 'N/A';
            echo "  {$status} {$id}: " . round($result['duration'], 2) . "s, {$speed}\n";
        }
    }

    private function recordCompletion($id, $result) {
        $this->monitoringData['completions'][] = [
            'id' => $id,
            'time' => microtime(true) - $this->startTime,
            'success' => $result['success'],
            'duration' => $result['duration']
        ];
    }

    private function generateReport() {
        $report = [
            'summary' => $this->generateSummary(),
            'detailed_results' => $this->results,
            'monitoring_data' => $this->monitoringData,
            'performance_analysis' => $this->analyzeOverallPerformance()
        ];

        return $report;
    }

    private function generateSummary() {
        $total = count($this->results);
        $successful = 0;
        $totalDuration = 0;
        $totalData = 0;

        foreach ($this->results as $result) {
            if ($result['success']) {
                $successful++;
                $totalDuration += $result['duration'];
                $totalData += strlen($result['body']);
            }
        }

        return [
            'total_requests' => $total,
            'successful_requests' => $successful,
            'success_rate' => $total > 0 ? round(($successful / $total) * 100, 1) : 0,
            'average_duration' => $successful > 0 ? round($totalDuration / $successful, 3) : 0,
            'total_data_transferred' => $totalData,
            'total_data_mb' => round($totalData / 1024 / 1024, 2)
        ];
    }

    private function analyzeOverallPerformance() {
        if (empty($this->results)) {
            return ['无数据可用于分析'];
        }

        $durations = [];
        foreach ($this->results as $result) {
            if ($result['success']) {
                $durations[] = $result['duration'];
            }
        }

        if (empty($durations)) {
            return ['无成功请求可用于性能分析'];
        }

        sort($durations);

        return [
            'fastest_request' => round(min($durations), 3),
            'slowest_request' => round(max($durations), 3),
            'median_duration' => round($durations[floor(count($durations) / 2)], 3),
            'total_execution_time' => round(microtime(true) - $this->startTime, 2)
        ];
    }

    public function close() {
        foreach ($this->requests as $request) {
            if (is_resource($request['handle'])) {
                curl_multi_remove_handle($this->multiHandle, $request['handle']);
                curl_close($request['handle']);
            }
        }

        if (is_resource($this->multiHandle)) {
            curl_multi_close($this->multiHandle);
        }

        $this->requests = [];
        $this->results = [];
        $this->monitoringData = [];
    }

    public function __destruct() {
        $this->close();
    }
}

// 使用高级监控器
$monitor = new AdvancedMultiMonitor();

// 添加多个请求进行监控
$urls = [
    'fast_api' => 'https://httpbin.org/delay/1',
    'medium_api' => 'https://httpbin.org/delay/2',
    'slow_api' => 'https://httpbin.org/delay/3',
    'json_api' => 'https://httpbin.org/json',
    'xml_api' => 'https://httpbin.org/xml'
];

foreach ($urls as $id => $url) {
    $monitor->addRequest($url, $id, ['type' => 'api_call']);
}

$report = $monitor->execute();

// 显示报告摘要
$summary = $report['summary'];
echo "\n=== 执行报告摘要 ===\n";
echo "总请求数: {$summary['total_requests']}\n";
echo "成功请求: {$summary['successful_requests']}\n";
echo "成功率: {$summary['success_rate']}%\n";
echo "平均耗时: {$summary['average_duration']} 秒\n";
echo "总数据传输: {$summary['total_data_mb']} MB\n";

// 显示性能分析
$performance = $report['performance_analysis'];
echo "\n=== 性能分析 ===\n";
echo "最快请求: {$performance['fastest_request']} 秒\n";
echo "最慢请求: {$performance['slowest_request']} 秒\n";
echo "中位数耗时: {$performance['median_duration']} 秒\n";
echo "总执行时间: {$performance['total_execution_time']} 秒\n";

$monitor->close();
@endphp