Как сделать асинхронные Запросы HTTP в PHP

В Java все переменные, которые вы объявляете, на самом деле являются «ссылками» на объекты (или примитивы), а не самими объектами.

При попытке выполнить один метод объекта , ссылка просит живой объект выполнить этот метод. Но если ссылка ссылается на NULL (ничего, нуль, void, nada), то нет способа, которым метод будет выполнен. Тогда runtime сообщит вам об этом, выбросив исключение NullPointerException.

Ваша ссылка «указывает» на нуль, таким образом, «Null -> Pointer».

Объект живет в памяти виртуальной машины пространство и единственный способ доступа к нему - использовать ссылки this. Возьмем этот пример:

public class Some {
    private int id;
    public int getId(){
        return this.id;
    }
    public setId( int newId ) {
        this.id = newId;
    }
}

И в другом месте вашего кода:

Some reference = new Some();    // Point to a new object of type Some()
Some otherReference = null;     // Initiallly this points to NULL

reference.setId( 1 );           // Execute setId method, now private var id is 1

System.out.println( reference.getId() ); // Prints 1 to the console

otherReference = reference      // Now they both point to the only object.

reference = null;               // "reference" now point to null.

// But "otherReference" still point to the "real" object so this print 1 too...
System.out.println( otherReference.getId() );

// Guess what will happen
System.out.println( reference.getId() ); // :S Throws NullPointerException because "reference" is pointing to NULL remember...

Это важно знать - когда больше нет ссылок на объект (в пример выше, когда reference и otherReference оба указывают на null), тогда объект «недоступен». Мы не можем работать с ним, поэтому этот объект готов к сбору мусора, и в какой-то момент VM освободит память, используемую этим объектом, и выделит другую.

202
задан Simon East 8 July 2018 в 20:04
поделиться

6 ответов

Ответ, который я ранее принял, не сработал. Он все еще ждал ответов. Однако это работает, взято из Как мне сделать асинхронный запрос GET в 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);
}
43
ответ дан 23 November 2019 в 05:02
поделиться

Можно сделать обман при помощи должностного лица () для вызова чего-то, что может сделать Запросы HTTP, как wget, но необходимо направить весь вывод от программы до где-нибудь, как файл или/dev/null, иначе процесс PHP будет ожидать того вывода.

, Если Вы хотите разделить процесс от апачского потока полностью, попробуйте что-то как (я не уверен в этом, но я надеюсь, что Вы получаете идею):

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

Это не хороший бизнес, и Вы, вероятно, захотите что-то как задание крона, вызывающее сценарий heartbeat, который опрашивает фактическую очередь событий базы данных, чтобы сделать реальные асинхронные события.

15
ответ дан Internet Friend 23 November 2019 в 05:02
поделиться

этому нужен php5, я украл его из docs.php.net и отредактировал конец.

я использую его для контроля, когда ошибка происходит на клиентском сайте, это отсылает данные мне, не держа вывод

function do_post_request($url, $data, $optional_headers = null,$getresponse = false) {
    $params = array(
        'http' => array(
            'method' => 'POST',
            'content' => $data
        )
    );
    if ($optional_headers !== null) {
         $params['http']['header'] = $optional_headers;
    }
    $ctx = stream_context_create($params);
    $fp = @fopen($url, 'rb', false, $ctx);

    if (!$fp) {
        return false;
    }

    if ($getresponse) {
        $response = stream_get_contents($fp);
        return $response;
    }
    return true;
}
25
ответ дан Manoj Sharma 23 November 2019 в 05:02
поделиться

Я нахожу этот пакет довольно полезным и очень простым: https://github.com/amphp/parallel-functions

<?php

use function Amp\ParallelFunctions\parallelMap;
use function Amp\Promise\wait;

$responses = wait(parallelMap([
    'https://google.com/',
    'https://github.com/',
    'https://stackoverflow.com/',
], function ($url) {
    return file_get_contents($url);
}));

Это загрузит все 3 URL параллельно. Можно также использовать методы экземпляров классов в закрытии.

, Например, я использую расширение Laravel на основе этого пакета https://, github.com/spatie/laravel-collection-macros#parallelmap

Здесь является моим кодом:

    /**
     * Get domains with all needed data
     */
    protected function getDomainsWithdata(): Collection
    {
        return $this->opensrs->getDomains()->parallelMap(function ($domain) {
            $contact = $this->opensrs->getDomainContact($domain);
            $contact['domain'] = $domain;
            return $contact;
        }, 10);
    }

Это загружает все необходимые данные в 10 параллельных потоках, и вместо 50 secs без асинхронного это закончилось во всего 8 secs.

0
ответ дан 23 November 2019 в 05:02
поделиться

Если вы контролируете цель, которую хотите вызвать асинхронно (например, ваш собственный "longtask.php"), вы можете закрыть соединение с этого конца, и оба скрипта будут работать параллельно. Это работает так:

  1. quick.php открывает longtask.php через cURL (никакой магии здесь нет)
  2. longtask.php закрывает соединение и продолжает работу (магия!)
  3. cURL возвращается к quick.php, когда соединение закрыто
  4. Обе задачи продолжаются параллельно

Я пробовал это, и это работает просто отлично. Но 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 в примечаниях пользователя и несколько улучшен.

26
ответ дан 23 November 2019 в 05:02
поделиться
/**
 * 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 &");
}
8
ответ дан 23 November 2019 в 05:02
поделиться
Другие вопросы по тегам:

Похожие вопросы: