laravel 队列实例（一）

导语之前在写事件/监听器的实例，数据都是直接入库的，实际这一步可以放到队列中去执行。laravel 队列有多种驱动可以选择，这里就使用 redis。创建队列使用 php artisan make:job BrowseLogQueue 即可创建队列文件，最终生成 Jobs/BrowseLogQueue.php 文件功能只是数据入库，代码很简单。需要注意的是，可以在类中指定最大失败次数等配置，代码如下<?php/** * 浏览记录入库 /namespace App\Jobs;use App\Events\NotifyAdmin;use App\Models\BrowseLog;use Illuminate\Bus\Queueable;use Illuminate\Queue\SerializesModels;use Illuminate\Queue\InteractsWithQueue;use Illuminate\Contracts\Queue\ShouldQueue;use Illuminate\Foundation\Bus\Dispatchable;use Exception;class BrowseLogQueue implements ShouldQueue{ use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; // 最大失败次数 public $tries = 5; // 超时 public $timeout = 120; protected $ip_addr; protected $request_url; protected $city_name; protected $created_at; protected $updated_at; /* * Create a new job instance. * * @return void / public function __construct($ip_addr, $request_url, $city_name, $now) { $this->ip_addr = $ip_addr; $this->request_url = $request_url; $this->city_name = $city_name; $this->created_at = $now; $this->updated_at = $now; } /* * Execute the job. * * @return void / public function handle(BrowseLog $browseLog) { $log = new $browseLog; $log->ip_addr = $this->ip_addr; $log->request_url = $this->request_url; $log->city_name = $this->city_name; $log->created_at = $this->created_at; $log->updated_at = $this->updated_at; $log->save(); } /* * 任务失败 * @param Exception $exception / public function failed(Exception $exception) { // 发送邮件，通知管理员 event(new NotifyAdmin($exception->getMessage())); }} 分发任务将监听器 CreateBrowseLog.php 文件修改如下/* * Handle the event. * * @param UserBrowse $event * @return void / public function handle(UserBrowse $event) { // 本地访问不做记录 $arr = [‘127.0.0.1’]; if (!in_array($event->ip_addr, $arr)) { /$log = new \App\Models\BrowseLog(); $log->ip_addr = $event->ip_addr; $log->request_url = $event->request_url; $log->city_name = $event->city_name; $log->save();*/ BrowseLogQueue::dispatch($event->ip_addr, $event->request_url, $event->city_name, now()); /*BrowseLogQueue::dispatch($event->ip_addr, $event->request_url, $event->city_name)->delay(now()->addMinute(1)); 延时添加 */ } }运行队列最后一步就是运行队列，执行 php artisan queue:work 运行没有问题，但是到此并没有结束，还需要使用 Supervisor 进程守护，下篇文章继续。参考资料：队列。