這里以發(fā)郵件為例，使用Redis做為隊(duì)列驅(qū)動(dòng)。
要先安裝predis組件：
composer require predis/predis
注意：要把php自帶的redis插件刪除掉！
1. 配置發(fā)送郵箱
1.1 在項(xiàng)目的.env文件中配置
DB_HOST= #數(shù)據(jù)庫(kù)主機(jī)地址
DB_DATABASE= #數(shù)據(jù)庫(kù)名
DB_USERNAME= #數(shù)據(jù)庫(kù)帳號(hào)
DB_PASSWORD= #數(shù)據(jù)庫(kù)密碼
QUEUE_DRIVER=redis #選用redis做隊(duì)列驅(qū)動(dòng)
MAIL_DRIVER=smtp
MAIL_HOST=郵箱服務(wù)器地址，如：smtp.126.com
MAIL_PORT=郵箱服務(wù)器端口，如：25
MAIL_USERNAME=你的郵箱帳號(hào)
MAIL_PASSWORD=你的郵箱密碼或授權(quán)碼
MAIL_ENCRYPTION=null
1.2 修改config/mail.php
'from' => ['address' => '你的郵箱帳號(hào)', 'name' => '項(xiàng)目名稱'],
2. 生成任務(wù)類(lèi)
php artisan make:job SendMailJob --queued
隊(duì)列的任務(wù)類(lèi)都默認(rèn)放在app/Jobs目錄下，任務(wù)類(lèi)會(huì)包含一個(gè)讓隊(duì)列用來(lái)調(diào)用此任務(wù)的handle方法，我們就在這個(gè)方法內(nèi)寫(xiě)要隊(duì)列執(zhí)行的動(dòng)作：
<?php
namespace App\Jobs;
use Log;
use Mail;
use App\Jobs\Job;
use Swift_RfcComplianceException;
use Exception;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Bus\SelfHandling;
use Illuminate\Contracts\Queue\ShouldQueue;
class SendMailJob extends Job implements SelfHandling, ShouldQueue
{
use InteractsWithQueue, SerializesModels;
private $to;
/**
* Create a new job instance.
*
* @return void
*/
public function __construct($to = '')
{
$this->to = $to;
}
/**
* 運(yùn)行任務(wù)。
*
* @return void
*/
public function handle()
{
if ($this->attempts() > 3) {
// 失敗了
echo '失敗了';
return false;
}
$to = $this->to;
try {
// 發(fā)郵件
Mail::send('mails.active', ['content' => 'this is a test Email ! by SCORT !!!'], function ($m) use($to) {
$m->from('你的郵箱帳號(hào)', '項(xiàng)目名稱')
->to($to)
->subject('郵件主題');
});
echo '成功:' . date('Ymd') . "\n";
} catch (Swift_RfcComplianceException $e) {
echo $e->getMessage();
// 當(dāng)任務(wù)失敗時(shí)會(huì)被調(diào)用...
Log::info($e->getMessage(), ['path' => __METHOD__, 'line' => __LINE__]);
} catch (Exception $e) {
echo 'ERROR';
// 當(dāng)任務(wù)失敗時(shí)會(huì)被調(diào)用...
Log::info($e->getMessage(), ['path' => __METHOD__, 'line' => __LINE__]);
}
}
/**
* 處理一個(gè)失敗的任務(wù)
*
* @return void
*/
public function failed()
{
// 當(dāng)任務(wù)失敗時(shí)會(huì)被調(diào)用...
Log::info('當(dāng)任務(wù)失敗時(shí)會(huì)被調(diào)用', ['path' => __METHOD__, 'line' => __LINE__]);
}
}
3. 創(chuàng)建郵箱模板
視圖目錄resources/views/下創(chuàng)建mails目錄，并在這個(gè)目錄里面創(chuàng)建郵件郵件模板active.blade.php
<html>
<head>
<title>郵件模板</title>
</head>
<body>
<div class="quote">{{ $content or '---' }}</div>
</div>
</body>
</html>
4. 回調(diào)處理
我們可以在 Laravel 內(nèi)置的app/Providers/AppServiceProvider.php中附加任務(wù)事件回調(diào)函數(shù)：
<?php
namespace App\Providers;
use Log;
use Queue;
use Illuminate\Support\ServiceProvider;
class AppServiceProvider extends ServiceProvider
{
/**
* Bootstrap any application services.
*
* @return void
*/
public function boot()
{
// 隊(duì)列失敗
Queue::failing(function ($connection, $job, $data) {
// 通知團(tuán)隊(duì)失敗的任務(wù)...
Log::error($connection);
Log::error('隊(duì)列執(zhí)行失??！', $data);
});
// 隊(duì)列完成
Queue::after(function ($connection, $job, $data) {
Log::info('隊(duì)列執(zhí)行完成！', $data);
});
}
/**
* Register any application services.
*
* @return void
*/
public function register()
{
//
}
}
5. 把任務(wù)推送到隊(duì)列上
可以在app/Http/Controllers/TestController.php控制器(如果沒(méi)有自行創(chuàng)建)上使用dispatch方法推送
<?php
namespace App\Http\Controllers;
use App\Jobs\SendMailJob;
use App\Http\Controllers\Controller;
class TestController extends Controller
{
/**
* 郵件測(cè)試
*/
public function mail()
{
$toArr = [
'469306621@qq.com',
'feng7396553@163.com',
'xfeng7396553',
];
foreach ($toArr as $to) {
$job = (new SendMailJob($to));
$this->dispatch($job);
}
echo 'success';
}
}
6. 失敗處理
當(dāng)任務(wù)運(yùn)行超過(guò)該重試次數(shù)時(shí)，它就會(huì)被寫(xiě)入至failed_jobs這個(gè)數(shù)據(jù)表中，運(yùn)行遷移：
php artisan queue:failed-table
php artisan migrate
可以用
queue:failed這個(gè) Artisan 命令查看失敗任務(wù):
php artisan queue:failed
要重試所有失敗的任務(wù)，可以使用queue:retry
php artisan queue:retry all
刪除所有失敗的任務(wù)：
php artisan queue:flush
7. 隊(duì)列監(jiān)聽(tīng)
php artisan queue:work --daemon --tries=3 #tries 重試次數(shù)
8. 添加路由
在路由文件app/Http/routes.php中添加如下一條路由：
Route::get('mail', 'TestController@mail');
9. 開(kāi)始發(fā)郵件
瀏覽器中訪問(wèn)：
http://你的IP/mail
