Technologie PHP pour implémenter l'envoi d'e-mails asynchrone

Avec l'utilisation généralisée du courrier électronique dans notre vie quotidienne et professionnelle, de nombreux sites Web et applications doivent envoyer de grandes quantités d'e-mails. Cependant, dans le cas d'envois de grandes quantités d'e-mails, l'envoi synchrone peut entraîner une dégradation des performances du site Web car PHP doit attendre que l'envoi de l'e-mail soit terminé avant de pouvoir continuer à s'exécuter.

Pour éviter ce problème, vous pouvez utiliser la technologie d'envoi asynchrone pour envoyer des emails. Cet article présentera la technologie PHP pour implémenter l'envoi asynchrone d'e-mails.

Première étape : installer et configurer le système de file d'attente

Pour réaliser l'envoi asynchrone d'e-mails, nous devons utiliser un système de file d'attente. Un système de file d'attente est un système qui stocke les tâches dans une file d'attente et les traite dans l'ordre premier entré, premier sorti.

Il existe actuellement de nombreux systèmes de file d'attente populaires, tels que Beanstalkd, RabbitMQ, Redis, etc. Ces systèmes de file d'attente disposent de bibliothèques PHP qui peuvent être utilisées facilement.

Nous prenons Beanstalkd comme exemple à présenter. Pour utiliser Beanstalkd, nous devons d'abord l'installer sur le serveur. Pour les méthodes d'installation, veuillez vous référer à la documentation officielle.

Après l'installation, nous devons configurer Beanstalkd pour définir son port d'écoute et d'autres paramètres. Veuillez vous référer à la documentation officielle pour les détails de configuration.

Étape 2 : Écrire une tâche de file d'attente

Une fois que nous avons configuré Beanstalkd et que nous l'utilisons comme système de file d'attente, nous devons écrire une tâche de file d'attente pour gérer l'envoi d'e-mails.

La tâche de file d'attente doit contenir le contenu suivant :

1. Paramètres liés à la réception des emails, tels que l'adresse du destinataire, l'objet, le contenu, etc.
2. Appelez la fonction d'envoi d'e-mails de PHP, telle que PHPMailer ou SwiftMailer, etc.
3. Renvoyer les résultats de l'envoi d'e-mails au système de file d'attente pour un traitement ultérieur.

Voici un exemple :

class SendEmailJob
{
    protected $to;
    protected $subject;
    protected $body;

    public function __construct($to, $subject, $body)
    {
        $this->to = $to;
        $this->subject = $subject;
        $this->body = $body;
    }

    public function handle()
    {
        $mailer = new PHPMailer();

        $mailer->setFrom('me@example.com', 'My Name');
        $mailer->addAddress($this->to);
        $mailer->Subject = $this->subject;
        $mailer->Body = $this->body;

        if (!$mailer->send()) {
            return ['success' => false, 'message' => $mailer->ErrorInfo];
        }

        return ['success' => true];
    }
}

Dans cet exemple, nous définissons une classe nommée SendEmailJob, qui reçoit les paramètres liés aux e-mails et appelle PHPMailer dans la méthode handle pour envoyer des e-mails. Si l'e-mail est envoyé avec succès, nous renverrons un tableau avec des informations de réussite, sinon nous renverrons un tableau avec des informations d'erreur.

Troisième étape : ajouter la tâche de messagerie à la file d'attente

Une fois que nous avons écrit la tâche de file d'attente, nous devons l'ajouter à la file d'attente dans Beanstalkd. Ceci peut être réalisé en utilisant la bibliothèque Beanstalkd.

Voici un exemple :

$job = new SendEmailJob('recipient@example.com', 'Subject', 'Body');
$payload = json_encode($job);

$connection = new PheanstalkPheanstalk('127.0.0.1');
$connection->useTube('emails')->put($payload);

Dans cet exemple, nous créons une instance de SendEmailJob et la convertissons en chaîne au format JSON. Nous avons ensuite créé une connexion à Beanstalkd et ajouté la tâche à un canal de file d'attente appelé emails.

Étape 4 : Traiter la tâche de file d'attente

Une fois que nous avons ajouté la tâche à la file d'attente, nous avons besoin d'un processus pour traiter la tâche de file d'attente.

Ce processus devrait :

1. Récupérer les tâches de la file d'attente.
2. Analysez les paramètres de la tâche.
3. Appelez la méthode de traitement des tâches.
4. Renvoyer les résultats des tâches au système de file d'attente.

Voici un exemple :

$connection = new PheanstalkPheanstalk('127.0.0.1');
$connection->watch('emails');

while (true) {
    $job = $connection->reserve();

    $payload = json_decode($job->getData(), true);

    $class = new $payload['class'](...$payload['args']);
    $result = $class->handle();

    if ($result['success']) {
        $connection->delete($job);
    } else {
        $connection->bury($job);
    }
}

Dans cet exemple, nous créons une boucle while exécutée en continu, récupérons la tâche de la file d'attente nommée emails de la file d'attente et appelons la méthode de traitement de la tâche de file d'attente.

Si le traitement réussit, nous supprimons la tâche de la file d'attente, sinon nous remettons la tâche dans la file d'attente pour un traitement ultérieur.

Résumé

Ce qui précède est la technologie PHP permettant de mettre en œuvre l'envoi asynchrone d'e-mails. Elle est principalement divisée en quatre étapes : l'installation et la configuration du système de file d'attente, l'écriture des tâches de file d'attente, l'ajout de tâches de courrier électronique à la file d'attente et le traitement des tâches de file d'attente.

L'utilisation d'un système de file d'attente peut améliorer considérablement la vitesse d'envoi des e-mails et les performances des applications PHP. Il améliore également la délivrabilité des e-mails en nous permettant de traiter plus efficacement les e-mails ayant échoué.

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!