Bereiten Sie unser Produkt mit Laravel-Warteschlangen skalierbar vor

Einführung

Was ist eine Aufgabe?

<?php

use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Bus\Queueable;


class CallExternalAPI implements ShouldQueue
{
    use Dispatchable,
        InteractsWithQueue,
        Queueable;
        
    /**
     * @var string
     */
    protected $url;

    /**
     *    .
     *
     * @param array $Data
     */
    public function __construct($url)
    {
        $this->url = $url;
    }
    

    /**
     *  ,   .
     *
     * @return void
     * @throws \Throwable
     */
    public function handle()
    {
        file_get_contents($this->url);
    }
}

Was verstehen wir unter „mühsamen Aufgaben“?

<?php

class ProjectController 
{
    public function store(Request $request)
    {
        $project = Project::create($request->all());
        
        //  NotifyMembers, TagUserActive, NotifyToProveSource 
        //   ,     
        Notification::queue(new NotifyMembers($project->owners));
        $this->dispatch(new TagUserAsActive($project->owners));
        $this->dispatch(new NotifyToProveSource($project->owners));
        
        return $project;
    }
}

Wer führt diese Aufgaben aus, nachdem er sie an die Warteschlange gesendet hat?

php artisan queue:work

In der Dokumentation heißt es:
Laravel enthält einen Warteschlangenarbeiter, der neue Aufgaben verarbeitet, wenn sie in die Warteschlange gestellt werden.

Supervisor-Rolle

Wie kann ich feststellen, dass der Aufgabencode nicht funktioniert?

Sie haben keine http-Anfrage

<?php

//   

class TagUserJob implements ShouldQueue
{
    public $data;
    
    public function __construct(array $data)
    {
        $this->data = $data;
    }
}

//       

$this->dispatch(new TagUserJob($request->all()));

Sie wissen nicht, wer sich angemeldet hat

<?php

//   
class TagUserJob implements ShouldQueue
{
    public $user;
    
    public function __construct(User $user)
    {
        $this->user= $user;
    }
}

//       
$this->dispatch(new TagUserJob($request->user()));

Verstehen, wie man skaliert

Horizont

<?php

'production' => [
    'supervisor-1' => [
        'connection' => "redis",
        'queue' => ['adveritisement', 'logs', 'phones'],
        'processes' => 9,
        'tries' => 3,
        'balance' => 'simple', //   simple, auto  null

    ]
]

Meine eigene Konfiguration

<?php

'production' => [
    'supervisor-1' => [
        'connection' => 'redis',
        'queue' => ['default', 'ingest', 'notifications'],
        'balance' => 'auto',
        'processes' => 15,
        'tries' => 3,
    ],
]

• Aufnahme für Prozesse zur Analyse von Daten aus externen Anwendungen;
• Benachrichtigungen werden verwendet, um Benachrichtigungen sofort zu planen, wenn beim Empfang von Daten ein Fehler festgestellt wird.
• Die Standardeinstellung wird für andere Aufgaben verwendet, die ich nicht mit Aufnahme- und Benachrichtigungsprozessen mischen möchte .

Schlussbemerkungen