## 消息隊列執行步驟 ### 1、`.env`文件指定隊列消息使用驅動 默認`sync`同步，可以換成數據庫`database` 和`redis` ~~~ QUEUE_CONNECTION=database ~~~ 在`config/queue.php`修改`'default' => env('QUEUE_DRIVER', 'redis')` ### 2、建立消息隊列的數據庫 ~~~ php artisan queue:table php artisan queue:failed-table php artisan migrate ~~~ ### 3、創建消息隊列 ``` php artisan make:job Test ``` 在`lumen`中沒有生成消息隊列的命令，可以在`app/job`下復制`ExampleJob.php` ### 4、分發（創建）消息隊列（數據庫可以看到消息隊列的信息） `->onQueue('test');`相對于隊列名稱，在`jobs`數據表中的`queue`字段 ~~~ $result = Test::dispatch('發送隊列任務！！'); // 或者 Queue::push('SendMail', array('message' => $message)); Queue::push('SendEmail@send', array('message' => $message)); Queue::push(function($job) use $id {}); ~~~ 在`lumen`中使用 ~~~ // 發送調度任務 //$result = dispatch(new Test($data)); // 成功 //$result = Queue::push(new Test($data)); // 成功 //$result = Queue::push(new Test())->onQueue('emails'); // 失敗 $result = dispatch(new Test($data))->onQueue('test'); // 成功 ~~~ `laravel`隊列操作的`handle`中增加依賴【未測試】 ``` $this->app->bindMethod(Test::class.'@handle', function ($job, $app) { return $job->handle($app->make(AudioProcessor::class)); }); ``` ### 5、執行消息隊列 ~~~ 執行隊列【一直運行】 php artisan queue:work 執行指定隊列【一直運行】 php artisan queue:work --queue=default 執行指定隊列【執行所有隊列后退出】 php artisan queue:work --stop-when-empty // 一小時后關閉 php artisan queue:work --max-time=3600 超時 --timeout=60 休眠 --sleep=3 嘗試次數 --tries=3 ~~~ ### 6、測試隊列消息 可以創建同步隊列消息，即默認隊列消息，在調用的隊列消息中寫入日志，訪問接口，查看是否有隊列消息的日志即可 ~~~ QUEUE_CONNECTION=sync ~~~