redis發布訂閱實現各類定時業務（優惠券過期，商品不支付自動撤單，自動收貨等）

修改redis配置文件
找到機器上redis配置文件conf/redis.conf，新增一行  notify-keyspace-events Ex

最后的Ex代表 監聽失效的鍵值

 

修改后效果如下圖

代碼效果：

redis.class.php類：（這里避免命名沖突，故命名Redis2）

<?php
class Redis2
{
private $redis;

public function __construct($host = '127.0.0.1', $port = 6379)
{
$this->redis = new Redis();
$this->redis->connect($host, $port);
}

public function setex($key, $time, $val)
{
return $this->redis->setex($key, $time, $val);
}

public function set($key, $val)
{
return $this->redis->set($key, $val);
}

public function get($key)
{
return $this->redis->get($key);
}

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);
}

}

psubscribe.php

<?php
require_once './Redis.class.php';
$redis = new \Redis2();
// 解決Redis客戶端訂閱時候超時情況
$redis->psubscribe(array('__keyevent@0__:expired'), 'keyCallback');
// 回調函數,這里寫處理邏輯
function keyCallback($redis, $pattern, $chan, $msg)
{
    echo "Pattern: $pattern\n";
    echo "Channel: $chan\n";
    echo "Payload: $msg\n\n";
    //keyCallback為訂閱事件后的回調函數，這里寫業務處理邏輯，
    //比如前面提到的商品不支付自動撤單，這里就可以根據訂單id,來實現自動撤單
}

index.php

<?php
require_once './Redis.class.php';
$redis = new \Redis2();
$order_id = 123;
//設置一個時間為10秒的redis值
$redis->setex('order_id',10,$order_id);