Laravel-werkwachtrijen beheren met Beanstalk en Supervisor op Ubuntu 16.04

• Beanstalk installeren
• Voorbeeldproject
• Verzenden en uitvoeren van taken
• Supervisor configureren
• Gevolgtrekking

Beanstalk is een snelle en eenvoudige werkwachtrij. Hiermee kunt u tijdrovende taken asynchroon uitvoeren, zoals het verzenden van e-mails, verbinding maken met externe API's of het verwerken van afbeeldingen. Door dit te doen, vermindert u de latentie van uw web-app. Laravel biedt out-of-the-box ondersteuning voor beanstalkd.

In deze tutorial zullen we beanstalkdeen demo-Laravel-applicatie installeren , opzetten en de wachtrijwerkers beheren via Supervisor . De demo-applicatie krijgt een lijst met beschikbare besturingssystemen van de Vultr API en kiest er willekeurig een.

Aangenomen wordt dat u Supervisor al op uw systeem hebt geïnstalleerd. Als je dat niet doet, lees dan de volgende tutorial over het instellen van Supervisor: Supervisor installeren en configureren op Ubuntu 16.04

Er wordt ook aangenomen dat je SSH-toegang hebt tot je Vultr-instantie.

Beanstalk installeren

De eerste stap die u moet nemen, is installeren beanstalkd.

sudo apt-get update
sudo apt-get install beanstalkd

Start de dienst.

sudo systemctl start beanstalkd

U kunt de service ook inschakelen om te starten bij systeeminitialisatie.

sudo systemctl enable beanstalkd

Controleer de servicestatus door de volgende opdracht te geven.

sudo systemctl status beanstalkd

Luistert standaard beanstalkdop de poort 11300. Beanstalk gebruikt een eenvoudig op tekst gebaseerd protocol dat wordt beschreven in de github-repository . U kunt het protocol testen door het uit te voeren telnet.

telnet localhost 11300

Schrijf het volgende en druk op ENTER.

list-tubes

U zou een lijst met beschikbare buizen op de server moeten zien:

OK 14
---
- default

Typ quiten druk op om de verbinding te verbreken ENTER.

Buizen in Beanstalk vertegenwoordigen werkwachtrijen. Beanstalk wordt voornamelijk samengesteld door producenten , consumenten , banen en buizen . Producenten stoppen banen in een buis om door een onbeperkt aantal consumenten te worden geconsumeerd (verwerkt). Merk op dat zowel producenten als consumenten gewoon klanten zijn van de Beanstalk-server en volledig onafhankelijk van elkaar zijn. Concreet betekent dit dat je door Beanstalk te gebruiken je jobs in je PHP-applicatie kunt produceren en laten verwerken in bijvoorbeeld een NodeJS-app. Gelukkig vat Laravel dit allemaal samen en biedt het ons een zeer eenvoudige API om taken te verzenden en af ​​te handelen, zoals we hierna zullen zien.

Voorbeeldproject

Om ons voorbeeldproject te bouwen, moeten we eerst de afhankelijkheden ervan installeren. We gaan PHP en Composer installeren.

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

Maak nu het project op basis van Laravel 5.5.

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

Volgende cdin de onlangs gemaakte map. We zullen vanaf nu in deze map werken. Naar deze map kan later worden verwezen als PROJECT_ROOT.

cd vultr/

Om Beanstalk in Laravel te gebruiken, moeten we nog een afhankelijkheid installeren, de PHP Beanstalk-client.

composer require pda/pheanstalk ~3.0

We moeten ook een functievertegenwoordiging creëren. In Laravel is dit een klasse in de app/Jobsmap. Laravel heeft een console-commando om ons te helpen een Job-klasse te creëren. Laten we onze voorbeeldjob maken.

php artisan make:job FindFavoriteOS

Werk het app/Jobs/FindFavoriteOS.phpbestand bij naar het volgende.

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

De handle-methode is wat effectief wordt uitgevoerd wanneer de taak wordt verbruikt. Hier halen we gegevens op van de Vultr API, kiezen willekeurig een besturingssysteem en schrijven het gekozen besturingssysteem naar het logbestand. Het logbestand bevindt zich op storage/logs/laravel.log.

We hebben Beanstalk al geïnstalleerd en de taak gedefinieerd die ermee moet worden uitgevoerd. Nu is het tijd om Laravel te vertellen dat hij Beanstalk als de standaardwerkwachtrij moet gebruiken. Kopieer het standaardbestand .envvan de Laravel-installatie.

cp .env.example .env

Open nu het .envbestand en werk de regel bij waar het wachtrijstuurprogramma is gespecificeerd.

QUEUE_DRIVER=beanstalkd

Genereer ten slotte een toepassingssleutel.

php artisan key:generate

We zijn nu klaar om taken naar de Beanstalk-werkwachtrij te sturen.

Verzenden en uitvoeren van taken

Een baan versturen in Laravel is vrij eenvoudig. Werk het routes/web.phpbestand bij.

<?php

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

    return '50 Jobs dispatched!';
});

Ondanks dat het niet wordt aanbevolen om de ingebouwde meegeleverde server in productie te laten, zullen we deze hier kortheidshalve gebruiken.

php artisan serve --host 0.0.0.0 --port 8000

Navigeer nu in een webbrowser naar http://[vultr-instance-ip]:8000. Je ziet het volgende bericht.

50 Jobs dispatched!

Open een nieuwe SSH-verbinding met uw server en voer in de projectroot het volgende uit.

php artisan queue:work --once

Dit is de verwachte output:

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

Bevestig dat het logboek is gegenereerd.

cat storage/logs/laravel.log

Supervisor configureren

Om te voorkomen dat de wachtrij handmatig moet worden verwerkt, gebruiken we supervisord. Maak de volgende programmaconfiguratie in /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

Merk op dat het juiste pad om het Supervisor-configuratiebestand te plaatsen, afhangt van uw configuratie. Vergeet ook niet om te vervangen [PROJECT_ROOT]door het volledige pad naar het PROJECT_ROOTop uw systeem.

Hier configureren we Supervisor om automatisch de wachtrij te verwerken en, in het geval dat het script wordt verbroken, om het opnieuw te starten. Merk ook op dat we geen enkele werknemer instantiëren, maar 8 processen. Het staat u vrij om zoveel processen te instantiëren, afhankelijk van uw toepassing.

Om supervisor toe te staan ​​onze werknemer te beheren, dwingt u hem de configuratie opnieuw te lezen.

sudo supervisorctl reread
sudo supervisorctl update

Als de Supervisor-service niet is gestart, moeten velen deze starten.

sudo systemctl start supervisord

Laten we nu kijken of de taken worden verwerkt.

tail -f storage/logs/laravel.log

Navigeer in een webbrowser naar http://[vultr-instance-ip]:8000. U zult zien dat de logs worden gegenereerd op uw console.

Gevolgtrekking

We hebben met succes een Laravel-applicatie geconfigureerd om Beanstalk als werkwachtrij te gebruiken. We hebben ook laten zien hoe u Supervisor kunt gebruiken om werknemers te beheren.