laravel 队列实例（一）

baoxl 发布于2019-07-01 12:40 / 732人阅读

摘要：导语之前在写事件监听器的实例，数据都是直接入库的，实际这一步可以放到队列中去执行。队列有多种驱动可以选择，这里就使用。创建队列使用即可创建队列文件，最终生成文件功能只是数据入库，代码很简单。

导语

之前在写事件/监听器的实例，数据都是直接入库的，实际这一步可以放到队列中去执行。laravel 队列有多种驱动可以选择，这里就使用 redis。

创建队列

使用 php artisan make:job BrowseLogQueue 即可创建队列文件，最终生成 Jobs/BrowseLogQueue.php 文件

功能只是数据入库，代码很简单。需要注意的是，可以在类中指定最大失败次数等配置，代码如下

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 AppModelsBrowseLog();

            $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 进程守护，下篇文章继续。

参考资料：队列。

GPU云服务器云服务器消息队列实例 LaravelS -laravel laravel

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/31223.html

剖析Laravel队列系统--Worker

摘要：一旦这一切完成，方法会运行在类属性在命令构造后设置容器解析实例，在中我们设置了将使用的缓存驱动，我们也根据命令来决定我们调用什么方法。作业只在以上起效在上也无效处理作业方法调用触发事件触发事件。译文GitHub https://github.com/yuansir/diving-laravel-zh 原文链接https://divinglaravel.com/queue-system...

CollinPeng 2019-06-27 17:03 评论0 收藏0
剖析Laravel队列系统--准备队列作业

摘要：原文链接我们推送到队列的每个作业都存储在按执行顺序排序的某些存储空间中，该存储位置可以是数据库，存储或像这样的第三方服务。这个数字从开始，在每次运行作业时不断增加。原文链接https://divinglaravel.com/queue-system/preparing-jobs-for-queue Every job we push to queue is stored in som...

marek 2019-06-27 16:54 评论0 收藏0
laravel 队列

摘要：如果任务没有在规定时间内完成，那么该有序集合的任务将会被重新放入队列中。这两个进程操纵了三个队列，其中一个，负责即时任务，两个，负责延时任务与待处理任务。如果任务执行成功，就会删除中的任务，否则会被重新放入队列中。在实际的项目开发中，我们经常会遇到需要轻量级队列的情形，例如发短信、发邮件等，这些任务不足以使用 kafka、RabbitMQ 等重量级的消息队列，但是又的确需要异步、重试...

BDEEFE 2019-07-01 10:35 评论0 收藏0