Gestionarea cozilor de lucru Laravel cu Beanstalk și Supervisor pe Ubuntu 16.04

• Instalarea Beanstalk
• Proiect de probă
• Distribuirea și rularea locurilor de muncă
• Configurarea supraveghetorului
• Concluzie

Beanstalk este o coadă rapidă și simplă de lucru. Vă permite să rulați sarcini care consumă timp în mod asincron, cum ar fi trimiterea de e-mailuri, conectarea la API-uri externe sau procesarea imaginilor. Procedând astfel, veți reduce latența aplicației dvs. web. Laravel oferă asistență extraordinara pentru beanstalkd.

În acest tutorial vom instala beanstalkd, configura o aplicație demo Laravel și vom gestiona lucrătorii la coadă prin Supervisor . Aplicația demo va primi o listă de sisteme de operare disponibile din API-ul Vultr și va alege la întâmplare unul.

Se presupune că aveți deja Supervizor instalat în sistemul dvs. Dacă nu, ar trebui să citiți următorul tutorial despre cum să configurați Supervisor: Instalarea și configurarea Supervisorului pe Ubuntu 16.04

De asemenea, se presupune că aveți acces SSH la instanța dvs. Vultr.

Instalarea Beanstalk

Primul pas de făcut este să instalați beanstalkd.

sudo apt-get update
sudo apt-get install beanstalkd

Porniți serviciul.

sudo systemctl start beanstalkd

De asemenea, puteți activa serviciul să înceapă la inițializarea sistemului.

sudo systemctl enable beanstalkd

Verificați starea serviciului emitând următoarea comandă.

sudo systemctl status beanstalkd

În mod implicit, beanstalkdascultă portul 11300. Beanstalk folosește un protocol pe bază de text simplu descris în depozitul github . Puteți testa protocolul acestuia rulând telnet.

telnet localhost 11300

Scrieți următorul și apăsați ENTER.

list-tubes

Ar trebui să vedeți o listă de tuburi disponibile pe server:

OK 14
---
- default

Pentru a închide conexiunea, pur quitși simplu tastați și apoi apăsați ENTER.

Tuburile din Beanstalk reprezintă cozi de lucru. Beanstalk este compus practic din producători , consumatori , locuri de muncă și tuburi . Producătorii introduc locuri de muncă într-un tub pentru a fi consumate (procesate) de către orice număr de consumatori. Rețineți că atât producătorii, cât și consumatorii sunt pur și simplu clienți ai serverului Beanstalk și sunt total independenți unul de celălalt. În termeni practici, aceasta înseamnă că, folosind Beanstalk, puteți să vă produceți joburile în aplicația dvs. PHP și să le prelucrați într-o aplicație NodeJS, de exemplu. Din fericire, Laravel rezumă toate acestea și ne oferă o API foarte simplă pentru expediere și gestionare a lucrărilor, așa cum vom vedea în continuare.

Proiect de probă

Pentru a construi proiectul nostru de eșantion, trebuie să instalăm mai întâi dependențele sale. Vom instala PHP și Composer.

sudo apt-get install php php-mbstring php-xml php-common php-zip composer

Acum, creați proiectul bazat pe Laravel 5.5.

composer create-project --prefer-dist laravel/laravel vultr "5.5.*"

În continuare cdîn folderul creat recent. De acum înainte vom lucra în acest director. Acest folder poate fi referit ulterior PROJECT_ROOT.

cd vultr/

Pentru a utiliza Beanstalk în Laravel, trebuie să instalăm încă o dependență, clientul PHP Beanstalk.

composer require pda/pheanstalk ~3.0

De asemenea, trebuie să creăm o reprezentare a locurilor de muncă. În Laravel, aceasta este o clasă din app/Jobsfolder. Laravel are o comandă de consolă pentru a ne ajuta să creăm o clasă Job. Haideți să ne creăm exemplul Job.

php artisan make:job FindFavoriteOS

Actualizați app/Jobs/FindFavoriteOS.phpfișierul la următoarele.

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Support\Facades\Log;

class FindFavoriteOS implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct()
    {
        //
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $rawData = file_get_contents('https://api.vultr.com/v1/os/list');
        $list = json_decode($rawData, true);
        shuffle($list);
        $key = array_rand($list);
        $favorite = $list[$key];
        Log::info('My Favorite OS is: ' . $favorite['name']);
    }
}

Metoda de mâner este ceea ce va fi executat în mod eficient atunci când lucrarea este consumată. Aici, preluăm date din API-ul Vultr, alegem la întâmplare un sistem de operare și scriem sistemul de operare ales în fișierul jurnal. Fișierul jurnal este situat la storage/logs/laravel.log.

Am instalat deja Beanstalk și am definit ca jobul să fie executat de acesta. Acum este timpul să-i spunem lui Laravel să folosească Beanstalk ca coadă de lucru implicită. Copiați .envfișierul implicit furnizat de instalarea Laravel.

cp .env.example .env

Acum deschideți .envfișierul și actualizați linia în care este specificat driverul de coadă.

QUEUE_DRIVER=beanstalkd

În cele din urmă, generați o cheie de aplicație.

php artisan key:generate

Acum suntem pregătiți să trimitem lucrări la coada de lucru Beanstalk.

Distribuirea și rularea locurilor de muncă

Trimiterea unei slujbe în Laravel este destul de simplă. Actualizați routes/web.phpfișierul.

<?php

Route::get('/', function () {
    for ($i = 0; $i < 50; $i++) {
        \App\Jobs\FindFavoriteOS::dispatch();
    }

    return '50 Jobs dispatched!';
});

În ciuda faptului că nu este recomandat să rulați serverul furnizat încorporat în producție, îl vom folosi aici, din motive de scurtă durată.

php artisan serve --host 0.0.0.0 --port 8000

Acum, într-un browser web, navigați la http://[vultr-instance-ip]:8000. Veți vedea următorul mesaj.

50 Jobs dispatched!

Deschideți o nouă conexiune SSH pe serverul dvs. și în interiorul rădăcinii proiectului nostru, executați următoarele.

php artisan queue:work --once

Aceasta este producția preconizată:

[2018-02-14 00:03:52] Processing: App\Jobs\FindFavoriteOS
[2018-02-14 00:03:53] Processed:  App\Jobs\FindFavoriteOS

Confirmați că jurnalul a fost generat.

cat storage/logs/laravel.log

Configurarea supraveghetorului

Pentru a evita nevoia de a prelucra manual coada, vom folosi supervisord. Creați următoarea configurație a programului în /etc/supervisor/conf.d/vultr.conf.

[program:vultr]
process_name=%(program_name)s_%(process_num)02d
command=php [PROJECT_ROOT]/artisan queue:work
autostart=true
autorestart=true
numprocs=8
redirect_stderr=true
stdout_logfile=/var/log/worker.log

Observați că calea potrivită pentru a pune fișierul de configurare Supervisor va depinde de configurarea dvs. De asemenea, nu uitați să înlocuiți [PROJECT_ROOT]calea completă către sistemul de PROJECT_ROOTpe sistemul dvs.

Aici configurăm Supervisorul pentru a începe automat procesarea cozii și, în cazul ruperii scriptului, pentru a-l reporni. De asemenea, rețineți că nu inițiem un singur lucrător, ci 8 procese. Ești liber să instaurezi totuși multe procese pe care le consideri necesare în funcție de aplicația ta.

Pentru a permite Supervizorului să gestioneze lucrătorul nostru, forțați-l să recitească configurația sa.

sudo supervisorctl reread
sudo supervisorctl update

Dacă serviciul de supraveghetor nu a fost pornit, mulți trebuie să îl porniți.

sudo systemctl start supervisord

Acum să vedem dacă procesele sunt procesate.

tail -f storage/logs/laravel.log

Pe un browser web, navigați la http://[vultr-instance-ip]:8000. Veți vedea că jurnalele sunt generate pe consola dvs.

Concluzie

Am configurat cu succes o aplicație Laravel pentru a utiliza Beanstalk ca coadă de lucru. De asemenea, am demonstrat cum să folosim Supervizorul pentru a gestiona lucrătorii.