curl_multi_selectでのレスポンスの取得について

Question

php5.6.24 環境でWEB APIへ複数のデータを一括でPOSTし、更新する処理を作成中です。

参考にしているコードはcurl_multiでHTTP並行リクエストを行うサンプル

curl_multi_select時に一部データがfalseしか取得できない現象が発生し困り果てています。
同一のデータで複数回実行した際にも、一部データのみFALSEになる場合や、全件正常に取得できる場合などもあります。

curl_multi_info_read実行時に複数のデータを掴んでいることもあるとの記事を見つけたのですが、複数のデータを取得する繰り返し処理を下記コードに追加する必要があるでしょうか。

今回、作成している処理では、同一のAPIへCURLOPT_POSTFIELDSに持たせたキー値を元にした更新処理となります。
上記の参考記事以外にもあちこち見ているのですが、基本的に別々のAPI(URL)への接続を想定しており、
同一API(URL)への並列処理を想定したものが見当たりません。

また、根本的に同一のURLへの並列アクセスの場合は、レスポンスが正常に取得できないことなどはあるでしょうか。

よろしくお願いいたします。

<?php
//タイムアウト時間を決めておく
$TIMEOUT = 10; //10秒

$mh = curl_multi_init();
$url = 'http://example.com/api'
$header = array("Authorization:Bearer " . $accessToken,);

$i = 0;

foreach($datas as $data) {
    $params = array(
         'id' => $data->id,
         ...
         ...
         ...
    );

    ${$i} = curl_init($url);
    curl_setopt_array(${$i}, array(
    CURLOPT_POST           => true,
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_POSTFIELDS     => http_build_query($params),
    CURLOPT_HTTPHEADER     => $header,
    CURLOPT_TIMEOUT        => $TIMEOUT,
    CURLOPT_CONNECTTIMEOUT => $TIMEOUT,
    CURLOPT_VERBOSE        => TRUE,
    ));

    curl_multi_add_handle($mh, ${$i});
    $i++;
}

do {
    $stat = curl_multi_exec($mh, $running); //multiリクエストスタート
} while ($stat === CURLM_CALL_MULTI_PERFORM);
if ( ! $running || $stat !== CURLM_OK) {
    throw new RuntimeException('リクエストが開始出来なかった。マルチリクエスト内のどれか、URLの設定がおかしいのでは？');
}

do switch (curl_multi_select($mh, $TIMEOUT)) { //イベントが発生するまでブロック
    case -1: //selectに失敗。ありうるらしい。 https://bugs.php.net/bug.php?id=61141
        usleep(10); //ちょっと待ってからretry。ここも別の処理を挟んでもよい。
        do {
            $stat = curl_multi_exec($mh, $running);
        } while ($stat === CURLM_CALL_MULTI_PERFORM);
        continue 2;

    case 0:  //タイムアウト -> 必要に応じてエラー処理に入るべきかも。
        continue 2; //ここではcontinueでリトライします。

    default: //どれかが成功 or 失敗した
        do {
            $stat = curl_multi_exec($mh, $running); //ステータスを更新
        } while ($stat === CURLM_CALL_MULTI_PERFORM);

        do if ($raised = curl_multi_info_read($mh, $remains)) {
            //変化のあったcurlハンドラを取得する
            $info = curl_getinfo($raised['handle']);
            echo "$info[url]: $info[http_code]\n";
            $response = curl_multi_getcontent($raised['handle']);

            if ($response === false) {
                //エラー。404などが返ってきている
                echo 'ERROR!!!', PHP_EOL;
            } else {
                //正常にレスポンス取得
                //戻り値（オブジェクト）からループでデータを取得する
                $responseXML = simplexml_load_string($response);

                $result_num = count($responseXML->Result);
                if ($result_num > 0) {
                    $result = $responseXML->Result[0];
                    array_push($returnList, $result->Status);
                }
            }
            curl_multi_remove_handle($mh, $raised['handle']);
            curl_close($raised['handle']);
        } while ($remains);
        //select前に全ての処理が終わっていたりすると
        //複数の結果が入っていることがあるのでループが必要
} while ($running);
echo 'finished', PHP_EOL;
curl_multi_close($mh);

Answer 1

よく理解していないので、的はずれな回答になるかもしれませんが。。。
curl_multi の接続上限設定
これ、参考になりませんか？

Comments

[yu-]

ご回答ありがとうございます。
ご紹介いただいた記事について参考にさせていただきます。

Answer 2

はっきりとした原因が分かった訳ではないのですが、

http://www.onlineaspect.com/2009/01/26/how-to-use-curl_multi-without-blocking/

を参考にコーディングして見たところ、期待通りの結果を得ることができました。

function rolling_curl($urls, $callback, $custom_options = null) {

    $rolling_window = 5;
    $rolling_window = (sizeof($urls) < $rolling_window) ? sizeof($urls) : $rolling_window;

    $master = curl_multi_init();
    $curl_arr = array();

    $std_options = array(CURLOPT_RETURNTRANSFER => true,
    CURLOPT_FOLLOWLOCATION => true,
    CURLOPT_MAXREDIRS => 5);
    $options = ($custom_options) ? ($std_options + $custom_options) : $std_options;

    for ($i = 0; $i < $rolling_window; $i++) {
        $ch = curl_init();
        $options[CURLOPT_URL] = $urls[$i];
        curl_setopt_array($ch,$options);
        curl_multi_add_handle($master, $ch);
    }

    do {
        while(($execrun = curl_multi_exec($master, $running)) == CURLM_CALL_MULTI_PERFORM);
        if($execrun != CURLM_OK)
            break;
        while($done = curl_multi_info_read($master)) {
            $info = curl_getinfo($done['handle']);
            if ($info['http_code'] == 200)  {
                $output = curl_multi_getcontent($done['handle']);

                $callback($output);

                $ch = curl_init();
                $options[CURLOPT_URL] = $urls[$i++]; 
                curl_setopt_array($ch,$options);
                curl_multi_add_handle($master, $ch);

                curl_multi_remove_handle($master, $done['handle']);
            } else {
                // エラー発生時
            }
        }
    } while ($running);
   
    curl_multi_close($master);
    return true;
}