【PHP8.x】curl_multi_init関数の使い方

<?php

/**
 * PHP cURL Multi API の基本的な使用例。
 * 複数のHTTPリクエストを並行して実行し、結果を取得します。
 * curl_multi_init() 関数は、複数の cURL ハンドルを管理するためのマルチ cURL ハンドルを初期化します。
 */
function runCurlMultiExample(): void
{
    echo "--- cURL Multi Example - Start ---\n";

    // 1. マルチ cURL ハンドルを初期化します。
    // これにより、複数の cURL リクエストを同時に管理するための CurlMultiHandle オブジェクトが作成されます。
    $mh = curl_multi_init();
    if ($mh === false) {
        echo "エラー: マルチ cURL ハンドルの初期化に失敗しました。\n";
        return;
    }

    $ch = []; // 個々の cURL ハンドルを格納する配列
    $urls = [
        "https://httpbin.org/get?param=one",
        "https://httpbin.org/get?param=two",
        "https://httpbin.org/get?param=three",
    ];

    // 2. 複数の cURL ハンドルを作成し、オプションを設定し、マルチハンドルに追加します。
    foreach ($urls as $index => $url) {
        $ch[$index] = curl_init(); // 個々の cURL ハンドルを初期化
        if ($ch[$index] === false) {
            echo "エラー: URL '{$url}' の cURL ハンドルの初期化に失敗しました。\n";
            continue;
        }

        curl_setopt($ch[$index], CURLOPT_URL, $url);
        curl_setopt($ch[$index], CURLOPT_RETURNTRANSFER, true); // 結果を文字列として取得
        curl_setopt($ch[$index], CURLOPT_HEADER, false);      // レスポンスヘッダを含めない

        // 個々の cURL ハンドルをマルチ cURL ハンドルに追加します。
        curl_multi_add_handle($mh, $ch[$index]);
        echo "追加: URL '{$url}' の cURL ハンドルをマルチハンドルに追加しました。\n";
    }

    // 追加されたハンドルがない場合は終了
    if (empty($ch)) {
        echo "エラー: 処理する cURL ハンドルがありません。終了します。\n";
        curl_multi_close($mh);
        return;
    }

    // 3. すべてのリクエストが完了するまで実行します。
    // $running には、まだ処理中のリクエストの数が格納されます。
    $running = null;
    do {
        // curl_multi_exec() は、アクティブなリクエストを同時に実行し、ステータスを更新します。
        $status = curl_multi_exec($mh, $running);

        // まだ実行中のリクエストがある場合、ネットワーク I/O を待機します。
        // curl_multi_select() は、ソケットアクティビティがあるまでブロックします。
        if ($running > 0) {
            curl_multi_select($mh);
        }
    } while ($running > 0 && $status === CURLM_OK);

    // エラーチェック
    if ($status !== CURLM_OK) {
        echo "エラー: cURL multi exec が失敗しました。ステータス: " . $status . "\n";
    }

    echo "\nすべての cURL リクエストが完了しました。結果を取得します。\n";

    // 4. 各リクエストの結果を取得します。
    foreach ($ch as $index => $handle) {
        // curl_multi_getcontent() で、完了した cURL ハンドルからレスポンスボディを取得します。
        $response = curl_multi_getcontent($handle);
        $info = curl_getinfo($handle); // リクエストに関する詳細情報を取得

        if ($response === false) {
            $error = curl_error($handle);
            echo "--- URL '{$urls[$index]}' のエラー ---\n";
            echo "エラーメッセージ: $error\n";
        } else {
            echo "--- URL '{$urls[$index]}' のレスポンス (HTTP {$info['http_code']}) ---\n";
            // JSON レスポンスの場合、デコードして整形すると見やすくなります。
            $decodedResponse = json_decode($response, true);
            if ($decodedResponse !== null) {
                echo json_encode($decodedResponse, JSON_PRETTY_PRINT) . "\n";
            } else {
                echo $response . "\n";
            }
        }
        echo "---------------------------------------------------\n";

        // 5. 個々の cURL ハンドルをマルチ cURL ハンドルから削除し、閉じます。
        curl_multi_remove_handle($mh, $handle);
        curl_close($handle);
    }

    // 6. マルチ cURL ハンドルを閉じます。
    // これにより、関連するリソースが解放されます。
    curl_multi_close($mh);

    echo "--- cURL Multi Example - End ---\n";
}

// 関数を実行します。
runCurlMultiExample();

?>

curl_multi_init関数は、PHPで複数のHTTPリクエストを並行して効率的に処理するための「マルチcURLハンドル」を初期化する際に使用されます。この関数は引数を必要とせず、呼び出すと、複数のcURLリクエストを同時に管理できるCurlMultiHandle型のオブジェクトを戻り値として返します。

システムエンジニアを目指す初心者の方にとって、ウェブサイトの構築などで、複数の外部APIから同時にデータを取得したい場合などに非常に有効な機能です。個々のリクエストを順番に処理するのではなく、並行して実行することで、全体の処理時間を大幅に短縮できるメリットがあります。

サンプルコードでは、まずこのcurl_multi_init()関数を呼び出してマルチcURLハンドル $mh を作成しています。これは、複数のcURLリクエストをまとめるための「親」のような役割を果たします。その後、個々のURLに対してcurl_init()で作成した通常のcURLハンドルを、curl_multi_add_handle()関数を使ってこの $mh に追加していきます。最終的に、curl_multi_exec()関数を使って、追加されたすべてのリクエストを同時に実行し、処理が完了したらcurl_multi_close()でリソースを解放します。curl_multi_init()は、この並行処理の起点となる重要な関数です。