Cómo hacer solicitudes HTTP en PHP y no esperar la respuesta

Question 1

¿Hay alguna forma en PHP de hacer llamadas HTTP y no esperar una respuesta? No me importa la respuesta, solo quiero hacer algo como file_get_contents(), pero no espere a que finalice la solicitud antes de ejecutar el resto de mi código. Esto sería muy útil para desencadenar “eventos” de algún tipo en mi aplicación o desencadenar procesos largos.

¿Algunas ideas?

Question 2

La respuesta que había aceptado previamente no funcionó. Todavía esperaba respuestas. Sin embargo, esto funciona, tomado de ¿Cómo hago una solicitud GET asíncrona en PHP?

function post_without_wait($url, $params)
{
    foreach ($params as $key => &$val) {
      if (is_array($val)) $val = implode(',', $val);
        $post_params[] = $key.'='.urlencode($val);
    }
    $post_string = implode('&', $post_params);

    $parts=parse_url($url);

    $fp = fsockopen($parts['host'],
        isset($parts['port'])?$parts['port']:80,
        $errno, $errstr, 30);

    $out = "POST ".$parts['path']." HTTP/1.1\r\n";
    $out.= "Host: ".$parts['host']."\r\n";
    $out.= "Content-Type: application/x-www-form-urlencoded\r\n";
    $out.= "Content-Length: ".strlen($post_string)."\r\n";
    $out.= "Connection: Close\r\n\r\n";
    if (isset($post_string)) $out.= $post_string;

    fwrite($fp, $out);
    fclose($fp);
}

Question 3

Si controla el objetivo al que desea llamar de forma asincrónica (por ejemplo, su propio “longtask.php”), puede cerrar la conexión desde ese extremo y ambos scripts se ejecutarán en paralelo. Funciona así:

quick.php abre longtask.php a través de cURL (sin magia aquí)
longtask.php cierra la conexión y continúa (¡magia!)
cURL vuelve a quick.php cuando se cierra la conexión
Ambas tareas continúan en paralelo

He probado esto, y funciona bien. Pero quick.php no sabrá nada sobre el rendimiento de longtask.php, a menos que cree algún medio de comunicación entre los procesos.

Pruebe este código en longtask.php, antes de hacer cualquier otra cosa. Cerrará la conexión, pero seguirá ejecutándose (y suprimirá cualquier salida):

while(ob_get_level()) ob_end_clean();
header('Connection: close');
ignore_user_abort();
ob_start();
echo('Connection Closed');
$size = ob_get_length();
header("Content-Length: $size");
ob_end_flush();
flush();

El código se copia de la Notas aportadas por el usuario del manual de PHP y algo mejorado.

Question 4

Puede hacer trucos usando exec() para invocar algo que puede hacer solicitudes HTTP, como wgetpero debe dirigir toda la salida del programa a algún lugar, como un archivo o /dev/null, de lo contrario, el proceso de PHP esperará esa salida.

Si desea separar el proceso del hilo de apache por completo, intente algo como (no estoy seguro de esto, pero espero que entienda la idea):

exec('bash -c "wget -O (url goes here) > /dev/null 2>&1 &"');

No es un buen negocio, y probablemente querrá algo como un trabajo cron que invoque un script de latido que sondee una cola de eventos de base de datos real para hacer eventos asincrónicos reales.

Question 5

Puedes usar esta biblioteca: https://github.com/stil/curl-fácil

Es bastante sencillo entonces:

<?php
$request = new cURL\Request('http://yahoo.com/');
$request->getOptions()->set(CURLOPT_RETURNTRANSFER, true);

// Specify function to be called when your request is complete
$request->addListener('complete', function (cURL\Event $event) {
    $response = $event->response;
    $httpCode = $response->getInfo(CURLINFO_HTTP_CODE);
    $html = $response->getContent();
    echo "\nDone.\n";
});

// Loop below will run as long as request is processed
$timeStart = microtime(true);
while ($request->socketPerform()) {
    printf("Running time: %dms    \r", (microtime(true) - $timeStart)*1000);
    // Here you can do anything else, while your request is in progress
}

A continuación puede ver la salida de la consola del ejemplo anterior. Mostrará un reloj en vivo simple que indica cuánto tiempo se está ejecutando la solicitud:

animación

Question 6

A partir de 2018, Engullir se ha convertido en la biblioteca estándar de facto para solicitudes HTTP, utilizada en varios marcos modernos. Está escrito en PHP puro y no requiere instalar ninguna extensión personalizada.

Puede hacer llamadas HTTP asincrónicas muy bien, e incluso juntarlos como cuando necesita realizar 100 llamadas HTTP, pero no desea ejecutar más de 5 a la vez.

Ejemplo de solicitud simultánea

use GuzzleHttp\Client;
use GuzzleHttp\Promise;

$client = new Client(['base_uri' => 'http://httpbin.org/']);

// Initiate each request but do not block
$promises = [
    'image' => $client->getAsync('/image'),
    'png'   => $client->getAsync('/image/png'),
    'jpeg'  => $client->getAsync('/image/jpeg'),
    'webp'  => $client->getAsync('/image/webp')
];

// Wait on all of the requests to complete. Throws a ConnectException
// if any of the requests fail
$results = Promise\unwrap($promises);

// Wait for the requests to complete, even if some of them fail
$results = Promise\settle($promises)->wait();

// You can access each result using the key provided to the unwrap
// function.
echo $results['image']['value']->getHeader('Content-Length')[0]
echo $results['png']['value']->getHeader('Content-Length')[0]

Ver http://docs.guzzlephp.org/en/stable/quickstart.html#concurrent-requests

Question 7

/**
 * Asynchronously execute/include a PHP file. Does not record the output of the file anywhere. 
 *
 * @param string $filename              file to execute, relative to calling script
 * @param string $options               (optional) arguments to pass to file via the command line
 */ 
function asyncInclude($filename, $options="") {
    exec("/path/to/php -f {$filename} {$options} >> /dev/null &");
}

Question 8

Falsificar una solicitud de aborto usando CURL estableciendo un nivel bajo CURLOPT_TIMEOUT_MS
colocar ignore_user_abort(true) para seguir procesando después de cerrar la conexión.

Con este método, no es necesario implementar el manejo de la conexión a través de encabezados y búfer demasiado dependientes del sistema operativo, el navegador y la versión de PHP.

proceso maestro

function async_curl($background_process=""){

    //-------------get curl contents----------------

    $ch = curl_init($background_process);
    curl_setopt_array($ch, array(
        CURLOPT_HEADER => 0,
        CURLOPT_RETURNTRANSFER =>true,
        CURLOPT_NOSIGNAL => 1, //to timeout immediately if the value is < 1000 ms
        CURLOPT_TIMEOUT_MS => 50, //The maximum number of mseconds to allow cURL functions to execute
        CURLOPT_VERBOSE => 1,
        CURLOPT_HEADER => 1
    ));
    $out = curl_exec($ch);

    //-------------parse curl contents----------------

    //$header_size = curl_getinfo($ch, CURLINFO_HEADER_SIZE);
    //$header = substr($out, 0, $header_size);
    //$body = substr($out, $header_size);

    curl_close($ch);

    return true;
}

async_curl('http://example.com/background_process_1.php');

proceso de fondo

ignore_user_abort(true);

//do something...

NÓTESE BIEN

Si desea que cURL se agote en menos de un segundo, puede usar CURLOPT_TIMEOUT_MS, aunque hay un error/”característica” en “sistemas similares a Unix” que hace que libcurl se agote inmediatamente si el valor es
[…]

La solución es deshabilitar las señales usando CURLOPT_NOSIGNAL

Recursos

¿El tiempo de espera de curl de menos de 1000 ms siempre falla?
http://www.php.net/manual/en/function.curl-setopt.php#104597
http://php.net/manual/en/features.conexión-manejo.php

Ejemplo de solicitud simultánea

¿Ha sido útil esta solución?