主要原理
利用redis过期通知事件
1.redis配置
daemonize yes //守护进程
这里需要配置 notify-keyspace-events 的参数为 “Ex”。x 代表了过期事件
2.封装redis类
namespace app\common\service;
class MyRedis
{
private $redis;
public function __construct($host = '127.0.0.1', $port = 6379)
{
$this->redis = new \Redis();
$this->redis->connect($host, $port);
$this->setOption();
}
public function expire($key = null, $time = 0)
{
return $this->redis->expire($key, $time);
}
public function psubscribe($patterns = array(), $callback)
{
$this->redis->psubscribe($patterns, $callback);
}
public function setOption()
{
$this->redis->setOption(\Redis::OPT_READ_TIMEOUT, -1);
}
}
3.接受过期通知
这里用的是tp5的命令模式,框架如果支持命令模式会方便很多
#! /usr/local/php/bin/php
namespace app\api\command;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use app\common\model\Order;
use app\common\service\MyRedis;
class Test extends Command
{
protected function configure()
{
$this->setName('test')->setDescription('Here is the remark ');
}
protected function execute(Input $input, Output $output)
{
$redis = new MyRedis();
$redis->psubscribe(array('__keyevent@0__:expired'),
function ($redis, $pattern, $chan, $msg) use ($output) {
if ($pattern = '__keyevent@0__:expired' && $msg) {
$array = explode('_', $msg);
$function = $array['0'];
$this->$function($array['1']);
$output->writeln($msg);
}
});
}
/*
* 具体事件
*/
public function order($id)
{
$Order = Order::get($id);
$a=mt_rand(10000,99999);
$data['status'] = $a;
$Order->save($data);
}
}
4.把命令挂到后台一直去执行
nohup php /home/www/app/think test &
jobs #查看是否生效
ps aux | grep php #再看看也行
5.在需要的地方设置过期事件
setex order_1 5 chokingwin
然后就会自动触发order方法,参数是"_"后面的1
注意事项
如果代码修改过,记得kill掉 nohup,再启动一次
感谢chokingwin的文章
