亚洲精品tv久久久久,无码8090精品久久一区,色综合久久无码五十路人妻

批量處理任務的場景在我們開發中是經常使用的，比如郵件群發，消息通知，短信，秒殺等等，我們需要將這個耗時的操作放在隊列中來處理，從而大幅度縮短web請求和相應的時間。

下面講解下laravel中隊列的使用

配置文件 config/queue.php

<?php return [     &#39;default&#39; =>?env('QUEUE_DRIVER',?'sync'), ????'connections'?=&gt;?[ ????????'sync'?=&gt;?[ ????????????'driver'?=&gt;?'sync', ????????], ????????'database'?=&gt;?[ ????????????'driver'?=&gt;?'database', ????????????'table'?=&gt;?'jobs', ????????????'queue'?=&gt;?'default', ????????????'retry_after'?=&gt;?90, ????????], ????????'beanstalkd'?=&gt;?[ ????????????'driver'?=&gt;?'beanstalkd', ????????????'host'?=&gt;?'localhost', ????????????'queue'?=&gt;?'default', ????????????'retry_after'?=&gt;?90, ????????], ????????'sqs'?=&gt;?[ ????????????'driver'?=&gt;?'sqs', ????????????'key'?=&gt;?'your-public-key', ????????????'secret'?=&gt;?'your-secret-key', ????????????'prefix'?=&gt;?'https://sqs.us-east-1.amazonaws.com/your-account-id', ????????????'queue'?=&gt;?'your-queue-name', ????????????'region'?=&gt;?'us-east-1', ????????], ????????'redis'?=&gt;?[ ????????????'driver'?=&gt;?'redis', ????????????'connection'?=&gt;?'default', ????????????'queue'?=&gt;?'default', ????????????'retry_after'?=&gt;?90, ????????], ????], ????'failed'?=&gt;?[ ????????'database'?=&gt;?env('DB_CONNECTION',?'mysql'), ????????'table'?=&gt;?'failed_jobs', ????], ];

配置文件默認使用的是同步驅動sync，每一種隊列驅動的配置都可以在該文件中找到，包括數據庫， Beanstalkd， Amazon SQS， Redis。其中還包含了一個null隊列驅動用于那些放棄隊列的任務。failed配置項用于配置失敗隊列任務存放的數據庫及數據表。?

接下來我們需要創建一個隊列任務類。

創建隊列任務類，之后會在app/Jobs目錄下生成一個SendEmail.php的文件

php?artisan?make:job?SendEmail

<?php namespace AppJobs; use AppUser; use IlluminateBusQueueable; use IlluminateQueueSerializesModels; use IlluminateQueueInteractsWithQueue; use IlluminateContractsQueueShouldQueue; use IlluminateFoundationBusDispatchable; use IlluminateSupportFacadesMail; class SendEmail implements ShouldQueue {     use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;     protected $user;     /**      * Create a new job instance.      *      * @return void      */     public function __construct(User $user)     {         $this->user?=?$user; ????} ????/** ?????*?執行隊列的方法?比如發送郵件 ?????* ?????*?@return?void ?????*/ ????public?function?handle() ????{ ??????$user?=?$this-&gt;user; ?????? ??????Mail::raw('這里填寫郵件的內容',function?($message){ ?????????????//?發件人（你自己的郵箱和名稱） ????????????$message-&gt;from('your_email@163.com',?'yourname'); ????????????//?收件人的郵箱地址 ????????????$message-&gt;to($this-&gt;user); ????????????//?郵件主題 ????????????$message-&gt;subject('隊列發送郵件'); ????????}); ????} }

任務類創建完之后到控制器把數據加入到隊列

創建發送消息的控制器使用dispatch方法手動分發任務,方法里傳一個任務類的實例

<?php namespace AppHttpControllers; use AppJobsSendEmail; use AppUser; class MessageController extends Controller {     public function index()     {         $user = User::find(1);         $this->dispatch(new?SendEmail($user)); ????} }

然后訪問瀏覽器，運行項目把任務推送到隊列中。然后使用Artisan命令，執行隊列里的任務

php artisan queue:

● queue:work 默認只執行一次隊列請求, 當請求執行完成后就終止；

●?queue:listen 監聽隊列請求，只要運行著，就能一直接受請求，除非手動終止；

●?queue:work –daemon同listen一樣，不同的是work不需要再次加載框架，直接運行任務，一般推薦使用這個來處理隊列監聽。

●?注：使用 queue:work –daemon ，當更新代碼的時候，需要停止，然后重新啟動，這樣才能把修改的代碼應用上。

更多Laravel相關技術文章，請訪問Laravel框架入門教程欄目進行學習！

文章版權歸作者所有，未經允許請勿轉載。

THE END