Redis Client，单例

php代码

<?php  //if(!defined('BASEPATH')) exit('No direct script access allowed...');

/**
 * ---------------- redis.conf.php ------------------
 * $redis_conf = array();
 * $redis_conf['master'] = array();;
 * $redis_conf['master']['host'] = '127.0.0.1';
 * $redis_conf['master']['port'] = 6379;
 * $redis_conf['master']['passwd'] = '';
 * $redis_conf['master']['timeout'] = 1;
 * ---------------- author:  simon ------------------
 */

/**
 * Redis Client Interface
 *
 * ------------------- Usage ---------------------
 * $conf_dir = __DIR__ .'/../conf/redis.conf.php';
 * $redis = RedisCli::getInstance($conf_dir, 'master');
 * $ret = $redis->set('xxxxx', 'good');
 * $ret = $redis->get('xxxxx');
 *
 */

class RedisCli {
	private static $_instance = array();
	private $_redis = false;
	
	/**
	 * 单例模型，构造函数
	 */
	public static function getInstance($conf_dir='/xxx/redis.conf.php', $serverName='master') {
		if (isset(self::$_instance[$serverName])) {
			return self::$_instance[$serverName];
		}
		require_once($conf_dir);
		if (!isset($redis_conf[$serverName])) {
			throw new Exception("param serverName Or redis config error...");
		}
		$conf = $redis_conf[$serverName];
		if (!class_exists('Redis')) {
			throw new Exception("Class Redis not exists, please install the php Redis extension...");
		}
		if (isset($conf['host']) && isset($conf['port']) && isset($conf['passwd']) && isset($conf['timeout'])) {
			self::$_instance[$serverName] = new self($conf['host'], $conf['port'], $conf['passwd'], $conf['timeout']);
			return self::$_instance[$serverName];
		}
		return false;
	}

	/**
	 *  私有, 单例模型，禁止外部构造
	 */
	private function __construct($host, $port, $passwd, $timeout) {
		$this->_redis = new Redis();
		if ($this->_redis->connect($host, $port, $timeout)) {
			if (!empty($passwd)) {
				$this->_redis->auth($passwd);
			}
		}
	}

	/**
	 *  私有, 单例模型，禁止克隆
	 */
	private function __clone() {
	}

    /**
	 *  公有，调用对象函数
	 */
	public function __call($method, $args) {
		if (!$this->_redis || !$method) {
			return false;
		}
		if (!method_exists($this->_redis, $method)) {
			throw new Exception("Class RedisCli not have method ($method) ");
		}
		return call_user_func_array(array($this->_redis, $method), $args);
	}
}

?>

登录后复制