Nouvelles fonctionnalités et modifications dans le système de file d'attente Laravel 8

Ce qui suit est une introduction aux nouvelles fonctionnalités et modifications du système de file d'attente Laravel 8 de la colonne du didacticiel Laravel. J'espère que cela sera utile aux amis dans le besoin !

                                                                                                                                                                                                                                      

Laravel 8 est livré avec de nouvelles fonctionnalités intéressantes et quelques modifications du système de file d'attente. Dans cet article, nous examinerons ces fonctionnalités et modifications.

Changements

---

Backoff (rewind)

a modifié la méthode retryAfter() et retryAfter Propriétés des tâches en file d'attente, des e-mails, des notifications et des auditeurs renommés en backoff. L'option

de la commande

php artisan queue：work--delay a également été renommée --backoff.

Vous devez également savoir que vous pouvez désormais transmettre un tableau à l'attribut backoff pour demander au travailleur d'implémenter un backoff exponentiel :

public $backoff = [30, 60];

ou renvoyer un tableau à partir de la méthode backoff() :

public function backoff()
{
    return [30, 60]; 
}

En utilisant ici une interruption exponentielle, nous demandons au travailleur de retarder la nouvelle tentative de travail de 30 secondes après le premier échec, puis de 60 secondes après chaque échec.

Vous pouvez également utiliser le repli exponentiel sur la commande queue:work :

php artisan queue:Work --backoff=30,60

Expiration des tâches

pour les tâches en file d'attente, les notifications et les auditeurs. Le timeoutAt L'attribut a été renommé retryUntil.

Utilisez $retryUntil pour demander au travailleur de continuer à réessayer le travail jusqu'à un certain temps dans le futur.

Vous pouvez ajouter retryUntil comme propriété publique ou retryUntil méthode de la classe d'emploi :

public function retryUntil()
{
    return now()->addDay();
}

Nouvelles fonctionnalités

Fermetures de file d'attente

Vous pouvez désormais enchaîner les appels aux méthodes catch() lors de la répartition des fermetures de file d'attente :

dispatch(function () {
    // Job logic...
})->catch(function (Throwable $e) {
    // Handle Failure...
});

Si le travail échoue, la fermeture fournie à la méthode catch() sera appelée .

Fiabilité du pilote de base de données

Laravel effectuera désormais des opérations au sein d'une transaction lors de la libération d'un travail dans la file d'attente à l'aide du pilote de file d'attente de base de données. Cela signifie que les tâches ne seront pas supprimées de la file d'attente à moins qu'une nouvelle instance publiée ne soit ajoutée. Cela réduit considérablement les risques d’échec au travail.

Efficacité du pilote Redis

Lors de la distribution par lots d'un ensemble de tâches à l'aide du pilote de file d'attente Redis, Laravel effectuera l'opération en envoyant une seule commande à Redis. Auparavant, Laravel envoyait plusieurs commandes rpush à Redis, une pour chaque tâche.

Worker se termine gracieusement

À partir de Laravel 8, Workers quittera gracieusement et appellera tous les rappels de résiliation enregistrés par App：：Terminating().

Arrêt automatique des travailleurs

Pour éviter les fuites de mémoire, il est courant de tuer vos travailleurs de temps en temps, puis de laisser votre outil de surveillance des processus démarrer un nouveau travailleur. . Cela se fait généralement en ajoutant une tâche CRON qui exécute la commande queue:restart.

Dans Laravel 8, vous pouvez demander aux travailleurs de quitter après avoir traité un certain nombre de tâches ou exécuté pendant un nombre spécifique de secondes :

php artisan queue:work --max-jobs=1000 --max-time=3600

Travailleurs nommés

Vous ajoutez maintenant l'option --name à la commande queue:work :

php artisan queue:work --name=notifications

L'objectif principal de l'ajout de cette fonctionnalité est de permettre aux utilisateurs de personnaliser la façon dont les travailleurs choisissent la file d'attente dans laquelle traiter les tâches au moment de l'exécution :

Worker::popUsing('notifications', function ($pop) {
    $queues = time()->atNight() 
        ? ['mail', 'webhooks'] 
        : ['push-notifications', 'sms', 'mail', 'webhooks'];

    foreach ($queues as $queue) {
        if (! is_null($job = $pop($queue))) {
            return $job;
        }
    }
});

Regroupement de tâches

Le regroupement de tâches de Laravel vous permet de répartir de nombreuses tâches pour un traitement parallèle par vos travailleurs. Vous pouvez effectuer des actions après que toutes les tâches du lot ont été traitées ou qu'une tâche par lot a échoué :

Bus::batch([
    new ProcessFile(1),
    new ProcessFile(2),
    new ProcessFile(3),
])->dispatch();

Vous pouvez trouver plus d'informations sur le traitement par lots de travaux dans la Documentation officielle Plus d'informations.

Chaîne de tâches

Vous pouvez désormais planifier une série de tâches directement en utilisant Bus :

Bus::chain([
    new ExtractReports,
    new GenerateReport,
    new SendResults,
])->dispatch();

Vous pouvez également ajouter un rappel catch() , Sera appelé si un travail de la chaîne échoue :

Bus::chain([
    new ExtractReports,
    new GenerateReport,
    new SendResults,
])->catch(function(){
    // Handle the chain failure.
})
->dispatch();

Taux d'équilibre Horizon

Deux nouvelles options de configuration ont été ajoutées à Horizon : balanceMaxShift et balanceCooldown.

 'environments' => [
    'environment' => [
        'supervisor-1' => [
            'balanceMaxShift' => 5,
        ],
    ],
],

balanceMaxShift Définit le nombre maximum de processus de travail à ajouter ou à supprimer chaque fois qu'Horizon étend le pool de travailleurs. Dans les versions précédentes d'Horizon, un seul processus de travail était ajouté ou supprimé. Vous pouvez désormais contrôler ce nombre.

Quant à balanceCooldown , il fixe le nombre de secondes à attendre entre chaque opération de zoom. Dans les versions antérieures d’Horizon, cette durée était codée en dur à 3 secondes.

 'environments' => [
    'environment' => [
        'supervisor-1' => [
            'balanceCooldown' => 1,
        ],
    ],
],

原文地址：https://dev.to/themsaid/features-and-changes-coming-to-laravel-8-s-queue-system-5amg

译文地址：https://learnku.com/laravel/t/50086

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!