Requête curl asynchrone en PHP

Exécuter plusieurs requêtes curl simultanément peut être un défi en PHP. Dans cet article, nous explorerons différentes approches pour réaliser une exécution asynchrone à l'aide de fonctions intégrées et de bibliothèques externes.

cURL multi-threading

Les fonctions curl_multi_* de PHP permettent pour l'exécution asynchrone de plusieurs requêtes cURL. Voici un exemple :

curl_multi_init();
$mh = curl_multi_init();

$ch1 = curl_init();
curl_setopt($ch1, CURLOPT_URL, 'http://example.com/endpoint');
curl_multi_add_handle($mh, $ch1);

$ch2 = curl_init();
curl_setopt($ch2, CURLOPT_URL, 'http://example.com/endpoint2');
curl_multi_add_handle($mh, $ch2);

$active = null;
do {
    $mrc = curl_multi_exec($mh, $active);
} while ($mrc == CURLM_CALL_MULTI_PERFORM);

while ($active && $mrc == CURLM_OK) {
    if (curl_multi_select($mh) != -1) {
        do {
            $mrc = curl_multi_exec($mh, $active);
        } while ($mrc == CURLM_CALL_MULTI_PERFORM);
    }
}

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

pthreads

La bibliothèque pthreads permet la programmation multithread en PHP. En utilisant pthreads, les requêtes curl asynchrones peuvent être réalisées comme ceci :

class RequestThread extends Thread {
    public function run() {
        $ch = curl_init();
        // ... set cURL options here

        curl_exec($ch);
        curl_close($ch);
    }
}

$thread = new RequestThread();
$thread->start();

Exécution parallèle à l'aide de la bibliothèque

Il existe également des bibliothèques spécialement conçues pour l'exécution parallèle en PHP, telles que les fonctions parallèles et les fonctions parallèles. demande. Voici un exemple utilisant la bibliothèque de requêtes parallèles :

use Parallel\{Task, Runtime};

$runtime = new Runtime;

$tasks = [
    new Task(function () {
        // ... cURL request 1
    }),
    new Task(function () {
        // ... cURL request 2
    }),
];

$runtime->run($tasks);

Considérations

Lors de l'exécution de requêtes asynchrones, il est important de prendre en compte les limites de ressources du serveur et les goulots d'étranglement potentiels. Il est également crucial de gérer les erreurs et les exceptions qui peuvent survenir lors de l'exécution.