Как использовать amphp / параллельную библиотеку для неблокирующего процесса - PullRequest
Новая
       18

Как использовать amphp / параллельную библиотеку для неблокирующего процесса

0 голосов
/ 14 мая 2019

Я хочу использовать библиотеку amphp / parallel для неблокирующего процесса. У меня есть простая функция загрузки файла, которая скручивает попадание в удаленный файл изображения и сохраняет его в локальном файле. Я использую этот метод через REST API. По сути, мне нужен процесс, в котором aysnc-загрузка должна выполняться на бэкэнде, и это можно сказать так: REST API нажимает на функцию, а функция говорит: «Эй, хорошо, я загружаю в фоновом режиме, вы можете продолжить». Означает неблокирование, и API получает ответ как хорошо, а не ждать. Между тем, если при загрузке произошел сбой в сети, работник может через некоторое время перезапустить процесс. Как начать?

Я пробовал следующий код, но не работал. 

require_once "vendor/autoload.php";
use Amp\Loop;
use Amp\Parallel\Worker\CallableTask;
use Amp\Parallel\Worker\DefaultWorkerFactory;

\Amp\Loop::run(function () {
  $remote_file_url = "some remote image url"; //http://example.com/some.png
  $file_save_path = "save path for file"; //var/www/html/some.png
  $factory = new DefaultWorkerFactory();
  $worker = $factory->create();
  $result = yield $worker->enqueue(new CallableTask('downloadFile', [$remote_file_url, $file_save_path]));

  $code = yield $worker->shutdown();

  });

// downloadFile - простая функция загрузки 

function downloadFile($remoteFile, $localFile) {
    if (!$remoteFile || !$localFile) {
        return;
    }
    set_time_limit(0);
    $fp = fopen($localFile, 'w+');
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $remoteFile);
    curl_setopt($ch, CURLOPT_TIMEOUT, 50);
    curl_setopt($ch, CURLOPT_FILE, $fp);
    curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
    $result = curl_exec($ch);
    curl_close($ch);
    fclose($fp);

    return $result ? true : false;
}

Я получаю эту ошибку: 

PHP Fatal error:  Uncaught Amp\\Parallel\\Worker\\TaskError: Uncaught Error in worker with message "Call to undefined function downloadFile()" and code "0" in /var/www/html/test/vendor/amphp/parallel/lib/Worker/Internal/TaskFailure.php:45\nStack trace:\n#0 /var/www/html/test/vendor/amphp/parallel/lib/Worker/TaskWorker.php(126): Amp\\Parallel\\Worker\\Internal\\TaskFailure->promise()\n#1 [internal function]: Amp\\Parallel\\Worker\\TaskWorker->Amp\\Parallel\\Worker\\{closure}()\n#2 /var/www/html/test/vendor/amphp/amp/lib/Coroutine.php(76): Generator->send(Object(Amp\\Parallel\\Worker\\Internal\\TaskFailure))\n#3 /var/www/html/test/vendor/amphp/amp/lib/Internal/Placeholder.php(130): Amp\\Coroutine->Amp\\{closure}(NULL, Object(Amp\\Parallel\\Worker\\Internal\\TaskFailure))\n#4 /var/www/html/test/vendor/amphp/amp/lib/Coroutine.php(81): Amp\\Coroutine->resolve(Object(Amp\\Parallel\\Worker\\Internal\\TaskFailure))\n#5 /var/www/html/test/vendor/amphp/amp/lib/Internal/Placeholder.php(130): Amp\\Coroutine->Amp\\{closure}(NULL, Object(Amp\\Parallel\\Worker\\Internal\\TaskFailur in /var/www/html/test/vendor/amphp/parallel/lib/Worker/Internal/TaskFailure.php on line 45

У меня такое же требование, как и в Как работает amphp в отношении фонового процесса.

1 Ответ

0 голосов
/ 14 июня 2019

Как правило, Amp не работает магически в фоновом режиме.Если вы используете PHP через PHP-FPM или аналогично, Amp будет отключен после того, как ответ будет сделан, как и все остальное.

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

Тем не менее, если вы просто хотите одновременную загрузку, лучше подойдет amphp/artaxчем при использовании amphp/parallel, так как он имеет значительно меньшие издержки по сравнению с отдельным процессом PHP на HTTP-запрос.

...