Upravljanje delovnih čakalnih vrst Laravel z Beanstalk in nadzornikom v Ubuntu 16.04

Beanstalk je hitra in preprosta delovna čakalna vrsta. Omogoča vam asinhrono izvajanje zamudnih nalog, kot so pošiljanje e-pošte, povezovanje z zunanjimi API-ji ali obdelava slik. S tem boste zmanjšali zakasnitev spletne aplikacije. Laravel nudi že pripravljeno podporo za beanstalkd.

V tej vadnici bomo namestili beanstalkd, nastavili demo aplikacijo Laravel in upravljali delavce v čakalni vrsti prek Supervisorja . Demo aplikacija bo prejela seznam razpoložljivih operacijskih sistemov iz Vultr API-ja in naključno izbrala enega.

Predpostavlja se, da imate v sistemu že nameščen nadzornik. Če tega ne storite, preberite naslednjo vadnico o nastavitvi Supervisorja: Namestitev in konfiguracija Supervisorja v Ubuntu 16.04

Predpostavlja se tudi, da imate dostop SSH do svojega primerka Vultr.

Namestitev Beanstalk

Prvi korak je namestitev beanstalkd.

sudo apt-get update
sudo apt-get install beanstalkd

Zaženite storitev.

sudo systemctl start beanstalkd

Prav tako lahko omogočite, da se storitev zažene ob inicializaciji sistema.

sudo systemctl enable beanstalkd

Preverite stanje storitve z naslednjim ukazom.

sudo systemctl status beanstalkd

Privzeto beanstalkdposluša na vratih 11300. Beanstalk uporablja preprost besedilni protokol, ki je opisan v njegovem repozitoriju github . Njegov protokol lahko preizkusite tako, da zaženete telnet.

telnet localhost 11300

Napišite naslednje in pritisnite ENTER.

list-tubes

Videti bi morali seznam cevi, ki so na voljo na strežniku:

OK 14
---
- default

Če želite zapreti povezavo, preprosto vnesite quitin pritisnite ENTER.

Cevi v Beanstalk predstavljajo delovne čakalne vrste. Fižolovo steblo sestavljajo predvsem proizvajalci , potrošniki , delovna mesta in cevi . Proizvajalci dajo delovna mesta v cev, ki jo porabi (obdela) poljubno število potrošnikov. Upoštevajte, da so tako proizvajalci kot potrošniki preprosto odjemalci strežnika Beanstalk in so popolnoma neodvisni drug od drugega. V praksi to pomeni, da lahko z uporabo Beanstalk izdelate svoja opravila v aplikaciji PHP in jih na primer obdelate v aplikaciji NodeJS. Na srečo Laravel vse to abstrahira in nam nudi zelo preprost API za pošiljanje in obdelavo opravil, kot bomo videli v nadaljevanju.

Vzorčni projekt

Za izdelavo našega vzorčnega projekta moramo najprej namestiti njegove odvisnosti. Namestili bomo PHP in Composer.

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

Zdaj ustvarite projekt, ki temelji na Laravel 5.5.

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

Nato cdv nedavno ustvarjeno mapo. Od zdaj naprej bomo delali v tem imeniku. Ta mapa se lahko kasneje omenja kot PROJECT_ROOT.

cd vultr/

Za uporabo Beanstalk v Laravel moramo namestiti še eno odvisnost, odjemalca PHP Beanstalk.

composer require pda/pheanstalk ~3.0

Ustvariti moramo tudi zastopstvo delovnega mesta. V Laravelu je to razred znotraj app/Jobsmape. Laravel ima ukaz na konzoli, ki nam pomaga ustvariti razred Job. Ustvarimo naš vzorčni Job.

php artisan make:job FindFavoriteOS

Posodobite app/Jobs/FindFavoriteOS.phpdatoteko na naslednje.

<?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 ročaja je tisto, kar se bo učinkovito izvajalo, ko bo opravilo zaužito. Tukaj pridobimo podatke iz API-ja Vultr, naključno izberemo OS in zapišemo izbrani OS v datoteko dnevnika. Dnevniška datoteka se nahaja na storage/logs/laravel.log.

Beanstalk smo že namestili in definirali opravilo, ki ga bo izvedel. Zdaj je čas, da povemo Laravelu, naj uporabi Beanstalk kot privzeto delovno čakalno vrsto. Kopirajte privzeto .envdatoteko, ki jo zagotavlja namestitev Laravel.

cp .env.example .env

Zdaj odprite .envdatoteko in posodobite vrstico, kjer je naveden gonilnik čakalne vrste.

QUEUE_DRIVER=beanstalkd

Na koncu ustvarite aplikacijski ključ.

php artisan key:generate

Zdaj smo pripravljeni za pošiljanje opravil v delovno čakalno vrsto Beanstalk.

Razpošiljanje in vodenje opravil

Pošiljanje službe v Laravel je precej preprosto. Posodobite routes/web.phpdatoteko.

<?php

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

    return '50 Jobs dispatched!';
});

Kljub temu, da nam ni priporočljivo izvajati vgrajenega strežnika v produkciji, ga bomo zaradi kratkosti tukaj uporabljali.

php artisan serve --host 0.0.0.0 --port 8000

Zdaj v spletnem brskalniku se pomaknite do http://[vultr-instance-ip]:8000. Videli boste naslednje sporočilo.

50 Jobs dispatched!

Odprite novo povezavo SSH s svojim strežnikom in v korenu našega projekta izvedite naslednje.

php artisan queue:work --once

To je pričakovani rezultat:

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

Potrdite, da je bil dnevnik ustvarjen.

cat storage/logs/laravel.log

Konfiguriranje nadzornika

Da se izognemo potrebi po ročni obdelavi čakalne vrste, bomo uporabili supervisord. Ustvarite naslednjo konfiguracijo programa v /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

Upoštevajte, da bo prava pot za namestitev konfiguracijske datoteke Supervisor odvisna od vaše nastavitve. Prav tako ne pozabite zamenjati [PROJECT_ROOT]s celotno potjo do v PROJECT_ROOTvašem sistemu.

Tukaj konfiguriramo Supervisor, da samodejno začne z obdelavo čakalne vrste in jo v primeru zloma skripta znova zažene. Upoštevajte tudi, da ne instanciramo enega delavca, ampak 8 procesov. Glede na vašo aplikacijo lahko ustvarite kolikor koli potrebnih procesov.

Če želite nadzorniku omogočiti upravljanje našega delavca, ga prisilite, da ponovno prebere svojo konfiguracijo.

sudo supervisorctl reread
sudo supervisorctl update

Če storitev Supervisor še ni bila zagnana, jo morate veliko zagnati.

sudo systemctl start supervisord

Zdaj pa poglejmo, ali so opravila v obdelavi.

tail -f storage/logs/laravel.log

V spletnem brskalniku se pomaknite do http://[vultr-instance-ip]:8000. Videli boste, da se dnevniki generirajo na vaši konzoli.

Zaključek

Aplikacijo Laravel smo uspešno konfigurirali za uporabo Beanstalk kot delovne čakalne vrste. Prav tako smo pokazali, kako uporabljati Supervisor za upravljanje delavcev.