Как запустить асинхронно несколько запросов в php?

Пользователь

от elissa , в категории: PHP , год назад

Как запустить асинхронно несколько запросов в php?

Facebook Vk Ok Twitter LinkedIn Telegram Whatsapp

1 ответ

Пользователь

от richard , год назад

@elissa 

Для запуска нескольких запросов асинхронно в PHP можно использовать механизм многопоточности и функцию многопоточного выполнения - curl_multi_exec().


Вот простой пример, который выполняет три запроса к разным URL-адресам асинхронно:

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
// создаем массив URL-адресов, которые нужно запросить
$urls = array(
    'http://example.com/request1',
    'http://example.com/request2',
    'http://example.com/request3'
);

// создаем массив для хранения всех дескрипторов запросов
$ch = array();

// инициализируем мультикурл-дескриптор
$mh = curl_multi_init();

// создаем дескрипторы запросов и добавляем их в мультикурл-дескриптор
foreach ($urls as $url) {
    $ch[] = curl_init($url);
    curl_setopt($ch[count($ch) - 1], CURLOPT_RETURNTRANSFER, 1);
    curl_multi_add_handle($mh, $ch[count($ch) - 1]);
}

// выполняем запросы асинхронно
$active = null;
do {
    $mrc = curl_multi_exec($mh, $active);
} while ($mrc == CURLM_CALL_MULTI_PERFORM);

// обрабатываем результаты запросов
foreach ($ch as $c) {
    $response = curl_multi_getcontent($c);
    // обрабатываем ответ сервера
    echo $response;
    
    // удаляем дескриптор из мультикурл-дескриптора
    curl_multi_remove_handle($mh, $c);
}

// закрываем мультикурл-дескриптор
curl_multi_close($mh);


В этом примере мы создаем массив URL-адресов, которые мы хотим запросить. Затем мы создаем массив дескрипторов запросов и добавляем их в мультикурл-дескриптор. Затем мы выполняем запросы асинхронно с помощью функции curl_multi_exec().


После того, как все запросы завершены, мы обрабатываем результаты и закрываем мультикурл-дескриптор.


Обратите внимание, что в этом примере мы используем функцию curl_multi_getcontent() для получения содержимого ответа на запрос. Если вы используете другие функции curl для обработки ответа, то вы должны использовать соответствующие функции для получения ответа.