Laravel-työjonojen hallinta Beanstalkin ja Supervisorin avulla Ubuntussa 16.04

Beanstalk on nopea ja yksinkertainen työjono. Sen avulla voit suorittaa aikaa vieviä tehtäviä asynkronisesti, kuten sähköpostien lähettämisen, yhteyden muodostamisen ulkoisiin sovellusliittymiin tai kuvien käsittelyyn. Näin lyhennät verkkosovelluksesi viivettä. Laravel tarjoaa valmiin tuen beanstalkd.

Tässä opetusohjelmassa asennamme beanstalkd, asennamme Laravel-demosovelluksen ja hallitsemme jonotyöntekijöitä Supervisorin kautta . Demosovellus saa luettelon käytettävissä olevista käyttöjärjestelmistä Vultr API:sta ja valitsee niistä satunnaisesti.

Oletuksena on, että järjestelmässäsi on jo asennettu Supervisor. Jos et, sinun tulee lukea seuraava opetusohjelma Supervisorin asentamisesta : Supervisorin asentaminen ja määrittäminen Ubuntu 16.04:ssä

Oletetaan myös, että sinulla on SSH-käyttöoikeus Vultr-instanssiisi.

Beanstalkin asennus

Ensimmäinen askel on asentaa beanstalkd.

sudo apt-get update
sudo apt-get install beanstalkd

Käynnistä palvelu.

sudo systemctl start beanstalkd

Voit myös ottaa palvelun käyttöön järjestelmän alustuksen yhteydessä.

sudo systemctl enable beanstalkd

Tarkista palvelun tila antamalla seuraava komento.

sudo systemctl status beanstalkd

Kuuntelee oletusarvoisesti beanstalkdporttia 11300. Beanstalk käyttää yksinkertaista tekstipohjaista protokollaa, joka on kuvattu sen github-arkistossa . Voit testata sen protokollaa suorittamalla telnet.

telnet localhost 11300

Kirjoita seuraava ja paina ENTER.

list-tubes

Sinun pitäisi nähdä luettelo palvelimella olevista putkista:

OK 14
---
- default

Sulje yhteys kirjoittamalla quitja painamalla sitten ENTER.

Beanstalkissa olevat putket edustavat työjonoja. Pavunvarsi koostuu pohjimmiltaan tuottajista , kuluttajista , työpaikoista ja putkista . Tuottajat laittavat työpaikat putkeen, jonka kaikki kuluttajat voivat kuluttaa (prosessoida). Huomaa, että sekä tuottajat että kuluttajat ovat yksinkertaisesti Beanstalk-palvelimen asiakkaita ja ovat täysin riippumattomia toisistaan. Käytännössä tämä tarkoittaa, että Beanstalkin avulla voit tuottaa työsi PHP-sovelluksessasi ja käsitellä ne esimerkiksi NodeJS-sovelluksessa. Onneksi Laravel tiivistää kaiken tämän ja tarjoaa meille erittäin yksinkertaisen sovellusliittymän töiden lähettämiseen ja käsittelemiseen, kuten näemme seuraavaksi.

Esimerkkiprojekti

Esimerkkiprojektimme rakentamiseksi meidän on ensin asennettava sen riippuvuudet. Asennamme PHP:n ja Composerin.

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

Luo nyt projekti Laravel 5.5:n perusteella.

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

Seuraavaksi cdäskettäin luotuun kansioon. Työskentelemme tästä lähtien tässä hakemistossa. Tähän kansioon voidaan viitata myöhemmin nimellä PROJECT_ROOT.

cd vultr/

Käyttääksemme Beanstalkia Laravelissa meidän on asennettava vielä yksi riippuvuus, PHP Beanstalk -asiakas.

composer require pda/pheanstalk ~3.0

Meidän on myös luotava Job-edustus. Laravelissa tämä on app/Jobskansion sisällä oleva luokka . Laravelilla on konsolikomento, joka auttaa meitä luomaan Job-luokan. Luodaan mallityömme.

php artisan make:job FindFavoriteOS

Päivitä app/Jobs/FindFavoriteOS.phptiedosto seuraavaan.

<?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']);
    }
}

Käsittelymenetelmä on se, mikä suoritetaan tehokkaasti, kun työ kuluu. Täällä noudetaan tiedot Vultr API:sta, valitaan satunnaisesti käyttöjärjestelmä ja kirjoitetaan valittu käyttöjärjestelmä lokitiedostoon. Lokitiedosto sijaitsee osoitteessa storage/logs/laravel.log.

Olemme jo asentaneet Beanstalkin ja määrittäneet sen suorittaman työn. Nyt on aika käskeä Laravelia käyttämään Beanstalkia oletustyöjonona. Kopioi .envLaravel-asennuksen tarjoama oletustiedosto.

cp .env.example .env

Avaa nyt .envtiedosto ja päivitä rivi, jossa jonoohjain on määritetty.

QUEUE_DRIVER=beanstalkd

Luo lopuksi sovellusavain.

php artisan key:generate

Olemme nyt valmiita lähettämään töitä Beanstalk-työjonoon.

Lähetys ja ajotyöt

Työn lähettäminen Laravelissa on melko yksinkertaista. Päivitä routes/web.phptiedosto.

<?php

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

    return '50 Jobs dispatched!';
});

Vaikka sisäänrakennettua palvelinta ei suositella käytettäväksi tuotannossa, käytämme sitä tässä lyhyyden vuoksi.

php artisan serve --host 0.0.0.0 --port 8000

Siirry nyt verkkoselaimessa kohtaan http://[vultr-instance-ip]:8000. Näet seuraavan viestin.

50 Jobs dispatched!

Avaa uusi SSH-yhteys palvelimellesi ja suorita projektimme juuren sisällä seuraava.

php artisan queue:work --once

Tämä on odotettu tulos:

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

Vahvista, että loki on luotu.

cat storage/logs/laravel.log

Valvojan määrittäminen

Jotta jonoa ei tarvitse käsitellä manuaalisesti, käytämme supervisord. Luo seuraavat ohjelmakokoonpanot sovelluksessa /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

Huomaa, että oikea polku Supervisor-määritystiedoston sijoittamiseen riippuu asetuksistasi. Muista myös korvata [PROJECT_ROOT]koko polku PROJECT_ROOTjärjestelmässäsi olevaan polkuun .

Tässä konfiguroimme Supervisorin aloittamaan automaattisesti jonon käsittelyn ja käynnistämään sen uudelleen, mikäli komentosarja katkeaa. Huomaa myös, että emme instantoi yhtä työntekijää, vaan 8 prosessia. Voit vapaasti instantoida monia prosesseja, jotka katsot tarpeellisiksi sovelluksestasi riippuen.

Jotta valvoja voi hallita työntekijäämme, pakota se lukemaan kokoonpanonsa uudelleen.

sudo supervisorctl reread
sudo supervisorctl update

Jos Supervisor-palvelua ei ole käynnistetty, monien on käynnistettävä se.

sudo systemctl start supervisord

Katsotaan nyt, ovatko työt käsittelyssä.

tail -f storage/logs/laravel.log

Siirry verkkoselaimella kohtaan http://[vultr-instance-ip]:8000. Näet lokit, joita luodaan konsolissasi.

Johtopäätös

Olemme onnistuneesti konfiguroineet Laravel-sovelluksen käyttämään Beanstalkia työjonona. Esitimme myös, kuinka Supervisoria käytetään työntekijöiden johtamiseen.