Lokale Umgebung:
System ist: Mac OS
php-Version: 7.1
ThinkPHP-Version: 5.1.15
Ich habe kürzlich think- queue Diese Erweiterungsklasse wurde nicht im Handbuch geschrieben. Ich habe viele Informationen gefunden und schließlich eine Szene geschrieben. Zuerst haben wir ein Projekt zum Herunterladen des TP-Frameworks erstellt think-queue-Erweiterung. Erstellen Sie das Projekt:
Geben Sie das Projektverzeichnis ein, um es anzuzeigen: 
Laden Sie die Erweiterungsklasse herunter. 
Geben Sie nach dem Herunterladen Folgendes ein und zeigen Sie es an: 
Erstellen Sie dann mit MAMP ein Virtuelle Maschine 
Erstellen Sie dann die Datenbank und die Datentabelle. 
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;Starten Sie den Redis-Dienst.
Danach werden eine Reihe von Vorgängen ausgeführt, z. B. das Aktivieren des obligatorischen Routings, das Konfigurieren der Datenbank, das Konfigurieren des Routings und das Konfigurieren von Vorlagen-Tags usw.....
Erstellen Sie das Member.php-Modellverzeichnis: application/index/model/Member.php
Erstellen Sie den Register.php-Validator Verzeichnis: application/index/validate/Register.phpErstellen Sie die Datei sendActivationMail.php für die Verarbeitungswarteschlange. Verzeichnis: application/index/job /sendActivationMail.php
Erstellen Sie die Operationsmethode
<?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 = '';
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 im Register-Controller Der 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;
}
}
} ist geschrieben, wechseln Sie den Controller zur Ausführung in das aktuelle Verzeichnis
php think queue:work --queue sendActivationMail --daemon
Der Code enthält jedoch sehr detaillierte Kommentare. Es gibt keinen Fehlerrückruf. 
Ich werde schreiben Den Rest des Codes, wenn ich das nächste Mal Zeit habe