ql-gw-laravel5/app/Common/RedisCluster.php

<?php
namespace App\Common;

/**
 * Redis 操作，支持 Master/Slave 的负载集群
 * 
 * @author jackluo
 */
class RedisCluster
{
    // 是否使用 M/S 的读写集群方案
    private $_isUseCluster = false;  
    
    // Slave 句柄标记
    private $_sn = 0;
    
    // 服务器连接句柄
    private $_linkHandle = array(
        'master'=>null,// 只支持一台 Master
        'slave'=>array(),// 可以有多台 Slave
    );
    
    /**
     * 构造函数
     * 
     * @param boolean $isUseCluster 是否采用 M/S 方案
     */
    public function __construct($isUseCluster=false)
    {
        $this->_isUseCluster = $isUseCluster;
    }
    
    /**
     * 连接服务器,注意：这里使用长连接，提高效率，但不会自动关闭
     * 
     * @param array $config Redis服务器配置
     * @param boolean $isMaster 当前添加的服务器是否为 Master 服务器
     * @return boolean
     */
    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;  
    }  
         
    /** 
     * 关闭连接 
     * 
     * @param int $flag 关闭选择 0:关闭 Master 1:关闭 Slave 2:关闭所有 
     * @return boolean 
     */  
    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;  
    }  
         
    /** 
     * 得到 Redis 原始对象可以有更多的操作 
     * 
     * @param boolean $isMaster 返回服务器的类型 true:返回Master false:返回Slave 
     * @param boolean $slaveOne 返回的Slave选择 true:负载均衡随机返回一个Slave选择 false:返回所有的Slave选择 
     * @return redis object 
     */  
    public function getRedis($isMaster=true,$slaveOne=true){  
        // 只返回 Master  
        if($isMaster){  
            return $this->_linkHandle['master'];  
        }else{  
            return $slaveOne ? $this->_getSlaveRedis() : $this->_linkHandle['slave'];  
        }  
    }  
         
    /** 
     * 写缓存 
     * 
     * @param string $key 组存KEY 
     * @param string $value 缓存值 
     * @param int $expire 过期时间， 0:表示无过期时间 
     */  
    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;  
    }  
         
    /** 
     * 读缓存 
     * 
     * @param string $key 缓存KEY,支持一次取多个 $key = array('key1','key2') 
     * @return string || boolean  失败返回 false, 成功返回字符串 
     */  
    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);  
    }  
      
   
/* 
    // magic function 
    public function __call($name,$arguments){ 
        return call_user_func($name,$arguments);     
    } 
*/  
    /** 
     * 条件形式设置缓存，如果 key 不存时就设置，存在时设置失败 
     * 
     * @param string $key 缓存KEY 
     * @param string $value 缓存值 
     * @return boolean 
     */  
    public function setnx($key, $value){  
        return $this->getRedis()->setnx($key, $value);  
    }  
         
    /** 
     * 删除缓存 
     * 
     * @param string || array $key 缓存KEY，支持单个健:"key1" 或多个健:array('key1','key2') 
     * @return int 删除的健的数量 
     */  
    public function remove($key){  
        // $key => "key1" || array('key1','key2')  
        return $this->getRedis()->delete($key);  
    }  
         
    /** 
     * 值加加操作,类似 ++$i ,如果 key 不存在时自动设置为 0 后进行加加操作 
     * 
     * @param string $key 缓存KEY 
     * @param int $default 操作时的默认值 
     * @return int　操作后的值 
     */  
    public function incr($key,$default=1){  
        if($default == 1){  
            return $this->getRedis()->incr($key);  
        }else{  
            return $this->getRedis()->incrBy($key, $default);  
        }  
    }  
         
    /** 
     * 值减减操作,类似 --$i ,如果 key 不存在时自动设置为 0 后进行减减操作 
     * 
     * @param string $key 缓存KEY 
     * @param int $default 操作时的默认值 
     * @return int　操作后的值 
     */  
    public function decr($key,$default=1){  
        if($default == 1){  
            return $this->getRedis()->decr($key);  
        }else{  
            return $this->getRedis()->decrBy($key, $default);  
        }  
    }  
         
    /** 
     * 添空当前数据库 
     * 
     * @return boolean 
     */  
    public function clear(){  
        return $this->getRedis()->flushDB();  
    }  
         
    /* =================== 以下私有方法 =================== */  
         
    /** 
     * 随机 HASH 得到 Redis Slave 服务器句柄 
     * 
     * @return redis object 
     */  
    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];  
    }  
         
    /** 
     * 根据ID得到 hash 后 0～m-1 之间的值 
     * 
     * @param string $id 
     * @param int $m 
     * @return int 
     */  
    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;
    }
    
    /**
     * lpush
     */
    public function lpush($key,$value)
    {
        return $this->getRedis()->lpush($key,$value);
    }
    
    /**
     * add lpop 
     */
    public function lpop($key)
    {  
        return $this->getRedis()->lpop($key);
    }
    
    /**
     * lrange
     */
    public function lrange($key,$start,$end)
    {
        return $this->getRedis()->lrange($key,$start,$end);
    }
    
    /**
     * set hash opeation
     */
    public function hset($name,$key,$value)
    {
        if(is_array($value))
        {
            return $this->getRedis()->hset($name,$key,serialize($value));
        }
        
        return $this->getRedis()->hset($name,$key,$value);
    }
    
    /**
     * get hash opeation
     */
    public function hget($name,$key = null,$serialize=true)
    {
        if($key)
        {
            $row = $this->getRedis()->hget($name,$key);
            if($row && $serialize)
            {
                unserialize($row);
            }
            
            return $row;
        }
        
        return $this->getRedis()->hgetAll($name);
    }
    
    /**
     * delete hash opeation 
     */  
    public function hdel($name,$key = null)
    {
        if($key)
        {
            return $this->getRedis()->hdel($name,$key);
        }
        
        return $this->getRedis()->hdel($name);
    }
    
    /**
     * Transaction start 
     */
    public function multi()
    {
        return $this->getRedis()->multi();
    }
    
    /**
     * Transaction send 
     */
    public function exec()
    {  
        return $this->getRedis()->exec();
    }
}// End Class  
         
// ================= TEST DEMO =================  
         
// 只有一台 Redis 的应用  
/* $redis = new RedisCluster();  
$redis->connect(array('host'=>'127.0.0.1','port'=>6379));  
  
  
//*  
$cron_id = 10001;  
$CRON_KEY = 'CRON_LIST'; //  
$PHONE_KEY = 'PHONE_LIST:'.$cron_id;//  
  
//cron info  
$cron = $redis->hget($CRON_KEY,$cron_id);  
if(empty($cron)){  
      
    $cron = array('id'=>10,'name'=>'jackluo');//mysql data  
    $redis->hset($CRON_KEY,$cron_id,$cron); // set redis      
}  
//phone list  
$phone_list = $redis->lrange($PHONE_KEY,0,-1);  
print_r($phone_list);  
if(empty($phone_list)){  
    $phone_list =explode(',','13228191831,18608041585');    //mysql data  
    //join  list  
    if($phone_list){  
        $redis->multi();  
        foreach ($phone_list as $phone) {  
            $redis->lpush($PHONE_KEY,$phone);              
        }  
        $redis->exec();  
    }  
}  
  
print_r($phone_list);  */ 
  
  
/*$list = $redis->hget($cron_list,);  
  
var_dump($list);*/  
//*/  
  
  
//$redis->set('id',35);  
  
/*  
    $redis->lpush('test','1111');  
    $redis->lpush('test','2222');  
    $redis->lpush('test','3333');  
  
    $list = $redis->lrange('test',0,-1);  
    print_r($list);  
    $lpop = $redis->lpop('test');  
    print_r($lpop);  
    $lpop = $redis->lpop('test');  
    print_r($lpop);  
    $lpop = $redis->lpop('test');  
    print_r($lpop);  
*/  
//    var_dump($redis->get('id'));