PHPnbsp;操作redisnbsp;封装的类…

转的　http://www.yiibase.com/server/view/411.html　

php



class RedisCluster{
   
      
   // 是否使用 M/S 的读写集群方案
   private $_isUseCluster = false;
      
   // Slave 句柄标记
   private $_sn = 0;
      
   // 服务器连接句柄
   private $_linkHandle = array(
       'master'=>null,// 只支持一台 Master
       'slave'=>array(),// 可以有多台 Slave
   );
      
   
   public function __construct($isUseCluster=false){
   
       $this->_isUseCluster = $isUseCluster;
   }
      
   
   public function connect($config=array('host'=>'127.0.0.1','port'=>6379), $isMaster=true){
   
       // default port
       if(!isset($config['port'])){
   
           $config['port'] = 6379;
       }
       // 设置 Master 连接
       if($isMaster){
   
           $this->_linkHandle['master'] = new Redis();
           $ret = $this->_linkHandle['master']->pconnect($config['host'],$config['port']);
       }else{
   
           // 多个 Slave 连接
           $this->_linkHandle['slave'][$this->_sn] = new Redis();
           $ret = $this->_linkHandle['slave'][$this->_sn]->pconnect($config['host'],$config['port']);
           ++$this->_sn;
       }
       return $ret;
   }
      
   
   public function close($flag=2){
   
       switch($flag){
   
           // 关闭 Master
           case 0:
               $this->getRedis()->close();
           break;
           // 关闭 Slave
           case 1:
               for($i=0; $i<$this->_sn; ++$i){
   
                   $this->_linkHandle['slave'][$i]->close();
               }
           break;
           // 关闭所有
           case 1:
               $this->getRedis()->close();
               for($i=0; $i<$this->_sn; ++$i){
   
                   $this->_linkHandle['slave'][$i]->close();
               }
           break;
       }
       return true;
   }
      
   
   public function getRedis($isMaster=true,$slaveOne=true){
   
       // 只返回 Master
       if($isMaster){
   
           return $this->_linkHandle['master'];
       }else{
   
           return $slaveOne ? $this->_getSlaveRedis() : $this->_linkHandle['slave'];
       }
   }
      
   
   public function set($key, $value, $expire=0){
   
       // 永不超时
       if($expire == 0){
   
           $ret = $this->getRedis()->set($key, $value);
       }else{
   
           $ret = $this->getRedis()->setex($key, $expire, $value);
       }
       return $ret;
   }
      
   
   public function get($key){
   
       // 是否一次取多个值
       $func = is_array($key) ? 'mGet' : 'get';
       // 没有使用M/S
       if(! $this->_isUseCluster){
   
           return $this->getRedis()->{$func}($key);
       }
       // 使用了 M/S
       return $this->_getSlaveRedis()->{$func}($key);
   }
      
   
   public function setnx($key, $value){
   
       return $this->getRedis()->setnx($key, $value);
   }
      
   
   public function remove($key){
   
       // $key => "key1" || array('key1','key2')
       return $this->getRedis()->delete($key);
   }
      
   
   public function incr($key,$default=1){
   
       if($default == 1){
   
           return $this->getRedis()->incr($key);
       }else{
   
           return $this->getRedis()->incrBy($key, $default);
       }
   }
      
   
   public function decr($key,$default=1){
   
       if($default == 1){
   
           return $this->getRedis()->decr($key);
       }else{
   
           return $this->getRedis()->decrBy($key, $default);
       }
   }
      
   
   public function clear(){
   
       return $this->getRedis()->flushDB();
   }
      
   
      
   
   private function _getSlaveRedis(){
   
       // 就一台 Slave 机直接返回
       if($this->_sn <= 1){
   
           return $this->_linkHandle['slave'][0];
       }
       // 随机 Hash 得到 Slave 的句柄
       $hash = $this->_hashId(mt_rand(), $this->_sn);
       return $this->_linkHandle['slave'][$hash];
   }
      
   
   private function _hashId($id,$m=10)
   {
   
       //把字符串K转换为 0～m-1 之间的一个值作为对应记录的散列地址
       $k = md5($id);
       $l = strlen($k);
       $b = bin2hex($k);
       $h = 0;
       for($i=0;$i<$l;$i++)
       {
   
           //相加模式HASH
           $h += substr($b,$i*2,2);
       }
       $hash = ($h*1)%$m;
       return $hash;
   }
      

}// End Class
      

// ================= TEST DEMO =================
      

// 只有一台 Redis 的应用

$redis = new RedisCluster();

$redis->connect(array('host'=>'127.0.0.1','port'=>6379));

$redis->set('id',35);

var_dump($redis->get('id'));
      
      

// 有一台 Master 和 多台Slave 的集群应用

$redis = new RedisCluster(true);

$redis->connect(array('host'=>'127.0.0.1','port'=>6379), true);// master

$redis->connect(array('host'=>'127.0.0.1','port'=>63791), false);// slave 1

$redis->connect(array('host'=>'127.0.0.1','port'=>63792), false);// slave 2

$redis->set('id',100);

for($i=1; $i<=100; ++$i){
   
   var_dump($redis->get('id')).PHP_EOL;

}
      

// phpRedis 扩展的更多高级操作

$redis = new RedisCluster();

$redis->connect(array('host'=>'127.0.0.1','port'=>6379));

$ret = $redis->getRedis()->ping();// phpRedis 原始API

var_dump($ret);