laravel 队列实例（一）

共计 2020 个字符，预计需要花费 6 分钟才能阅读完成。

导语
之前在写事件 / 监听器的实例，数据都是直接入库的，实际这一步可以放到队列中去执行。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 进程守护，下篇文章继续。

参考资料：队列。