在php中實現Redis的訂閱與發布

<?php
//require_once dirname(__FILE__).'/class/RedisClass.class.php';


function init_redis(){
   $redis = new Redis();
   $redis->connect('127.0.0.1','6379');
   return $redis;
}
//鍵值過期是通知
function psubscribe($callback){
   $redis = init_redis();
   $redis->psubscribe(array('__keyevent@*__:expired'),$callback);
}

//訂閱頻道
function subscribe($callback){
   $redis = init_redis();
   $redis->subscribe(array('sunsun'),$callback);
}
//鍵值過期的回調函數
function redisCallback($redis, $pattern, $channel, $message)
{
    var_dump($redis);
    var_dump($pattern);
    var_dump($channel);
    var_dump($message);
}
//訂閱的回調函數
function redisCallbacks($redis, $channel, $message)
{
    var_dump($redis);
    var_dump($channel);
    var_dump($message);
}
psubscribe('redisCallback');
subscribe('redisCallbacks');