Laravel源码分析|Laravel源码分析 - Redis延迟队列(一)
延迟队列，首先它是一个队列。然后其任务可以延迟被执行。依据官网介绍，实现一个简单的Redis延迟队列功能 确保当前已经部署好运行Laravel5.8版本的lnmp以及redis环境，根据官网内容，配置并创建一个基于Redis的延迟队列
实现队列，以及延迟队列的方式有很多种，基于Redis的方式也是比较常见，并且实现方式也比较简单。
通过三篇文章，分析基于Laravel框架实现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如下：toDateTimeString();
$res = sprintf('Successful email delivery: %s', $nowStr);
echo $res;
}
}
3. 创建控制器 通过artisan命令创建一个控制器：
php artisan make:controller Blog/QueueController修改
app/Http/Controllers/Blog/QueueController.php代码如下：toDateTimeString();
$res = sprintf('Starting email delivery: %s', $nowStr);
SendEmailJob::dispatch()->delay(now()->addSeconds(20));
dd($res);
}
}send方法就是延迟20s执行SendEmailJob任务
4. 修改路由 编辑
routes/web.php代码如下: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
文章图片
执行任务
【Laravel源码分析|Laravel源码分析 - Redis延迟队列(一)】显示当前时间为2019-10-03 10:47:12
8. 通过redis-cli查看 运行完http://localhost/blog/send](http://localhost/blog/send之后，查看redis中存在一个key为
queues:default:delayed的zset类型的数据，值为SendEmailJob对象序列化后的值
文章图片
SendEmailJob对象序列化
score的值为延迟后的时间戳1570070852，日期格式为2019-10-03 10:47:32
9. 查看任务队列的监听
文章图片
20s之后执行
显示当前执行时间为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的延迟队列，有任何问题或建议，欢迎评论～
推荐阅读
- 如何寻找情感问答App的分析切入点
- D13|D13 张贇 Banner分析
- 自媒体形势分析
- 2020-12(完成事项)
- Android事件传递源码分析
- Python数据分析(一)（Matplotlib使用）
- Quartz|Quartz 源码解析(四) —— QuartzScheduler和Listener事件监听
- 泽宇读书会——如何阅读一本书笔记
- Java内存泄漏分析系列之二（jstack生成的Thread|Java内存泄漏分析系列之二：jstack生成的Thread Dump日志结构解析）
- [源码解析]|[源码解析] NVIDIA HugeCTR，GPU版本参数服务器---(3)