强烈推荐使用think-queue ,[传送门 ](https://blog.csdn.net/qq_34050360/article/details/116986237 "传送门 ")
一、安装Redis
二、修改Redis配置如下所示,并重启:
这里需要配置 notify-keyspace-events 的参数为 “Ex”。x 代表了过期事件。notify-keyspace-events “Ex” 保存配置后,重启Redis服务,使配置生效。
三、安装php的Redis扩展
四、在 \\think\\cache\\driver\\Redis() 添加几个方法,或者重新定义一个Redis方法:
~~~php
/*自定义Redis*/
public function setex($key, $time, $val)
{
return $this->handler->setex($key, $time, $val);
}
public function expire($key = null, $time = 0)
{
return $this->handler->expire($key, $time);
}
public function psubscribe($patterns = array(), $callback)
{
$this->handler->psubscribe($patterns, $callback);
}
public function setOption()
{
$this->handler->setOption(\Redis::OPT_READ_TIMEOUT, -1);
}
/*自定义Redis*/
~~~
![](data:image/gif;base64,R0lGODlhAQABAPABAP///wAAACH5BAEKAAAALAAAAAABAAEAAAICRAEAOw== "点击并拖拽以移动")
五、application\\command.php 新增一个
~~~php
<?php
return [
'app\api\controller\Gopush', //脚本推送进程常驻
];
~~~
![](data:image/gif;base64,R0lGODlhAQABAPABAP///wAAACH5BAEKAAAALAAAAAABAAEAAAICRAEAOw== "点击并拖拽以移动")
六、新建控制器 app\\api\\controller\\Gopush
~~~php
<?php
namespace app\api\controller;
use think\Controller;
use think\Request;
use think\console\Command;
use think\console\Input;
use think\console\Output;
class Gopush extends Command
{
protected function configure()
{
$this->setName('gopush')->setDescription('Here is the gopush');
}
protected function execute(Input $input, Output $output)
{
$redis = new \think\cache\driver\Redis();
$redis->setOption();
// $redis->psubscribe(array('__keyevent@0__:expired'), 'keyCallback');
$redis->psubscribe(array('__keyevent@0__:expired'), function ($redis, $pattern, $channel, $msg){
echo PHP_EOL;
echo "Pattern: $pattern\n";
echo "Channel: $channel\n";
echo "Payload: $msg\n\n";
//................
/*TODO处理业务逻辑*/
});
$output->writeln("TestCommand:998998998");
}
// public static function keyCallback($redis, $pattern, $chan, $msg)
// {
// echo "Pattern: $pattern\n";
// echo "Channel: $chan\n";
// echo "Payload: $msg\n\n";
// //keyCallback为订阅事件后的回调函数,这里写业务处理逻辑,
// //比如前面提到的商品不支付自动撤单,这里就可以根据订单id,来实现自动撤单
// }
}
~~~
![](data:image/gif;base64,R0lGODlhAQABAPABAP///wAAACH5BAEKAAAALAAAAAABAAEAAAICRAEAOw== "点击并拖拽以移动")
### 七、执行命令 php think gopush 让进程在终端运行(后面放到常驻进程里面去 supervisor),如下图所示 (**重点:每次修改了东西,守护进程要进行重启才有效**)(启动如果一直失败,就将启动用户改为root)
![](https://img-blog.csdnimg.cn/20201020162512685.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MDUwMzYw,size_16,color_FFFFFF,t_70)![](data:image/gif;base64,R0lGODlhAQABAPABAP///wAAACH5BAEKAAAALAAAAAABAAEAAAICRAEAOw== "点击并拖拽以移动")编辑
![](https://img-blog.csdnimg.cn/2020102015380388.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0MDUwMzYw,size_16,color_FFFFFF,t_70)![](data:image/gif;base64,R0lGODlhAQABAPABAP///wAAACH5BAEKAAAALAAAAAABAAEAAAICRAEAOw== "点击并拖拽以移动")编辑
八、触发方法:$key 可以用来做需要的内容数据拼接,时间可以根据订单倒计时算出来秒数,第三个参数只是备注
~~~php
/*这个格式去推送消息-用户设置的时候处理*/
public function r3(){
$re=new Redis();
$key='推送别名-内容ID-用户ID';
$re->setex($key,3,'redis延迟任务'); //3秒后回调
}
~~~
![](data:image/gif;base64,R0lGODlhAQABAPABAP///wAAACH5BAEKAAAALAAAAAABAAEAAAICRAEAOw== "点击并拖拽以移动")
九、thinkphp自定义命令 [自定义命令行 · ThinkPHP5.0完全开发手册 · 看云](https://www.kancloud.cn/manual/thinkphp5/235129 "自定义命令行 · ThinkPHP5.0完全开发手册 · 看云") 可以看着理解,很简单的
十、参考博客,都是原生的,最后还得封装,我都给你们封装好了
[参考地址一](https://blog.csdn.net/weixin_30535043/article/details/99357330?utm_medium=distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-1.channel_param&depth_1-utm_source=distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-1.channel_param "参考地址一")
[参考地址二](https://www.cnblogs.com/idjl/p/9610538.html "参考地址二")
[参考地址三](https://blog.csdn.net/jj546630576/article/details/80340573?utm_medium=distribute.pc_relevant_t0.none-task-blog-BlogCommendFromMachineLearnPai2-1.channel_param&depth_1-utm_source=distribute.pc_relevant_t0.none-task-blog-BlogCommendFromMachineLearnPai2-1.channel_param "参考地址三")
[参考地址四](https://blog.csdn.net/assasin0308/article/details/90261104?utm_medium=distribute.pc_relevant_t0.none-task-blog-BlogCommendFromMachineLearnPai2-1.channel_param&depth_1-utm_source=distribute.pc_relevant_t0.none-task-blog-BlogCommendFromMachineLearnPai2-1.channel_param "参考地址四")
[参考地址五](https://github.com/chenlinzhong/php-delayqueue "参考地址五")
[参考地址六](https://blog.csdn.net/weixin_30856965/article/details/96166152?utm_medium=distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-2.channel_param&depth_1-utm_source=distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-2.channel_param "参考地址六")
[参考地址七](https://blog.csdn.net/ligupeng7929/article/details/85206877?utm_medium=distribute.pc_relevant.none-task-blog-title-2&spm=1001.2101.3001.4242 "参考地址七")
十一、划重点
~~~php
/*$redis->psubscribe(array('__keyevent@'.$redis_db.'__:expired'), function ($redis, $pattern, $channel, $msg){
echo PHP_EOL;
echo "Pattern: $pattern\n";
echo "Channel: $channel\n";
echo "Payload: $msg\n\n";
//................
});*/
~~~
![](data:image/gif;base64,R0lGODlhAQABAPABAP///wAAACH5BAEKAAAALAAAAAABAAEAAAICRAEAOw== "点击并拖拽以移动")
点击链接加入群聊【ThinkPHP56小功能】:[正在跳转](https://jq.qq.com/?_wv=1027&k=Z0c641WP "正在跳转")
- 支付宝身份验证接口踩坑实录-PHP(基于ThinkPHP5)(第二版更新中)
- 抖音小程序开发之授权登录+支付宝支付+微信支付(ThinkPHP5-第三版修订中)
- TP5小知识点锦集(长期更新)
- PHP 二维码生成+识别
- 高德地图点聚合点击事件以及内容渲染
- ThinkPhP5使用phpexcle 导出数据(复制粘贴就可使用)
- Fastadmin微信小程序授权登录+获取手机号插件
- PHP -AES-128-CBC位加密解密
- PHP-Rsa分段加密解密(ThinkPHP5)
- PHP大转盘抽奖代码片段
- Fastadmin 项目上线关闭调试模式注意事项(记一次require-table.js修改事件)
- ThinkPHP5条件查询FIND_IN_SET正反使用
- ThinkPhP5整合微信小程序订阅消息
- think-queue处理延时任务事件
- ThinkPHP5 生成二维码
- Python3定时监控指定文件内容变换-(增加多行,遍历每行进行逻辑分析处理)
- Python3开发声光报警器监控触发报警
- ThinkPHP5下载文件流到本地
- 百度鹰眼抽轨迹集合稀算法&缩放比例调整显示静态图(ThinkPHP5)
- PHP 导出Excle
- Fastadmin 自定义Tab选项卡(B表的条件查询A表的数据,在A表里面加B表的参数作为选项卡)
- Fastadmin 修改url组件跳转为复制功能
- 微信H5分享好友跟朋友圈-基于Easywechat
- Python3抓取监控日志文件关键词跟内容变化修正版
- ThinkPHP5上传图片压缩处理-(解决IOS拍照上传旋转90度问题)最近更新2021年12月9日11:35:07
- 二维数组根据‘key’分组为新的三维数组
- ThinkPHP5 成功部署Workerman 运行示例
- Fastadmin框架TOKEN的使用
- ThinkPHP5 -微信小程序订阅消息开发-插件(插件基于fastadmin开发)
- ThinkPHP5-文本转义emoji表情
- ThinkPHP5 自定义命令行处理 监听Redis key失效触发回调事件,实现延迟任务 实现自动取消订单,自动完成订单
- Fastadmin插件Shopro商城里面短信插件修改为腾讯云短信插件步骤
- Fastadmin框架自定义搜索操作流程
- ThinkPHP5 处理 微信小程序内容安全审核
- Fastadmin自定义快捷搜索之模糊搜索关联他表
- php根据年月获取指定月份天数及日期数组的方法
- PHP构造函数使用校验token
- 基于ThinkPHP5&Redis腾讯云短信验证码注册登录基础业务逻辑代码整合
- ThinkPHP 解决跨域问题
- 支付宝沙箱环境测试支付(好久没做都忘了,写个博客比较省事)
- ThinkPHP5生成抖音小程序带参数二维码
- ThinkPHP5导入Excle-简单丝滑
- PHP生成带参数的小程序二维码
- ThinkPHP5成功调通IOS苹果支付
- swoole写聊天室,简单粗暴
- 微信小程序内容安全鉴别的时候,不成功因为没有转码
- Fastadmin 后台Excle文件上传(更新新增功能)
- Lnmp 配置thinkphp5 Nginx基础设置,包含http+https配置
- 通过经纬度获取数据库信息自动计算地址距离远近
- 二维数组根据某个字段排序
- PHP二维数组去重,最简单的方法
- TP5微信redis列队群发模板消息Sendmsg
- PHP检测是否关注公众号,亲测可用
- 小程序推广分享带参数二维码生成
- 基于ThinkPHP5微信H5授权登录获取用户信息(改进版)
- php过滤微信昵称中的表情
- Socket.io