<?php
require_once dirname(__FILE__) . '/config/RedisConfig.php';

/**
 * Redis操作类
 */
class YMQOAuthTokenRedisHelper
{
   /**
    * redis对象
    * @var Redis
    */
    public $mRedis; 
       
   /**
    * 操作redis中的数据
    * 
    * @return void
    */
    public function __construct()
    {
        if (defined('YMQ_OAUTH_TOKEN_REDIS_HOST') && defined('YMQ_OAUTH_TOKEN_REDIS_PORT'))
        {
            $this->createConnect(YMQ_OAUTH_TOKEN_REDIS_HOST, YMQ_OAUTH_TOKEN_REDIS_PORT);
        }
    }
    
   /**
    * 析构函数
    * 
    * @return void
    */
    public function __destruct()
    {
        $this->disconnect();
    }
    
   /**
    * 创建连接
    * 
    * @param $host string 主机名
    * @param $port int 主机端口
    * @return boolen
    */
    public function createConnect($host,$port)
    {
        $re = false;
        try
        {
            $this->mRedis = new Redis();
            $this->mRedis->connect($host,$port);
            $re = true;
        } 
        catch (Exception $e) 
        {
            // TODO 创建 MQ 异常处理
        }
        return $re;
    }
    
   /**
    * 关闭连接
    * 
    * @return void
    */
    public function disconnect()
    {
        if (isset($this->mRedis))
        {
            @$this->mRedis->close();
        }
        unset($this->mRedis);
    }
}