Explication graphique de l'utilisation de think-queue pour envoyer des e-mails de manière asynchrone dans les scénarios d'enregistrement des utilisateurs

Cet article est écrit par la colonne thinkphpFramework Tutorial pour présenter l'utilisation de think-queue pour envoyer des e-mails de manière asynchrone dans les scénarios d'enregistrement des utilisateurs. J'espère que cela sera utile aux amis dans le besoin !

Tutoriel d'utilisation de think-queue - scénario d'enregistrement d'utilisateur pour envoyer des e-mails de manière asynchrone

Environnement local :

Le système est : Mac Os
Version php : 7.1
Version ThinkPHP : 5.1.15

J'ai récemment vu think- queue Cette classe d'extension n'était pas écrite dans le manuel. C'était un casse-tête. J'ai trouvé beaucoup d'informations et j'ai finalement écrit une scène. Veuillez me pardonner si elle n'est pas bien écrite. Tout d'abord, nous avons créé un projet pour télécharger le framework tp. extension think-queue. Créez le projet :

Entrez le répertoire du projet pour afficher :

Téléchargez la classe d'extension

Après le téléchargement, entrez et affichez :

Utilisez ensuite MAMP pour créer un machine virtuelle

Créez ensuite la base de données et la table de données ;

create database if not exists myproject;
use myproject;
DROP TABLE IF EXISTS member;
CREATE TABLE IF NOT EXISTS member(
  id int(11) AUTO_INCREMENT primary key comment 'ID',
  email VARCHAR(32) NOT NULL DEFAULT '' COMMENT '',
  password VARCHAR(255) NOT NULL default '' comment '',
  create_time INT(11) UNSIGNED NOT NULL DEFAULT 0 comment '',
  update_time INT(11) UNSIGNED NOT NULL DEFAULT 0 comment '',
  unique key (email)
)engine innodb charset utf8;

Démarrez le service redis

Après cela, une série d'opérations, telles que l'activation du routage obligatoire, la configuration de la base de données, la configuration du routage, la configuration des balises de modèle , etc.....

Créer la page Répertoire du contrôleur Register.php : application/index/controller/Register.php

Créer le répertoire du modèle Member.php : application/index/model/Member.php

Créer le validateur Register.php répertoire : application/index/validate/Register.php

Créez le fichier sendActivationMail.php pour la file d'attente de traitement Répertoire : application/index/job /sendActivationMail.php

Créez la méthode d'opération

<?php /**
 * User: 李昊天
 * Date: 18/6/7
 * Time: 上午3:15
 * Email: haotian0607@gmail.com
 */

namespace app\index\controller;

use think\Controller;
use app\index\model\Member as MemberModel;
use app\index\validate\Register as RegisterValidate;
use think\Queue;

class Register extends Controller
{
    private $model = &#39;&#39;;

    public function initialize()
    {
        $this->model = new MemberModel();
    }

    /**
     * 渲染模板 展示注册页面
     * @return mixed
     */
    public function index()
    {
        return $this->fetch('index');
    }

    /**
     * 执行注册逻辑
     */
    public function doRegister()
    {
        if ($this->request->isPost()) {
            #实例化验证器 执行验证 如果验证失败跳转并且提示
            $validate = new RegisterValidate();
            $data = $this->request->post();
            if (false === $validate->check($data)) return $this->error($validate->getError());
            //此处应该加密密码 md5 sha1 hash 都可以
            //写入注册的用户
            $result = $this->model->allowField(['email', 'password'])->save($data);
            if ($result) {
                //注册完毕后获取到邮件账号  然后加入到队列
                $this->sendActivationMail($this->model->email);
                return $this->success('注册成功,请前往邮箱激活您的账号!');
            } else {
                return $this->error('注册失败');
            }
        }
    }

    /**
     * @param string $email 邮箱账号
     */
    private function sendActivationMail($email = '')
    {
        $jobName = 'app\index\job\sendActivationMail';  //负责处理队列任务的类
        $data = ['email' => $email]; //当前任务所需的业务数据
        $jobQueueName = 'sendActivationMail'; //当前任务归属的队列名称，如果为新队列，会自动创建


        $result = Queue::push($jobName, $data, $jobQueueName);

        if ($result) {
            echo date('Y-m-d H:i:s') . '一个新的队列任务';
        } else {
            echo date('Y-m-d H:i:s') . '添加队列出错';
        }

        // php think queue:work --queue sendActivationMail --daemon
    }
}

sendActivationMail.php dans le contrôleur de registre après. le code

<?php /**
 * User: 李昊天
 * Date: 18/6/7
 * Time: 上午3:36
 * Email: haotian0607@gmail.com
 */

namespace app\index\job;

use think\queue\Job;
use PHPMailer\Mail;
use think\Exception;

class sendActivationMail
{
    /**
     * fire方法是消息队列默认调用的方法
     * @param Job $job 当前的任务对象
     * @param $data 发布任务时自定义的数据
     */
    public function fire(Job $job, $data)
    {
        //执行发送邮件
        $isJobDone = $this->sendMail($data);

        //如果发送成功  就删除队列
        if ($isJobDone) {
            print ("<warn>任务执行成功,,已经删除!" . "</warn>\n");
            $job->delete();
        } else {
            //如果执行到这里的话 说明队列执行失败  如果失败三次就删除该任务  否则重新执行
            print ("<warn>任务执行失败!" . "</warn>\n");
            if ($job->attempts() > 3) {
                print ("<warn>删除任务!" . "</warn>\n");
                $job->delete();
            } else {

                $job->release(); //重发任务
                print ("<info>重新执行!第" . $job->attempts() . "次重新执行!</info>\n");
            }
        }
    }

    /**
     * 发送邮件
     * @param $data
     * @return bool
     */
    private function sendMail($data)
    {
        $title = '账号激活邮件';
        $msg = '欢迎您注册xxx网站,您的请点击一下连接激活您的账号!....';
        try {
            return Mail::send($title, $msg, $data['email']);
        } catch (Exception $e) {
            return false;
        }
    }
}

est écrit, basculez le contrôleur vers le répertoire actuel pour l'exécution

php think queue:work --queue sendActivationMail --daemon

Il y a des commentaires très détaillés dans le code, mais ce n'est pas complet,,, il n'y a pas de rappel d'erreur, J'écrirai. la suite du code quand j'aurai le temps la prochaine fois

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!