環境

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

queue 配置環境 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驅動
'connector' => 'redis',
"expire" => 60,//任務過期時間默認為秒，禁用為null
"default" => "default",//默認隊列名稱
"host" => Env::get("redis.host", "127.0.0.1"),//Redis主機IP地址
"port" => Env::get("redis.port", 6379),//Redis端口
"password" => Env::get("redis.password", "123456"),//Redis密碼
"select" => 5,//Redis數據庫索引
"timeout" => 0,//Redis連接超時時間
"persistent" => false,//是否長連接

];


復制代碼

生產者

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

消費者

<?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) {// 如果任務執行成功， 記得刪除任務
$job->delete();print("-------------------".date('Y-m-d H:i:s',$data['create_time'])."-郵件已發送成功，已經刪除這個隊列了-------------------" . PHP_EOL);
} else {if ($job->attempts() > 3) {//通過這個方法可以檢查這個任務已經重試了幾次了print("Hello Job has been retried more than 3 times!" . "\n");
$job->delete();// 也可以重新發布這個任務//print("Hello Job will be availabe again after 2s."."\n");//$job->release(2); //$delay為延遲時間，表示該任務延遲2秒后再執行
}
}
}/**
* 根據消息中的數據進行實際的業務處理...
*/private function JobDone($data)
{/**
* 執行郵件通知
*
*/
sleep(1);
Db::name('queue')->insert($data);return true;
}
}復制代碼

使用

訪問http://www.tp5.cc/ (本地虛擬主機) 創建一個隊列(生產者)

進入項目目錄
cd queue

執行(可以使用定時任務)(消費者)
php think queue:work --daemon --queue userRegisterEmailNoticeQueue1

End

來源：https://juejin.cn/post/6894824585766961166

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。