Comment gérer les exceptions liées au courrier à l'aide des files d'attente PHP ?

Comment gérer les exceptions liées au courrier à l'aide de la file d'attente PHP ?

Dans le développement réel, nous rencontrons souvent des situations anormales liées à l'envoi d'e-mails, telles qu'une panne du serveur de messagerie, des problèmes de réseau provoquant un échec d'envoi d'e-mails, etc. Pour résoudre ces problèmes, nous pouvons utiliser les files d'attente PHP pour gérer les exceptions liées au courrier. Cet article explique comment utiliser les files d'attente PHP pour gérer ces exceptions et fournit des exemples de code spécifiques.

1. Installer et configurer le système de file d'attente
   Tout d'abord, nous devons installer et configurer un système de file d'attente approprié. Actuellement, les systèmes de file d'attente les plus couramment utilisés incluent Beanstalkd et Redis. Dans cet article, nous utilisons Beanstalkd comme exemple de démonstration.

Tout d'abord, installez Beanstalkd via la ligne de commande :

sudo apt-get install beanstalkd

Ensuite, démarrez le service Beanstalkd :

sudo systemctl start beanstalkd

Ensuite, nous devons installer l'extension Beanstalkd en PHP, qui peut être installée via la commande suivante :

pecl install beanstalkd

Après l'installation est terminée, éditez le fichier php.ini et ajoutez le contenu suivant :

extension=beanstalkd.so

Redémarrez le service PHP-FPM :

sudo systemctl restart php-fpm

2. Écrivez une classe de traitement de file d'attente de courrier
   Ensuite, nous devons écrire une classe de traitement de file d'attente de courrier qui est responsable de l'ajout des e-mails à envoyer à la file d'attente et de gérer la logique d'envoi des e-mails dans la file d'attente. Voici un exemple de classe de traitement de file d'attente de courrier simple :

class MailQueue { protected $beanstalk; public function __construct() { $this->beanstalk = new PheanstalkPheanstalk('127.0.0.1'); } public function sendEmail($email, $subject, $message) { // 将邮件任务加入队列 $this->beanstalk->useTube('mail_queue')->put(json_encode([ 'email' => $email, 'subject' => $subject, 'message' => $message, ])); } public function handleEmails() { // 监听队列并处理邮件发送逻辑 while (true) { $job = $this->beanstalk->reserveFromTube('mail_queue'); $data = json_decode($job->getData(), true); // 发送邮件逻辑，这里省略具体实现 $this->sendEmail($data['email'], $data['subject'], $data['message']); // 删除任务 $this->beanstalk->delete($job); } } }

3. Utiliser la classe de traitement de file d'attente de courrier pour envoyer des courriers
   Utiliser la classe de traitement de file d'attente de courrier pour envoyer des courriers est très simple, il suffit d'appelersendEmail méthode. Voici un exemple de code qui utilise la classe de traitement de la file d'attente de courrier pour envoyer des e-mails : sendEmail方法即可。以下是一个使用邮件队列处理类发送邮件的示例代码：

$mailQueue = new MailQueue(); $mailQueue->sendEmail('example@example.com', '邮件主题', '邮件内容');

[program:mail_queue_worker] command=php /path/to/mail_queue_worker.php directory=/path/to/project user=www-data numprocs=1 autostart=true autorestart=true process_name=%(program_name)s_%(process_num)02d redirect_stderr=true