一、配置文件

首先我們需要在配置文件中配置默認隊列驅動為Redis，隊列配置文件是config/queue.php：

return ['default' => env('QUEUE_DRIVER', 'sync'),'connections' => ['sync' => ['driver' => 'sync',],'database' => ['driver' => 'database','table' => 'jobs','queue' => 'default','expire' => 60,],'beanstalkd' => ['driver' => 'beanstalkd','host' => 'localhost','queue' => 'default','ttr' => 60,],'sqs' => ['driver' => 'sqs','key' => 'your-public-key','secret' => 'your-secret-key','queue' => 'your-queue-url','region' => 'us-east-1',],'iron' => ['driver' => 'iron','host' => 'mq-aws-us-east-1.iron.io','token' => 'your-token','project' => 'your-project-id','queue' => 'your-queue-name','encrypt' => true,],'redis' => ['driver' => 'redis','connection' => 'default','queue' => 'default','expire' => 60,],],'failed' => ['database' => 'mysql', 'table' => 'failed_jobs',],
];

?

該配置文件第一個配置項default用于指定默認的隊列驅動，這里我們將其值改為redis（實際上是修改.env中的QUEUE_DRIVER）。

二、編寫隊列任務

?

首先我們通過如下Artisan命令創建任務類：
php artisan make:job SendReminderEmail
運行成功后會在app/Jobs目錄下生成一個SendReminderEmail.php，我們修改其內容如下：

?

<?php
namespace App\Jobs;use App\Jobs\Job;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Bus\SelfHandling;
use Illuminate\Contracts\Queue\ShouldQueue;
use App\User;
use Illuminate\Contracts\Mail\Mailer;
class SendReminderEmail extends Job implements SelfHandling, ShouldQueue
{use InteractsWithQueue, SerializesModels;protected $user;/*** Create a new job instance.** @return void*/public function __construct(User $user){$this->user = $user;}/*** Execute the job.** @return void*/public function handle(Mailer $mailer){$user = $this->user;$mailer->send('emails.reminder',['user'=>$user],function($message) use ($user){$message->to($user->email)->subject('新功能發布');});}
}

?

三、推送隊列任務

?

????手動分發任務
我們可以使用控制器中的DispatchesJobs trait（該trait在控制器基類Controller.php中引入）提供的dispatch方法手動分發任務：

//在控制器中use
use App\Jobs\SendReminderEmail;接著直接調用就是了
$user = App\User::findOrFail($id);
$this->dispatch(new SendReminderEmail($user));

四、運行隊列監聽器

在瀏覽器中訪問http://laravel.app:8000/mail/sendReminderEmail/1，此時任務被推送到Redis隊列中，我們還需要在命令行中運行Artisan命令執行隊列中的任務。Laravel為此提供了三種Artisan命令：

queue:work 默認只執行一次隊列請求, 當請求執行完成后就終止；
queue:listen 監聽隊列請求，只要運行著，就能一直接受請求，除非手動終止；
queue:work --daemon 同 listen 一樣， 只要運行著，就能一直接受請求，不一樣的地方是在這個運行模式下，當新的請求到來的時候，不重新加載整個框架，而是直接 fire 動作。能看出來， queue:work --daemon是最高級的，一般推薦使用這個來處理隊列監聽。
注：使用 queue:work --daemon ，當更新代碼的時候，需要停止，然后重新啟動，這樣才能把修改的代碼應用上。

所以我們接下來在命令行中運行如下命令：
php artisan queue:work --daemon

總結

以上是生活随笔為你收集整理的Laravel7中Redis队列的使用的全部內容，希望文章能夠幫你解決所遇到的問題。

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