Вы можете реализовывать задачу через сервис сообщений, например, RabbitMQ.
Для этого нужно установить сам RabbitMQ, пакетphp7.0-bcmath
для библиотеки php-amqplib (sudo apt-get install php7.0-bcmath
). Для Symfony есть пакет RabbitMqBundle (composer require php-amqplib/rabbitmq-bundle
), который под копотом использует php-amqplib
.
Затем нужно зарегистрировать бандл в AppKernal и добавить конфиги:
// app/AppKernel.php
public function registerBundles()
{
$bundles = array(
new OldSound\RabbitMqBundle\OldSoundRabbitMqBundle(),
);
}
Добавляем конфиги в config.yml ( Полный пример конфигурации можно посмотреть тут). Добавим подключение + настройки реббита:
old_sound_rabbit_mq:
connections:
default:
host: 'localhost'
port: 5672
user: 'guest'
password: 'guest'
vhost: '/'
lazy: false
connection_timeout: 3
read_write_timeout: 3
keepalive: false
heartbeat: 0
use_socket: true
По умолчанию RabbitMQ работает на порту 5672. Так же задаем хост, логин и пароль. По остальным настройкам можно прочитать по ссылке выше.
Producer и Consumer.
Если коротко, то Producer - это процесс отправки в очередь сообщения, Consumer - процесс получающий и обрабатывающий эти сообщения.
Добавляем produces и consumers в конфиг для обрабортки запроса, назовем его processing_request
(как это органично смотрится смотрите полный конфиг по сылке выше).
producers:
processing_request:
connection: default
exchange_options: {name: 'processing_request', type: direct}
consumers:
processing_request:
connection: default
exchange_options: {name: 'processing_request', type: direct}
queue_options: {name: 'processing_request'}
callback: processing_request_service
Добавляем consumer-сервис для обработки сообщений:
use OldSound\RabbitMqBundle\RabbitMq\ConsumerInterface;
use PhpAmqpLib\Message\AMQPMessage;
class ProcessingRequestConsumer implements ConsumerInterface
{
public function execute(AMQPMessage $msg)
{
//фоновый скрипт
...
}
}
Привязываем очередь к Consumer и говорим, что бы он ждал сообщение, делаем это через терминал (если добавить &
к скирпту, то можно запустить в фоне).
./app/console rabbitmq:consumer processing_request -vvv &
Теперь поставим в очередь обрабоку запроса.
Допустим, у вас есть некий контроллер, в котором нужно запустить обработку.
public function indexAction()
{
$this->get('old_sound_rabbit_mq.processing_request_producer')->publish('Processing Request...');
...
return $this->json(array('result' => 'success'));
}
Готово, вызывая экшн контроллера, добавляется в очередь обработчик запросов.
curl_multi_init
и N-дцать скриптов воркеров, каждый из которых обрабатывает часть данных. Но! Мне очень сложно придумать такую задачу, которая работает с "некоторыми" данными и выполняется за 20 часов. Хостинг правильно вам говорит - оптимизируйте скрипт. Заодно, может быть, стоит индексов в БД посоздавать