環(huán)境

thinkphp5.1
redis
"topthink/think-queue": "2.0.*"
復(fù)制代碼

queue 配置環(huán)境 config/queue.php

<?php
// +----------------------------------------------------------------------
// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]
// +----------------------------------------------------------------------
// | Copyright (c) 2006-2016 http://thinkphp.cn All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
return [
// 'connector' => 'Sync'


//Redis驅(qū)動(dòng)
'connector' => 'redis',
"expire" => 60,//任務(wù)過(guò)期時(shí)間默認(rèn)為秒，禁用為null
"default" => "default",//默認(rèn)隊(duì)列名稱
"host" => Env::get("redis.host", "127.0.0.1"),//Redis主機(jī)IP地址
"port" => Env::get("redis.port", 6379),//Redis端口
"password" => Env::get("redis.password", "123456"),//Redis密碼
"select" => 5,//Redis數(shù)據(jù)庫(kù)索引
"timeout" => 0,//Redis連接超時(shí)時(shí)間
"persistent" => false,//是否長(zhǎng)連接

];


復(fù)制代碼

生產(chǎn)者

<?php /**
* Created by.
* User: Jim
* Date: 2020/11/14
* Time: 10:25
*/namespace app\index\controller;use think\Controller;use think\Queue;/**
* 發(fā)布一個(gè)任務(wù)
* Class JobTest
* @package app\index\controller
*/class Index extends Controller
{public function index()
{// 當(dāng)輪到該任務(wù)時(shí)，系統(tǒng)將生成一個(gè)該類的實(shí)例，并調(diào)用其 fire 方法
$jobHandlerClassName = 'app\index\job\Email';// 2.當(dāng)前任務(wù)歸屬的隊(duì)列名稱，如果為新隊(duì)列，會(huì)自動(dòng)創(chuàng)建
$jobQueueName = "userRegisterEmailNoticeQueue1";// 3.當(dāng)前任務(wù)所需的業(yè)務(wù)數(shù)據(jù) . 不能為 resource 類型，其他類型最終將轉(zhuǎn)化為json形式的字符串
$jobData = ['create_time'=>time(),'queue_name'=>$jobQueueName,'task_type'=>$jobHandlerClassName,'data'=>'data',
];// 4.將該任務(wù)推送到消息隊(duì)列，等待對(duì)應(yīng)的消費(fèi)者去執(zhí)行
$isPushed = Queue::push($jobHandlerClassName, $jobData, $jobQueueName);if ($isPushed !== false) {echo date('Y-m-d H:i:s') . "用戶注冊(cè)郵箱通知加入隊(duì)列成功" . "
";
} else {echo '用戶注冊(cè)郵箱通知加入隊(duì)列失敗.';
}
}
}復(fù)制代碼

消費(fèi)者

<?php /**
* Created by.
* User: Jim
* Date: 2020/11/14
* Time: 10:32
*/namespace app\index\job;use think\Db;use think\queue\Job;class Email
{public function fire(Job $job, $data)
{
$isJobDone = $this->JobDone($data);if ($isJobDone) {// 如果任務(wù)執(zhí)行成功， 記得刪除任務(wù)
$job->delete();print("-------------------".date('Y-m-d H:i:s',$data['create_time'])."-郵件已發(fā)送成功，已經(jīng)刪除這個(gè)隊(duì)列了-------------------" . PHP_EOL);
} else {if ($job->attempts() > 3) {//通過(guò)這個(gè)方法可以檢查這個(gè)任務(wù)已經(jīng)重試了幾次了print("Hello Job has been retried more than 3 times!" . "\n");
$job->delete();// 也可以重新發(fā)布這個(gè)任務(wù)//print("Hello Job will be availabe again after 2s."."\n");//$job->release(2); //$delay為延遲時(shí)間，表示該任務(wù)延遲2秒后再執(zhí)行
}
}
}/**
* 根據(jù)消息中的數(shù)據(jù)進(jìn)行實(shí)際的業(yè)務(wù)處理...
*/private function JobDone($data)
{/**
* 執(zhí)行郵件通知
*
*/
sleep(1);
Db::name('queue')->insert($data);return true;
}
}復(fù)制代碼

使用

訪問http://www.tp5.cc/ (本地虛擬主機(jī)) 創(chuàng)建一個(gè)隊(duì)列(生產(chǎn)者)

進(jìn)入項(xiàng)目目錄
cd queue

執(zhí)行(可以使用定時(shí)任務(wù))(消費(fèi)者)
php think queue:work --daemon --queue userRegisterEmailNoticeQueue1

End

來(lái)源：https://juejin.cn/post/6894824585766961166

總結(jié)

以上是生活随笔為你收集整理的apache license 2.0如何使用防止法律纠纷_Thinkphp + queue 使用队列进行 邮件通知的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。