Плохой UX в веб-приложениях, которые выполняют интенсивные задачи (и как этого избежать с помощью очередей)

Использование очереди сообщений

Как только файл получен веб-сервером, как мы обрабатываем его вне цикла запрос / ответ? Здесь мы хотим использовать очередь сообщений .

Очередь сообщений — это программное обеспечение, которое выполняется в отдельном процессе на вашем веб-сервере (или, возможно, даже на отдельной машине), и его задачей является управление асинхронными задачами. В типичном сценарии веб-сервер сообщит очереди сообщений, что у нас есть «задание», очередь сообщений выполнит задание (т.е. выполнит код), а затем сообщит о результатах, когда это будет сделано.

Очереди сообщений удобны не только потому, что они снимают нагрузку с нашего веб-сервера — они, как правило, имеют другие полезные функции, например помогают нам гарантировать, что мы не потеряем работу, позволяя нам повторять их в случае неудачи, расставляя приоритеты для важных работ и т. Д.

Примеры программного обеспечения очереди сообщений:

• Beanstalkd
• Amazon SQS (облачная очередь сообщений)
• Redis (по сути не очередь сообщений, но отлично работает как единое целое)

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

Laravel Queues

Laravel Queues упрощает взаимодействие веб-приложения Laravel с очередью сообщений.

Вот краткий обзор того, как они работают — позже я приведу конкретный пример.

1. Запустите очередь сообщений. Скажите Laravel, где находится и как получить к нему доступ через config/queues.phpфайл конфигурации.
2. Запустите рабочий процесс очереди . Это посредник между веб-приложением и очередью сообщений, которая будет прослушивать новые задания и отправлять их в очередь. Поскольку нам нужно обрабатывать задачи очереди асинхронно, это будет запускаться как отдельный процесс для вашего веб-приложения.
3. Отправьте «задание» и рабочий процесс очереди (т.е. некоторый код, который вы хотите выполнить — мы лучше определим задания ниже).
4. Прослушайте событие, которое содержит результат работы (необязательно).

Например, мы можем использовать Redis в качестве очереди сообщений. Laravel включает в себя драйверы для этого из коробки, так что просто нужно запустить Redis на сервере и сообщить Laravel порт / пароль config/queues.php.

Laravel предоставляет рабочий процесс очереди из коробки через консоль Artisan. Откройте вкладку терминала и запустите:

$ php artisan queue:work redis

Далее мы увидим, как передавать задания в очередь сообщений, которые могут обрабатываться асинхронно.

работа

Теперь мы можем создать задание — код, который вы хотите запустить в очереди сообщений. Это обычно будет интенсивной или трудоемкой задачей, такой как обработка CSV.

Laravel предоставляет Jobкласс, в который вы помещаете свой код. Используйте Artisan для его создания:

$ php artisan make:job ProcessCSV

Этот handleметод вызывается при запуске этого задания, поэтому мы помещаем логику задачи.

App / Работа / ProcessCSV.php

public function handle()
{
  // Logic for processing CSV
}

public function store(Request $request) 
{
  if ($request->hasFile('csv')) {
    ProcessCSV::dispatch($request->file("csv"));
    return response("File received for processing!", 202);
  } else {
    return response("No file provided.", 400);
  }
}

<form id="upload" enctype="multipart/form-data" @submit.prevent="submit">
  <p>Please select the file you'd like to upload. Provide an email address and we'll inform you of the result and spam you later.</p>
  <input type="file" name="csv" />
  <input type="email" name="email" />
  <input type="submit" value="Upload" />
</form>

public function store(Request $request) 
{
  if ($request->hasFile('csv')) {
    ProcessCSV::dispatch($request->file("csv"), $request->email);
    return response("File received for processing!", 202);
  } else {
    return response("No file provided.", 400);
  }
}

Queue::after(function (JobProcessed $event) {
  $result = ... // get the job result from the DB
  SendEmail::dispatch($event->data["email"], $result);
});