curl_multi_close 與curl_getinfo 配合使用時的數據同步問題

gitbox 2025-05-12

在PHP 中， curl_multi_*系列函數提供了異步處理多個cURL 請求的能力，這對於需要同時請求多個URL 並等待結果的場景非常有用。在這些異步請求中， curl_getinfo用於獲取有關每個請求的詳細信息，比如HTTP 狀態碼、請求的URL、傳輸的時間等。然而，在使用curl_multi_close關閉一個多cURL 會話時，如何正確地獲取和處理每個請求的返回信息，避免數據同步問題，成為開發者在實際開發中常常遇到的難題。

本文將討論如何在使用curl_multi_close進行多個請求的處理時，確保通過curl_getinfo正確地獲取請求的詳細信息，並避免由於請求關閉時機不當而產生的數據同步問題。

1. 了解curl_multi_*函數和curl_getinfo的基本用法

在PHP 中， curl_multi_*函數允許我們同時發起多個cURL 請求，通過多線程並行處理它們。例如，使用curl_multi_init來初始化一個cURL 句柄集，使用curl_multi_add_handle添加多個cURL 句柄，然後通過curl_multi_exec執行並等待所有請求完成。最後，使用curl_multi_close關閉會話。

以下是一個簡單的示例：

 $mh = curl_multi_init();  // 初始化 multi curl 句柄
$ch1 = curl_init("http://gitbox.net/api/data1");  // 請求 1
$ch2 = curl_init("http://gitbox.net/api/data2");  // 請求 2

curl_multi_add_handle($mh, $ch1);  // 添加請求 1
curl_multi_add_handle($mh, $ch2);  // 添加請求 2

do {
    $mrc = curl_multi_exec($mh, $active);
} while ($active && $mrc == CURLM_OK);

curl_multi_remove_handle($mh, $ch1);  // 移除請求 1
curl_multi_remove_handle($mh, $ch2);  // 移除請求 2

curl_multi_close($mh);  // 關閉 multi curl 句柄

2. 數據同步問題的根源

當多個請求同時執行時，通常我們會希望能夠在所有請求完成後獲取它們的詳細信息。 curl_getinfo函數用於獲取每個cURL 請求的執行信息，比如返回的狀態碼（ CURLINFO_HTTP_CODE ）和其他元數據。然而，由於多個請求是異步並行進行的， curl_getinfo需要在適當的時機調用，確保不會在請求還沒有完全執行完畢時就獲取到數據。

如果你在請求完成之前調用curl_getinfo ，你可能會得到錯誤的或不完整的數據。因此，合理的同步時機非常重要。

3. 正確的使用順序和同步策略

3.1 通過curl_multi_select來處理並發請求

當你調用curl_multi_exec執行多個請求時，PHP 會進入一個循環，直到所有請求都執行完成。在這個過程中， curl_multi_select也可以幫助我們處理事件的等待，使得我們能夠更好地控制何時獲取請求的結果。

 do {
    // 等待請求完成
    $mrc = curl_multi_exec($mh, $active);

    // 等待直到有數據準備好
    if ($active) {
        curl_multi_select($mh);
    }
} while ($active && $mrc == CURLM_OK);

3.2 確保在移除句柄後再獲取數據

一旦所有請求完成並且所有句柄都被移除，才是獲取請求信息的合適時機。否則，如果你提前關閉句柄，可能會錯過一些請求的結果。

 // 获取請求信息
$info1 = curl_getinfo($ch1);
$info2 = curl_getinfo($ch2);

// 輸出信息
echo "Request 1 HTTP Code: " . $info1['http_code'] . "\n";
echo "Request 2 HTTP Code: " . $info2['http_code'] . "\n";

3.3 使用curl_multi_remove_handle來移除句柄

在獲取數據之後，記得將每個句柄從curl_multi會話中移除，並在最後關閉它們。這樣可以確保不會再嘗試獲取已經關閉的請求的結果。

 curl_multi_remove_handle($mh, $ch1);
curl_multi_remove_handle($mh, $ch2);

4. 代碼示例：綜合應用

結合前面提到的內容，以下是一個更完整的示例，展示瞭如何正確地獲取每個請求的詳細信息，並確保沒有數據同步問題：

 $mh = curl_multi_init();  // 初始化 multi curl 句柄
$ch1 = curl_init("http://gitbox.net/api/data1");  // 請求 1
$ch2 = curl_init("http://gitbox.net/api/data2");  // 請求 2

curl_multi_add_handle($mh, $ch1);  // 添加請求 1
curl_multi_add_handle($mh, $ch2);  // 添加請求 2

// 执行請求并等待完成
do {
    $mrc = curl_multi_exec($mh, $active);
    if ($active) {
        curl_multi_select($mh);  // 等待數據準備好
    }
} while ($active && $mrc == CURLM_OK);

// 获取請求的执行信息
$info1 = curl_getinfo($ch1);
$info2 = curl_getinfo($ch2);

// 输出請求信息
echo "Request 1 HTTP Code: " . $info1['http_code'] . "\n";
echo "Request 2 HTTP Code: " . $info2['http_code'] . "\n";

// 移除句柄
curl_multi_remove_handle($mh, $ch1);
curl_multi_remove_handle($mh, $ch2);

// 關閉 multi curl 句柄
curl_multi_close($mh);

結論

通過正確使用curl_multi_exec和curl_multi_select ，以及確保在請求完成後再通過curl_getinfo獲取信息，可以有效避免由於異步請求而導致的數據同步問題。對於並發請求的處理，時機的把握至關重要，合理的調用順序和同步策略能夠確保獲取到正確的數據。