php如何实现接口请求重试机制_phpcurl重试次数间隔与失败回调处理方案

function httpRequestWithRetry($url, $maxRetries = 3, $onFailure = null) {
    $ch = curl_init();
    // 设置 cURL 参数
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_TIMEOUT, 5);

    for ($i = 0; $i <= $maxRetries; $i++) {
        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        $error = curl_error($ch);

        if (!$error && $response !== false && $httpCode >= 200 && $httpCode < 300) {
            curl_close($ch);
            return ['success' => true, 'data' => $response];
        }

        // 判断是否需要重试
        if ($i < $maxRetries && in_array(curl_errno($ch), [CURLE_COULDNT_CONNECT, CURLE_OPERATION_TIMEOUTED])) {
            usleep(1000000); // 等待 1 秒
            continue;
        }

        // 所有重试失败，触发回调
        if ($onFailure && is_callable($onFailure)) {
            $onFailure([
                'url' => $url,
                'http_code' => $httpCode,
                'error' => $error,
                'retry_count' => $i
            ]);
        }
        break;
    }
    curl_close($ch);
    return ['success' => false, 'error' => 'Request failed after retries'];
}

httpRequestWithRetry(
    'https://api.example.com/data',
    3,
    function($log) {
        error_log("API 请求失败: {$log['url']}，状态码: {$log['http_code']}，错误: {$log['error']}");
        // 可扩展：发送邮件、写数据库、推送至监控系统
    }
);