Penjelasan grafik tentang cara menggunakan think-queue untuk menghantar e-mel secara tidak segerak dalam senario pendaftaran pengguna

Artikel ini ditulis oleh thinkphp ruangan tutorial rangka kerja untuk memperkenalkan penggunaan think-queue untuk menghantar e-mel secara tidak segerak dalam senario pendaftaran pengguna. Saya harap ia akan membantu rakan-rakan perlukan!

Tutorial penggunaan Think-queue-penghantaran e-mel tak segerak dalam senario pendaftaran pengguna

Persekitaran setempat:

Sistem ialah: Mac Os
versi php: 7.1
ThinkPHP versi: 5.1.15

Baru-baru ini saya melihat kelas sambungan think-queue tetapi manual tidak ditulis maklumat dan akhirnya menulis senario Maaf atas penulisan yang lemah
Mula-mula kami mencipta projek dan memuat turun rangka kerja tp dan sambungan think-queue

Buat projek:
<.>Masukkan direktori projek untuk melihat:

Muat turun kelas sambungan

Selepas memuat turun, lihat:

Kemudian gunakan MAMP untuk mencipta maya Selepas mesin

cipta pangkalan data dan jadual data

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;

mulakan redis perkhidmatan

dan kemudian beberapa siri operasi, Contohnya, dayakan penghalaan mandatori, konfigurasi pangkalan data, konfigurasi penghalaan, konfigurasi teg templat, dll....

Buat halaman Direktori Pengawal Register.php: application/index/controller/Register.php

Buat Direktori model Member.php: application/index/model/Member.php
Buat direktori Pengesah Register.php: application/index/validate/ Register.php
Buat fail sendActivationMail.php untuk memproses baris gilir Direktori: application/index/job /sendActivationMail.php

Buat kaedah operasi dalam pengawal Daftar

<?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 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;
        }
    }
}

Selepas menulis kod, tukar pengawal ke direktori semasa Laksanakan di bawah

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

Terdapat ulasan yang sangat terperinci dalam kod, tetapi ini tidak lengkap,,, tiada ralat panggil balik,

Saya akan tunggu sehingga saya ada masa seterusnya Kemudian tulis kod yang lain!

Atas ialah kandungan terperinci Penjelasan grafik tentang cara menggunakan think-queue untuk menghantar e-mel secara tidak segerak dalam senario pendaftaran pengguna. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!