延迟队列，首先它是一个队列。然后其任务可以延迟被执行。
实现队列，以及延迟队列的方式有很多种，基于Redis的方式也是比较常见，并且实现方式也比较简单。
通过三篇文章，分析基于Laravel框架实现Redis的延迟队列
第一篇： 依据官网介绍，实现一个简单的Redis延迟队列
第二篇：添加队列任务的源码分析
第三篇：监听队列的源码分析，即消费的源码分析
依据官网介绍，实现一个简单的Redis延迟队列功能
确保当前已经部署好运行Laravel5.8版本的lnmp以及redis环境，根据官网内容，配置并创建一个基于Redis的延迟队列
1. 配置.env文件
省略其他配置，这里配置Redis的host，password，port为自己的配置，暂时添加一个REDIS_PREFIX=为空
REDIS_HOST=172.17.0.4
REDIS_PASSWORD=null
REDIS_PORT=6379
REDIS_PREFIX=
QUEUE_CONNECTION=redis # 指定queue的默认服务为redis
config/queue.php配置队列
'redis' => [
'driver' => 'redis',
'connection' => 'default',
'queue' => env('REDIS_QUEUE', 'default'),
'retry_after' => 90,
'block_for' => null,
],
ps：默认当前已启动Redis服务
2. 创建一个Job任务
通过artisan命令创建一个SendEmailJob.php脚本命令：php artisan make:job SendEmailJob
执行完成之后，会在app/Jobs目录下，创建一个SendEmailJob.php脚本
修改脚本app/Jobs/SendEmailJob.php如下：
<?php
namespace App\Jobs;
use Carbon\Carbon;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
class SendEmailJob implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
public function __construct()
{
//
}
public function handle()
{
$nowStr = Carbon::now()->toDateTimeString();
$res = sprintf('Successful email delivery: %s', $nowStr);
echo $res;
}
}
3. 创建控制器
通过artisan命令创建一个控制器：php artisan make:controller Blog/QueueController
修改app/Http/Controllers/Blog/QueueController.php代码如下：
<?php
namespace App\Http\Controllers\Blog;
use App\Jobs\SendEmailJob;
use Carbon\Carbon;
use Illuminate\Http\Request;
use App\Http\Controllers\Controller;
class QueueController extends Controller
{
public function send(Request $request)
{
$nowStr = Carbon::now()->toDateTimeString();
$res = sprintf('Starting email delivery: %s', $nowStr);
SendEmailJob::dispatch()->delay(now()->addSeconds(20));
dd($res);
}
}
send方法就是延迟20s执行SendEmailJob任务
4. 修改路由
编辑 routes/web.php代码如下:
<?php
Route::get('/blog/send', 'Blog\QueueController@send');
5. 命令行打开一个Redis客户端
root@9c8ee64d2bc6:/data# redis-cli
127.0.0.1:6379> keys *
(empty list or set)
127.0.0.1:6379>
当前Redis中，暂无任何内容
6. 监听队列
通过执行artisan命令：php artisan queue:work持续监听队列，没有加任务参数，默认使用config/queue.php中的'default' => env('QUEUE_CONNECTION', 'sync'),已在.env中配置了QUEUE_CONNECTION为redis。
7. 运行http://localhost/blog/send
显示当前时间为2019-10-03 10:47:12
8. 通过redis-cli查看
运行完http://localhost/blog/send](http://localhost/blog/send之后，查看redis中存在一个key为queues:default:delayed的zset类型的数据，值为SendEmailJob对象序列化后的值
score的值为延迟后的时间戳1570070852，日期格式为2019-10-03 10:47:32
9. 查看任务队列的监听
显示当前执行时间为2019-10-03 10:47:33，忽略其他耗时～
10. 再次通过redis-cli查看reds的内容
127.0.0.1:6379> keys *
(empty list or set)
127.0.0.1:6379>
可见，之前的任务已被消费，并从redis中删除
至此，已经实现了一个基于Redis的延迟队列，有任何问题或建议，欢迎评论～
