[php] PHP에서 비동기 HTTP 요청을 만드는 방법

PHP에서 비동기 HTTP 호출을 수행하는 방법이 있습니까? 응답에 신경 쓰지 않고 단지 다음과 같은 일을하고 싶습니다.file_get_contents() 하고 싶지만 나머지 코드를 실행하기 전에 요청이 끝날 때까지 기다리지 않습니다. 이것은 내 응용 프로그램에서 일종의 “이벤트”를 설정하거나 긴 프로세스를 트리거하는 데 매우 유용합니다.

어떤 아이디어?

답변

이전에 수락 한 답변이 작동하지 않았습니다. 여전히 응답을 기다렸습니다. 이것은 PHP에서 비동기 GET 요청 을 어떻게합니까? 에서 가져온 것입니다 .

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);
}

답변

비동기식으로 호출하려는 대상 (예 : 자신의 “longtask.php”)을 제어하는 경우 해당 끝에서 연결을 닫을 수 있으며 두 스크립트가 동시에 실행됩니다. 다음과 같이 작동합니다.

quick.php는 cURL을 통해 longtask.php를 엽니 다 (여기에는 마법이 없습니다).
longtask.php는 연결을 닫고 계속합니다 (매직!)
연결이 닫히면 cURL이 quick.php로 돌아갑니다.
두 작업이 동시에 진행됩니다

나는 이것을 시도했지만 잘 작동합니다. 그러나 프로세스 간 통신 수단을 만들지 않는 한 quick.php는 longtask.php의 작동 방식에 대해 전혀 알지 못합니다.

다른 작업을 수행하기 전에 longtask.php에서이 코드를 사용해보십시오. 연결이 닫히지 만 여전히 계속 실행되고 출력이 표시되지 않습니다.

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();

코드는 PHP 매뉴얼의 사용자가 제공 한 메모 에서 복사되었으며 다소 개선되었습니다.

답변

exec ()를 사용하여 HTTP 요청을 할 수있는 것을 호출하여 속임수를 쓸 수 wget있지만, 프로그램의 모든 출력을 파일이나 / dev / null과 같은 다른 곳으로 보내야합니다. 그렇지 않으면 PHP 프로세스가 해당 출력을 기다립니다 .

프로세스를 아파치 스레드와 완전히 분리하려면 다음과 같이 시도하십시오 (나는 확실하지 않지만 아이디어를 얻길 바랍니다).

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

그것은 좋은 사업이 아니며 아마도 실제 데이터베이스 이벤트 큐를 폴링하여 실제 비동기 이벤트를 수행하는 하트 비트 스크립트를 호출하는 크론 작업과 같은 것을 원할 것입니다.

답변

2018 년 현재 Guzzle 은 여러 최신 프레임 워크에서 사용되는 HTTP 요청의 사실상 표준 라이브러리가되었습니다. 순수 PHP로 작성되었으며 사용자 정의 확장을 설치할 필요가 없습니다.

비동기식 HTTP 호출을 매우 잘 수행 할 수 있으며, 100 번의 HTTP 호출을해야 할 때와 같이 풀링 할 수 있지만 한 번에 5 개 이상 실행하고 싶지는 않습니다.

동시 요청 예

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]

http://docs.guzzlephp.org/en/stable/quickstart.html#concurrent-requests를 참조 하십시오

답변

/**
 * 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 &");
}

답변

이 라이브러리를 사용할 수 있습니다 : https://github.com/stil/curl-easy

그때는 매우 간단합니다.

<?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
}

아래는 위 예제의 콘솔 출력입니다. 얼마나 많은 시간 요청이 실행되고 있는지를 나타내는 간단한 라이브 시계가 표시됩니다.

답변

CURL낮음 설정을 사용하여 요청 중단을 가짜CURLOPT_TIMEOUT_MS
ignore_user_abort(true)연결이 닫힌 후에도 처리를 유지하도록 설정 합니다.

이 방법을 사용하면 OS, 브라우저 및 PHP 버전에 따라 헤더 및 버퍼를 통한 연결 처리를 구현할 필요가 없습니다.

마스터 프로세스

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');

백그라운드 프로세스

ignore_user_abort(true);

//do something...

cURL이 1 초 이내에 시간 초과되도록하려면 CURLOPT_TIMEOUT_MS를 사용할 수 있지만 “Unix-like systems”에 버그 / “기능”이있어 값이 <1000ms 인 경우 libcurl이 즉시 시간 초과되도록하는 버그 / “기능”이 있습니다. cURL 오류 (28) : 시간이 초과되었습니다 “. 이 동작에 대한 설명은 다음과 같습니다.

[…]

해결책은 CURLOPT_NOSIGNAL을 사용하여 신호를 비활성화하는 것입니다.

자원