Avec le développement rapide d'Internet, le push de messages est devenu un élément indispensable des applications modernes. Dans de nombreux cas, lorsqu'un utilisateur interagit avec une application, celle-ci doit envoyer des messages instantanément pour obtenir un retour de l'utilisateur. Dans ce cas, l’utilisation d’une file d’attente de messages pour traiter ces messages peut grandement améliorer les performances et l’évolutivité de l’application. Dans cet article, nous expliquerons comment utiliser la file d'attente Laravel pour implémenter le push de messages.

Qu'est-ce que la file d'attente Laravel??

Laravel Queue est un outil de traitement asynchrone des taches. Dans une application Laravel, les taches qui doivent être traitées peuvent être traitées de manière asynchrone en les pla?ant dans une file d'attente. Cette approche peut considérablement améliorer les performances et l’évolutivité des applications et réduire le temps de réponse des utilisateurs.

Utilisez Laravel Queue pour implémenter le push de messages

Dans une application Laravel, vous pouvez implémenter le push de messages en suivant les étapes suivantes :

1. Installer Laravel Queue

Tout d'abord, vous devez installer Laravel Queue. Dans les applications Laravel, les files d'attente Laravel sont installées via Composer. Composer peut être installé en utilisant la commande suivante dans le terminal?:

composer?require?illuminate/queue

2. Configurer Laravel Queue

Après avoir installé Laravel Queue, une certaine configuration est requise. Dans l'application Laravel, vous pouvez le configurer en procédant comme suit?:

A Ajoutez les informations de configuration suivantes dans le fichier .env?:

QUEUE_CONNECTION=redis
REDIS_HOST=localhost
REDIS_PASSWORD=null
REDIS_PORT=6379

B Configurez-le dans le fichier config/queue.php?:

'connections'?=>?[

????????'redis'?=>?[
????????????'driver'?=>?'redis',
????????????'connection'?=>?'default',
????????????'queue'?=>?env('QUEUE_NAME',?'default'),
????????????'retry_after'?=>?90,
????????????'block_for'?=>?null,
????????],

????],

3. Write. Code push de message

Après avoir terminé la configuration de la file d'attente Laravel, vous pouvez écrire du code pour implémenter le push de message. Voici un exemple d'écriture du code?:

use?Illuminate\Support\Facades\Queue;
use?App\Jobs\PushNotification;

$data?=?[
????'title'?=>?'New?Notification',
????'message'?=>?'You?have?a?new?notification',
????'user_id'?=>?1,
];

Queue::push(new?PushNotification($data));

Dans cet exemple, nous encapsulons les données de notification qui doivent être envoyées dans un tableau et les pla?ons dans la file d'attente. Après cela, la file d'attente Laravel gérera cette tache de manière asynchrone et exécutera la tache PushNotification.

4. écriture du code de tache de la file d'attente

Dans l'exemple ci-dessus, nous poussons les données de notification dans la file d'attente. Ensuite, vous devez écrire un code de tache qui gère les taches de notification push dans la file d'attente. Voici un exemple :

namespace?App\Jobs;

use?Illuminate\Support\Facades\Log;

class?PushNotification?implements?ShouldQueue
{
????use?Dispatchable,?InteractsWithQueue,?Queueable,?SerializesModels;

????protected?$data;

????/**
?????*?Create?a?new?job?instance.
?????*
?????*?@param?array?$data
?????*/
????public?function?__construct(array?$data)
????{
????????$this->data?=?$data;
????}

????/**
?????*?Execute?the?job.
?????*
?????*?@return?void
?????*/
????public?function?handle()
????{
????????//?Handle?the?notification?here
????????Log::info('Notification?sent?to?user?ID?'?.?$this->data['user_id']);
????}
}

Dans cet exemple, nous définissons une tache PushNotification et créons un constructeur pour initialiser les données requises par la tache. Dans la méthode handle de la tache, nous gérerons la logique d’envoi de la notification et enregistrerons à quel utilisateur la notification a été envoyée.

5. Démarrer le processeur de file d'attente

Après avoir terminé l'écriture des taches de file d'attente, vous devez démarrer le processeur de file d'attente pour exécuter les taches dans la file d'attente. Vous pouvez démarrer le processeur de file d'attente à l'aide de la commande suivante :

php?artisan?queue:work

Bien s?r, vous pouvez également spécifier la connexion à la file d'attente en exécutant la commande suivante :

php?artisan?queue:work?redis

Dans Laravel Queue, les processeurs de file d'attente disponibles incluent : Sync, Database, Redis, Beanstalkd. , Amazon SQS et Null. La commande ci-dessus utilise la connexion à la file d'attente Redis par défaut. La connexion à la file d'attente par défaut et le nom de la file d'attente peuvent être modifiés en modifiant le fichier .env.

6. Tests

Après avoir terminé toutes les étapes ci-dessus, nous pouvons tester si notre message push fonctionne correctement. En enregistrant le message poussé, nous pouvons déterminer si la tache a été ajoutée avec succès à la file d'attente. Voici un exemple de test d'un message push à l'aide d'un fichier journal?:

use?Illuminate\Support\Facades\Queue;
use?App\Jobs\PushNotification;

$data?=?[
????'title'?=>?'New?Notification',
????'message'?=>?'You?have?a?new?notification',
????'user_id'?=>?1,
];

Queue::push(new?PushNotification($data));
Log::info('Notification?sent?to?user?ID?'?.?$data['user_id']);

Dans cet exemple, nous enregistrons à quel utilisateur la notification a été envoyée. Après avoir démarré le processeur de file d'attente, vérifiez le fichier journal pour confirmer que la notification a été envoyée.

Conclusion

Les messages push sont devenus un élément essentiel des applications modernes lorsque les utilisateurs interagissent avec l'application. Dans cet article, nous avons présenté comment utiliser les files d'attente Laravel pour implémenter le push de messages. En utilisant les files d'attente Laravel, vous pouvez traiter les taches de votre application de manière asynchrone, améliorant ainsi les performances et l'évolutivité de votre application. Les files d'attente Laravel ne sont pas seulement faciles à utiliser, elles constituent un outil simple mais puissant qui peut être utilisé pour envoyer des messages vers n'importe quel appareil ou plate-forme au sein de votre application.

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!