Utiliser Laravel pour le traitement des files d'attente et la planification des tâches : améliorer les performances des applications-Laravel-php.cn

Utiliser Laravel pour le traitement des files d'attente et la planification des tâches : améliorer les performances des applications

WBOY

Libérer： 2023-08-12 20:18:25

original

1608 Les gens l'ont consulté

Utiliser Laravel pour le traitement des files dattente et la planification des tâches : améliorer les performances des applications

Utiliser Laravel pour le traitement des files d'attente et la planification des tâches : améliorer les performances des applications

Introduction :
Avec le développement d'applications, nous sommes souvent confrontés au défi de gérer un grand nombre de tâches et de requêtes. Afin d'améliorer les performances et la réactivité des applications, le framework Laravel fournit un puissant système de traitement de file d'attente et de planification des tâches. Cet article explique comment utiliser la fonction de file d'attente de Laravel pour gérer les tâches asynchrones et planifier des tâches récurrentes afin d'améliorer les performances et la stabilité des applications.

1. Introduction à la fonction de file d'attente de Laravel
Laravel fournit un service de file d'attente avec une bonne abstraction, qui peut ajouter des tâches qui doivent être exécutées de manière asynchrone à la file d'attente, puis les traiter par des processus en arrière-plan ou des travailleurs de file d'attente. Ce mode d'exécution de tâches asynchrone est appelé « file d'attente », qui peut efficacement séparer certaines tâches non en temps réel ou chronophages du processus de requête principal, permettant à l'application de répondre plus rapidement aux requêtes.

Avantages de la file d'attente Laravel :

Exécution asynchrone : après avoir ajouté une tâche à la file d'attente, une réponse peut être renvoyée immédiatement à l'utilisateur, tandis que la tâche sera exécutée de manière asynchrone en arrière-plan.
Amélioration de la simultanéité : étant donné que les tâches sont mises dans la file d'attente, plusieurs tâches peuvent être traitées en même temps, améliorant ainsi les capacités de traitement simultané de l'application.
Traitement tolérant aux pannes : lorsque l'exécution d'une tâche échoue, Laravel remet la tâche dans la file d'attente pour garantir qu'elle peut être exécutée avec succès.
Sûr et stable : en plaçant les tâches dans la file d'attente, certaines opérations sensibles ou chronophages peuvent être évitées et ne bloquent pas le processus de demande normal.
Prise en charge des microservices : les services de file d'attente peuvent être découplés des autres microservices pour améliorer l'évolutivité des applications.

2. Configurez la file d'attente Laravel

Configurez le pilote
Dans le fichier de configuration de Laravel config/queue.php, vous pouvez configurer le pilote de file d'attente. Laravel prend en charge plusieurs types de pilotes de file d'attente, tels que base de données, redis, beanstalkd, etc. config/queue.php中，可以配置队列的驱动程序。Laravel支持多种类型的队列驱动程序，如database、redis、beanstalkd等。

示例配置：

'default' => env('QUEUE_CONNECTION', 'redis'),
'connections' => [
    // Redis 驱动配置
    'redis' => [
        'driver' => 'redis',
        'connection' => 'default',
        'queue' => env('Redis_QUEUE', 'default'),
        'retry_after' => 90,
        'block_for' => null,
    ],
],

Copier après la connexion

启动队列工作人员
在Laravel中，队列任务需要由队列工作人员（Queue Worker）来执行。可以使用Laravel自带的Artisan命令php artisan queue:work来启动队列工作人员，并根据需要进行配置。

示例命令：

php artisan queue:work --queue=queue-name --tries=3

Copier après la connexion

该命令将启动一个队列工作人员，监听指定的队列（queue-name），并在任务执行失败时最多尝试3次。

三、使用Laravel队列处理任务

创建并分发任务
首先，我们需要创建一个任务类。可以使用Laravel自带的Artisan命令php artisan make:job来创建一个新的队列任务类。

示例任务类：

<?php

namespace AppJobs;

use IlluminateBusQueueable;
use IlluminateContractsQueueShouldQueue;
use IlluminateFoundationBusDispatchable;
use IlluminateQueueInteractsWithQueue;
use IlluminateQueueSerializesModels;

class ProcessPodcast implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $podcast;

    /**
     * Create a new job instance.
     *
     * @param  Podcast  $podcast
     * @return void
     */
    public function __construct(Podcast $podcast)
    {
        $this->podcast = $podcast;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        // 处理任务逻辑
    }
}

Copier après la connexion

通过实现ShouldQueue接口，该任务类将成为一个可以被队列处理的任务类。

然后，我们可以使用队列的dispatch方法来将任务分发到队列中，等待异步处理。

示例分发任务：

use AppJobsProcessPodcast;

ProcessPodcast::dispatch($podcast);

Copier après la connexion

监听队列并执行任务
当队列工作人员启动后，它会监听指定的队列，一旦有新的任务进入队列，就会执行任务的handle方法。

在任务的handle方法中，编写需要异步执行的逻辑代码。

示例任务处理逻辑：

public function handle()
{
    // 执行异步任务
    // ...
    // 执行完成后，任务将从队列中移除
}

Copier après la connexion

通过以上步骤，我们就可以实现将需要异步执行的任务添加到队列中，并由队列工作人员来处理执行。

四、使用Laravel任务调度功能
除了队列处理功能以外，Laravel还提供了任务调度功能，能够定期执行某个任务或者重复执行指定次数的任务。

创建任务调度
使用Laravel自带的Artisan命令php artisan make:command来创建一个任务调度类。

示例任务调度类：

<?php

namespace AppConsoleCommands;

use IlluminateConsoleCommand;

class SendEmails extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'emails:send';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Send reminder emails to all users';

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        // 任务调度逻辑
    }
}

Copier après la connexion

配置任务调度
在Laravel的配置文件app/Console/Kernel.php中，可以配置要定期执行的任务调度和调度频率。

示例配置：

protected $commands = [
    CommandsSendEmails::class,
];

protected function schedule(Schedule $schedule)
{
    $schedule->command('emails:send')
             ->dailyAt('01:00');
}

Copier après la connexion

上述配置表示每天在凌晨1点执行emails:send

```
* * * * * cd /path-to-your-project && php artisan schedule:run >> /dev/null 2>&1
```
Copier après la connexion
Exemple de commande :
rrreee
Cette commande démarrera un travailleur de file d'attente, écoutera la file d'attente spécifiée (queue-name) et essaiera jusqu'à 3 fois si l'exécution de la tâche échoue.

3. Utilisez la file d'attente Laravel pour traiter les tâches
🎜🎜Créer et distribuer des tâches🎜Tout d'abord, nous devons créer une classe de tâches. Vous pouvez utiliser la propre commande Artisan de Laravel php artisan make:job pour créer une nouvelle classe de tâches de file d'attente. 🎜🎜🎜Exemple de classe de tâches : 🎜rrreee🎜En implémentant l'interface ShouldQueue, cette classe de tâches deviendra une classe de tâches pouvant être traitée par une file d'attente. 🎜🎜Ensuite, nous pouvons utiliser la méthode dispatch de la file d'attente pour distribuer la tâche dans la file d'attente et attendre le traitement asynchrone. 🎜🎜Exemple de tâche de distribution : 🎜rrreee
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!