<?php
/**
 * 操作redis类,基于Predis
 * @author  <[<1731223728@qq.com>]>
 * @date(2016-06-15)
 */

require __DIR__.'/predis/src/Autoloader.php';

\Predis\Autoloader::register();

/**
 * Redis缓存驱动 
 * 要求安装phpredis扩展：https://github.com/nicolasff/phpredis
 */
class MyPredis{
    
    //predis对象
    private $handler;

    //redis服务器状态默认开始
    // private $redis_status = 1;

    // 存储对象
    private static $moduleObj = array(); 

    public function __construct() {
        
        $this->handler = self::getPredisObj();
    }

    /**
     * [get_servers 获得redis服务器配置]
     * @return [type] [description]
     */
    public static function get_servers(){
        $options = array (
            'scheme' => 'tcp',
            'host'   => '127.0.0.1',
            'port'   => 6379,
        );
        return $options;
    }
    
    /**
     * 获取predis 单例
     * @return object
     */
    public static function getPredisObj(){
        if (empty(self::$moduleObj['predisObj']) || is_null(self::$moduleObj['predisObj'])){
            self::$moduleObj['predisObj'] = new Predis\Client(self::get_servers());;
        }
        return self::$moduleObj['predisObj'];
    }

    
    /**
     * 读取缓存
     * @access public
     * @param string $name 缓存变量名
     * @return mixed
     */
    public function get($name) {
        
        $value = $this->handler->get($name);
        $jsonData  = json_decode( $value, true );
        return ($jsonData === NULL) ? $value : $jsonData;   //检测是否为JSON数据 true 返回JSON解析数组, false返回源数据
    }

    /**
     * 写入缓存
     * @access public
     * @param string $name 缓存变量名
     * @param mixed $value  存储数据
     * @param integer $expire  有效时间（秒）
     * @return boolean
     */
    public function set($name, $value, $expire = null) {
        
        //对数组/对象数据进行缓存处理，保证数据完整性
        $value  =  (is_object($value) || is_array($value)) ? json_encode($value) : $value;
        if(is_int($expire) && $expire) {
            $result = $this->handler->setex($name, $expire, $value);
        }else{
            $result = $this->handler->set($name, $value);
        }
        
        return $result;
    }



    /**
     * 删除缓存
     * @access public
     * @param string $name 缓存变量名
     * @return boolean
     */
    public function del($name) {
        return $this->handler->del($name);
    }

    /**
     * 检查key值是否存在
     * @access public
     * @param string $name 缓存变量名
     * @return boolean
     */
    public function exists($name) {
        return $this->handler->exists($name);
    }

    /**
     * [get_status 获得redis服务器状态]
     * @return [type] [description]
     */
    public function get_redis_status(){
        return $this->redis_status;
    }

    /**
     * [set_status 设置redis服务器方法]
     */
    public function set_status(){
        $this->redis_status = 0;
    }

}