配置文件config/queue.php ~~~ Supported: "null", "sync", "database", "beanstalkd", "sqs", "redis" //sync同步驅動 ~~~ `'default' => env('QUEUE_DRIVER', 'sync'),//默認同步驅動` ~~~ Queue Connections //隊列的配置 Failed Queue Jobs //失敗的隊列配置 ~~~ 在.env文件中驅動改為數據庫驅動 ~~~ QUEUE_DRIVER=database ~~~ 然后在命令行中 ~~~ php artisan queue:table ~~~ 遷移文件生成成功,然后執行遷移 ~~~ >database >migrations xx時間xxx.php //在命令行中 php artisan migrate ~~~ 創建一個任務類,名字叫SendEmail ~~~ php artisan make:job SendEmail ~~~ 可以看到對應文件夾下多出這些文件 ~~~ >blog >app >Jobs SendEmail.php ~~~ 然后在SendEmail.php文件下寫對應的代碼,寫個發郵件的測試下 ~~~ class SendEmail implements ShouldQueue { use InteractsWithQueue, Queueable,SerializesModels; protected $email; public function __construct($email) { $this->email=$email; } public function handle() { //use Mail; Mail::raw('隊列測試',function($message){ $message->to($this->eamil); //發送給誰 }); } } ~~~ 然后可以在我們控制器方法中使用隊列了 ~~~ public function queue() { //use App\Jobs\SendEmail; dispatch(new SendEmail('825455423@qq.com')); //在對應的隊列中創建成功 } ~~~ 為什么能直接使用dispatch,因為在控制器繼承的controller這個基類已經實現了這個dispatch ~~~ class Controller extends BaseController { use AuthorizesRequests, AuthorizesResources, DispatchesJobs, ValidatesRequests; } ~~~ 如果在模型中要自己手動use,然后運行對應控制器下面方法,可以看到數據庫有隊列的記錄的 然后執行這個隊列監聽器,有隊列進來就執行 ~~~ php artisan queue:listen ~~~ 處理失敗隊列 如果隊列執行失敗會把記錄放到一個失敗的表里面去,遷移創建一個表 建立失敗的表的遷移文件 ~~~ php artisan queue:failed-table ~~~ 創建成功現在開始生成表 ~~~ php artisan migrate ~~~ 遷移成功,失敗會放到failed_jobs這個表中 如果有很多失敗的記錄想重新執行,首先查看錯誤的記錄 ~~~ php artisan queue:failed ~~~ ~~~ //把id為1的失敗隊列那條執行下 php artisan queue:retry 1 //執行所有失敗的 php artisan queue:retry all ~~~ ~~~ //刪除id4的失敗隊列記錄 php artisan queue:forget 4 //全部清除失敗的隊列記錄 php artisan queue:flush ~~~