Laravel中使用Queue的最基本操作教程

前言

laravel中的队列服务跟其他队列服务也没有什么不同，都是最符合人类思维的最简单最普遍的流程：有一个地方存放队列信息，一个PHP进程在运行时将任务写入，另外一个PHP守护进程轮询队列信息，将达到执行要求的任务执行并删除。由于PHP是url驱动的同步语言，本身是阻塞的，所以laravel提供一个守护进程工具来查询并执行队列信息也就不足为奇了。

这两天初次接触 Laravel 的队列，也是搞了好一会。。。一番折腾下来还是感慨对 Laravel 不得其门，文档写的相对简单和概括，看源码又有些力不从心（不过看源码慢慢调试验证还是最可靠的）。

下面是我的一个简单 Demo，仅仅使用了队列的最基本操作，偏高级的操作需要再去好好时间一番 :)

和我一样入门 Laravel 的队列有些困难的同学可以交流一下。

配置

添加 Redis 包

在 composer.json 中 require 部分加入 "predis/predis": "~1.0",，然后 composer up 更新一下即可。

database.php

在 database.php 配置文件中对 redis 数据库部分进行配置，默认有一个 default 连接，就用这个好了:)

根据这个默认连接中需要的配置项，编辑 .env 配置文件，将其中的 REDIS_HOST、REDIS_PASSWORD、REDIS_PORT 填写成自己服务器中 Redis 的相应值。

queue.php

首先需要去 .env 中配置 QUEUE_DRIVER，因为现在打算用 Redis，所以配置成 redis。

接着配置 queue.php 里 connections 部分的 redis 连接，其中 connection 对应的值就是 database.php 中 redis 的那个 default 连接。

任务类

接下来就是写实际的操作类了，Laravel 提供了 artisan 命令简化创建任务类：

php artisan make:job Demo

在 app 目录下会生成 Jobs 目录，里面已经有了 Demo.php 任务类。

Lumen 可没有这个 artisan 命令，不过也很方便，默认会有一个 ExampleJob.php 已经写好了，拷贝一份改个名字即可。
先写个简单的日志输出测试一下好了，在 handle 方法中：

Log::info('Hello, queue');

发放任务

现在写个入口函数，推送任务到队列中。使用辅助函数 dispatch()：

Laravel 中使用如下方式：

Demo::dispatch();

Lumen 中使用如下方式：

dispatch(new Demo);

开启队列

顺利的话，这是最后一步了。命令行中执行：

php artisan queue:listen --queue=default

它会监听队列，并输出简单的执行情况，比如：

[2017-11-07 02:12:47] Processing: App/Jobs/Demo[2017-11-07 02:12:47] Processed: App/Jobs/Demo

没啥问题后就可以让这个队列脚本执行在后台：