解决PHP cURL循环POST请求403错误：结构化处理与最佳实践

<?php
// 假设 $postdata 是一个包含多个待发送数据项的数组
foreach( $postdata AS $item ) {
    $url = "https://example.com/api/endpoint";
    $requestHeader = ["authtoken: 123456789"]; // 注意：每次循环都会重新定义这个数组，可能导致内存开销或意外行为

    $fields_string = http_build_query($item);

    $ch = curl_init();

    curl_setopt($ch, CURLOPT_HTTPHEADER, $requestHeader);
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_POSTFIELDS, $fields_string);
    // 缺少 CURLOPT_RETURNTRANSFER，这意味着 curl_exec 会直接输出响应

    $result = curl_exec($ch);
    echo $result;

    curl_close($ch);
}
?>

<?php
// 假设这是您的原始数据源
$raw_data_items = [
    [
        'name' => 'Peter Apimann',
        'email' => 'peter.apimann@example.com',
        'website' => 'www.a.de',
        'phonenumber' => '123456789',
        'company' => 'Apimann Gmbh',
        'address' => 'Straße 1',
        'city' => 'Neu-Isengard',
        'zip' => '12345',
        'state' => 'Mordor',
        'description' => 'We are a fictional Company',
        'isCompetitor'  => false,
        'source' => '11',
        'status' => '16',
        'custom_fields[leads][11]' => "<a target='_blank' href='https://google.de'>visit link</a>"
    ],
    [
        'name' => 'John Doe',
        'email' => 'john.doe@example.com',
        'website' => 'www.b.com',
        'phonenumber' => '987654321',
        'company' => 'Doe Corp',
        'address' => 'Main Street 10',
        'city' => 'Someville',
        'zip' => '54321',
        'state' => 'Imaginary',
        'description' => 'Another fictional Company',
        'isCompetitor'  => true,
        'source' => '12',
        'status' => '17',
        'custom_fields[leads][11]' => "<a target='_blank' href='https://bing.com'>search link</a>"
    ],
    // ... 更多数据项
];

// 将所有待发送项收集到一个数组中
$itemsToSend = [];
foreach ($raw_data_items as $item) {
    // 可以在这里对每个 $item 进行任何必要的预处理或验证
    $itemsToSend[] = $item;
}
?>

<?php
/**
 * 执行一个 cURL POST 请求并返回结果。
 *
 * @param array $dataArray 要 POST 的数据。
 * @return array 包含请求结果的数组 (success, response, http_code, error)。
 */
function makeCurlPostRequest(array $dataArray): array {
    $url = "https://example.com/api/endpoint";
    $authToken = "123456789"; // 认证令牌

    $curl = curl_init();

    // 构建 POST 字段
    $postFields = http_build_query($dataArray);

    // 设置 cURL 选项
    curl_setopt($curl, CURLOPT_URL, $url);
    curl_setopt($curl, CURLOPT_POST, true);
    curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); // 关键：返回响应内容而不是直接输出
    curl_setopt($curl, CURLOPT_HTTPHEADER, [
        "authtoken: " . $authToken,
        "Content-Type: application/x-www-form-urlencoded", // 明确指定内容类型
        "User-Agent: YourApplicationName/1.0 (PHP cURL)", // 建议添加 User-Agent
    ]);
    curl_setopt($curl, CURLOPT_POSTFIELDS, $postFields);
    // 更多选项：
    // curl_setopt($curl, CURLOPT_TIMEOUT, 30); // 设置请求超时时间（秒）
    // curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false); // 如果遇到SSL证书问题，可以暂时禁用（不推荐生产环境）

    // 执行请求
    $response = curl_exec($curl);

    // 检查是否有 cURL 错误
    if (curl_errno($curl)) {
        $error_msg = curl_error($curl);
        curl_close($curl);
        return ['success' => false, 'error' => 'cURL Error: ' . $error_msg];
    }

    // 获取 HTTP 状态码
    $http_code = curl_getinfo($curl, CURLINFO_HTTP_CODE);

    curl_close($curl);

    // 根据 HTTP 状态码判断成功或失败
    if ($http_code >= 200 && $http_code < 300) {
        return ['success' => true, 'response' => $response, 'http_code' => $http_code];
    } else {
        return ['success' => false, 'response' => $response, 'http_code' => $http_code, 'error' => "HTTP Error: " . $http_code];
    }
}
?>

<?php
// ... (接上文的数据收集和函数定义)

echo "开始批量发送 POST 请求...\n";
foreach ($itemsToSend as $index => $item) {
    echo "正在发送第 " . ($index + 1) . " 条数据...\n";
    $result = makeCurlPostRequest($item);

    if ($result['success']) {
        echo "请求成功 (HTTP " . $result['http_code'] . "). 响应: " . substr($result['response'], 0, 100) . "...\n";
    } else {
        echo "请求失败 (HTTP " . ($result['http_code'] ?? 'N/A') . "). 错误: " . ($result['error'] ?? '未知错误') . ". 响应: " . substr($result['response'], 0, 100) . "...\n";
        // 可以在这里添加更复杂的错误处理逻辑，例如记录到日志文件，或者将失败的请求放入队列进行重试
    }

    // 关键：在每次请求之间添加一个短暂的延迟，以避免触发速率限制
    usleep(200000); // 延迟 200 毫秒 (0.2秒)，根据API的速率限制策略调整
}
echo "所有请求发送完毕。\n";
?>