Comment utiliser RabbitMQ pour la planification des tâches et la gestion des files d'attente en PHP

Comment utiliser RabbitMQ pour la planification des tâches et la gestion des files d'attente en PHP

1 Introduction
Lors du développement d'applications Web, nous devons souvent gérer certaines tâches fastidieuses, telles que l'envoi d'e-mails, la génération de rapports, le traitement de grandes quantités de données, etc. . Si ces tâches sont exécutées directement dans la requête web, le temps de réponse peut être ralenti et l'expérience utilisateur peut être affectée. Afin de résoudre ce problème, nous pouvons utiliser des files d'attente de messages pour la planification des tâches et la gestion des files d'attente. RabbitMQ est un puissant système de file d'attente de messages qui fournit une API riche qui peut être facilement utilisée en PHP.

2. Installez RabbitMQ
Tout d'abord, nous devons installer RabbitMQ sur le serveur. Vous pouvez l'installer selon le tutoriel d'installation fourni sur le site officiel, ou utiliser directement Docker pour exécuter le conteneur RabbitMQ. Une fois l'installation terminée, vous pouvez afficher l'état de la file d'attente et gérer la file d'attente en accédant à la page de gestion RabbitMQ.

3. Utilisez la bibliothèque PHP-amqplib pour fonctionner
L'utilisation de RabbitMQ en PHP nécessite l'utilisation d'une bibliothèque tierce, telle que PHP-amqplib. Cette bibliothèque peut être introduite via Composer. La commande est la suivante :

composer require php-amqplib/php-amqplib

Une fois l'installation terminée, introduisez le fichier de bibliothèque dans le code :

use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;

IV Connectez-vous à RabbitMQ
Avant d'utiliser RabbitMQ, vous devez vous connecter au Serveur RabbitMQ :

$host = 'localhost';
$port = 5672;
$user = 'guest';
$pass = 'guest';
$connection = new AMQPStreamConnection($host, $port, $user, $pass);
$channel = $connection->channel();

Utilisé ici L'hôte, le port, le nom d'utilisateur et le mot de passe RabbitMQ par défaut S'il existe des exigences personnalisées, ces paramètres peuvent être modifiés en fonction de la situation réelle.

5. Envoyer des messages à la file d'attente
Dans la planification des tâches, nous envoyons généralement des tâches à une file d'attente de messages pour être consommées par le travailleur en arrière-plan. Les messages peuvent être envoyés à la file d'attente en utilisant le code suivant :

$message = new AMQPMessage('hello world');
$channel->basic_publish($message, '', 'task_queue');

Ici, nous créons une instance AMQPMessage et définissons le corps du message à envoyer. Utilisez ensuite la méthode basic_publish pour envoyer le message à une file d'attente nommée task_queue.

6. Consommer les messages dans la file d'attente
La consommation des messages dans la file d'attente nécessite le démarrage d'un ou plusieurs processus Worker en arrière-plan pour le traitement. Le processus Worker récupérera le message de la file d'attente et effectuera les tâches correspondantes. Vous pouvez utiliser le code suivant pour consommer les messages dans la file d'attente :

$callback = function ($message) {
    echo "Received: " . $message->body . "
";
    usleep(100000);
    echo "Done
";
    $message->ack();
};
$channel->basic_consume('task_queue', '', false, false, false, false, $callback);
while (count($channel->callbacks)) {
    $channel->wait();
}

Ici, nous définissons une fonction anonyme $callback comme logique de traitement des messages. Dans cette fonction, nous pouvons effectuer un traitement de tâche spécifique, puis appeler la méthode $message->ack() pour indiquer que la tâche est terminée. La raison pour laquelle la méthode ack est appelée est que RabbitMQ ne sait pas si la tâche est exécutée avec succès par défaut, nous devons donc confirmer manuellement le résultat de l'exécution de la tâche.

7. Persistance du message
Dans l'exemple ci-dessus, la persistance du message est désactivée par défaut. Lorsque le serveur RabbitMQ est redémarré, le message sera perdu. Si nous voulons que le message soit automatiquement restauré après le redémarrage du serveur, nous devons effectuer la persistance du message. Il peut être défini par le code suivant :

$channel->queue_declare('task_queue', false, true, false, false);

Définissez le troisième paramètre sur true, ce qui signifie que la file d'attente est définie comme une file d'attente persistante.

8. Tâches retardées
Parfois, nous devons également mettre en œuvre des tâches retardées et exécuter des tâches après une heure spécifiée. RabbitMQ lui-même ne prend pas en charge la fonction de retardement des tâches, mais cela peut être réalisé en ajoutant des plug-ins supplémentaires. Un plug-in couramment utilisé est Rabbitmq_delayed_message_exchange, qui peut être installé des manières suivantes :

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

Une fois l'installation terminée, lors de l'envoi d'un message, définissez les propriétés d'AMQPMessage comme suit :

$message->set('application_headers', ['x-delay' => 3000]);

Le code ci-dessus sera exécuté avec un délai de 3 secondes après l'envoi du message.

9. Résumé
Grâce à l'introduction de cet article, nous avons appris à utiliser RabbitMQ pour la planification des tâches et la gestion des files d'attente en PHP. Après avoir pratiqué les étapes ci-dessus, nous pouvons facilement utiliser RabbitMQ pour gérer des tâches fastidieuses et améliorer les performances et la fiabilité de l'application. Dans le même temps, il introduit également des méthodes de persistance des messages et de traitement des tâches différées, nous permettant de mieux répondre aux différents besoins. J'espère que cet article vous aidera à utiliser RabbitMQ dans des projets réels.

Matériaux de référence :

1. Site officiel de RabbitMQ : https://www.rabbitmq.com/
2. Documentation officielle PHP-amqplib : https://github.com/php-amqplib/php-amqplib

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!