<?php
require_once dirname(__FILE__).'/config/RedisConfig.php';
/**
* 操作redis中的数据
* @author       dan.shen
*/
class YMQLoggerRedisHelper
{
    
    /**
    * redis对象
    * @var      Redis
    */
    public $mRedis;    
    /**
    * 操作redis中的数据
    * @return   void
    */
    public function __construct()
    {
        if(defined('YMQ_LOGGER_REDIS_HOST') && defined('YMQ_LOGGER_REDIS_PORT'))
        {
           $this->createConnect(YMQ_LOGGER_REDIS_HOST,YMQ_LOGGER_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 创建 UserOnline MQ 异常处理
        }
        return $re;
    }
    
    /**
    * 关闭连接
    * @return   void
    */
    public function disconnect()
    {
        if(isset($this->mRedis))
        {
            @$this->mRedis->close();
        }
        unset($this->mRedis);
    }
}

?>