本篇文章主要给大家介绍reids 键空间通知配合tp5 实现分布式延时任务，希望对需要的朋友有所帮助！
测试环境：windows 10 + phpStudy
配置redis配置文件 redis.windows.conf
notify-keyspace-events "Ex"
重启redis服务
立即学习“PHP免费学习笔记（深入）”；
重新打开一个控制台窗口，执行命令
psubscribe __keyevent@0__:expired
打开新窗口执行了阻塞订阅操作后的终端，等会会有信息输出：
C:\Users\admin>redis-cli 127.0.0.1:6379> psubscribe __keyevent@0__:expired Reading messages... (press Ctrl-C to quit) 1) "psubscribe" 2) "__keyevent@0__:expired" 3) (integer) 1
再开启一个终端，redis-cli 进入 redis，新增一个 6秒过期的键 username：
命令行完成了
二、借助TP5.1 的命令行工具
命令行工具的使用：https://www.kancloud.cn/manual/thinkphp5_1/354146
1、新建命令行pay
setName('pay')
->addArgument('type', Argument::REQUIRED, "the type of the task that pay needs to run")
->setDescription('this is payment system command line tools');
}
// 执行指令
public function execute(Input $input, Output $output)
{
$type = $input->getArgument('type');
if ($type == 'psubscribe') {
// 发布订阅任务
$this->psubscribe();
}
}
/**
* Redis 发布订阅模式
*/
private function psubscribe()
{
$service = new RedisSubscribe();
$service->sub();
}
}2、编写脚本 RedisSubscribe.php
setOption(\Redis::OPT_READ_TIMEOUT, -1);
$redis->psubscribe(array('__keyevent@0__:expired'), function ($redis, $pattern, $chan, $msg) {
Log::error('[1]--过期事件的订阅 ' . $msg);
});
}
}说明：psubscribe( patterns,patterns,callback ) 方法的第二个参数为一个回调函数，这里我使用闭包作为一个回调。
官方解释：匿名函数（Anonymous functions），也叫闭包函数（closures），允许 临时创建一个没有指定名称的函数。最经常用作回调函数（callback）参数的值。当然，也有其它应用的情况。
3、在TP5 项目根目录执行pay 命令工具
php think pay psubscribe
4、新打开console 窗口终端
C:\Users\admin>redis-cli 127.0.0.1:6379> setex UserName 10 Tinywan OK 127.0.0.1:6379> get UserName "Tinywan" 127.0.0.1:6379> get UserName (nil) 127.0.0.1:6379>
5、查看打日志文件，看有没有接收到过期的key
6、最终的结果如下所示
更高级的慢慢扩展
1、自动取消订单
2、订单完成后发送短信
3、延迟任务等等
相关推荐：《PHP7教程》
