PHP redis库

2017-09-13 08:13:27来源:CSDN作者:ucmir183人点击

分享
<?phpnamespace app/api/server;/** * redis操作类 * 说明,任何为false的串,存在redis中都是空串。 * 只有在key不存在时,才会返回false。 * 这点可用于防止缓存穿透 * */class RedisServer{    private $redis;    //当前数据库ID号    protected $dbId=0;    //当前权限认证码    protected $auth;    /**     * 实例化的对象,单例模式.     * @var /iphp/db/Redis     */    static private $_instance=array();    private  $k;    //连接属性数组    protected $attr=array(        //连接超时时间,redis配置文件中默认为300秒        'timeout'=>30,        //选择的数据库。        'db_id'=>0,    );    //什么时候重新建立连接    protected $expireTime;    protected $host;    protected $port;    private function __construct($config,$attr=array())    {        $this->attr        =    array_merge($this->attr,$attr);        $this->redis    =    new /Redis();        $this->port        =    isset($config['port']) ? $config['port'] : 6379;        $this->host        =    $config['host'];        $this->redis->connect($this->host, $this->port, $this->attr['timeout']);        if(isset($config['auth']))        {            $this->auth($config['auth']);            $this->auth    =    $config['auth'];        }        $this->expireTime    =    time() + $this->attr['timeout'];    }    /**     * 得到实例化的对象.     * 为每个数据库建立一个连接     * 如果连接超时,将会重新建立一个连接     * @param array $config     * @param int $dbId     * @return RedisServer     */    public static function getInstance($config, $attr = array())    {        //如果是一个字符串,将其认为是数据库的ID号。以简化写法。        if(!is_array($attr))        {            $dbId    =    $attr;            $attr    =    array();            $attr['db_id']    =    $dbId;        }        $attr['db_id']    =   isset($attr['db_id']) ? $attr['db_id'] : 0;        $k    =    md5(implode('', $config).$attr['db_id']);        static::$_instance[$k] = isset(static::$_instance[$k])?static::$_instance[$k]:[];        if(! (static::$_instance[$k] instanceof self))        {            static::$_instance[$k] = new self($config,$attr);            static::$_instance[$k]->k        =    $k;            static::$_instance[$k]->dbId    =    $attr['db_id'];            //如果不是0号库,选择一下数据库。            if($attr['db_id'] != 0){                static::$_instance[$k]->select($attr['db_id']);            }        }        elseif( time() > static::$_instance[$k]->expireTime)        {            static::$_instance[$k]->close();            static::$_instance[$k]         =     new self($config,$attr);            static::$_instance[$k]->k    =    $k;            static::$_instance[$k]->dbId=    $attr['db_id'];            //如果不是0号库,选择一下数据库。            if($attr['db_id']!=0){                static::$_instance[$k]->select($attr['db_id']);            }        }        return static::$_instance[$k];    }    private function __clone(){}    /**     * 执行原生的redis操作     * @return /Redis     */    public function getRedis()    {        return $this->redis;    }    /*****************hash表操作函数*******************/    /**     * 得到hash表中一个字段的值     * @param string $key 缓存key     * @param string  $field 字段     * @return string|false     */    public function hGet($key,$field)    {        return $this->redis->hGet($key,$field);    }    /**     * 为hash表设定一个字段的值     * @param string $key 缓存key     * @param string  $field 字段     * @param string $value 值。     * @return bool     */    public function hSet($key,$field,$value)    {        return $this->redis->hSet($key,$field,$value);    }    /**     * 判断hash表中,指定field是不是存在     * @param string $key 缓存key     * @param string  $field 字段     * @return bool     */    public function hExists($key,$field)    {        return $this->redis->hExists($key,$field);    }    /**     * 删除hash表中指定字段 ,支持批量删除     * @param string $key 缓存key     * @param string  $field 字段     * @return int     */    public function hdel($key,$field)    {        $fieldArr=explode(',',$field);        $delNum=0;        foreach($fieldArr as $row)        {            $row=trim($row);            $delNum+=$this->redis->hDel($key,$row);        }        return $delNum;    }    /**     * 返回hash表元素个数     * @param string $key 缓存key     * @return int|bool     */    public function hLen($key)    {        return $this->redis->hLen($key);    }    /**     * 为hash表设定一个字段的值,如果字段存在,返回false     * @param string $key 缓存key     * @param string  $field 字段     * @param string $value 值。     * @return bool     */    public function hSetNx($key,$field,$value)    {        return $this->redis->hSetNx($key,$field,$value);    }    /**     * 为hash表多个字段设定值。     * @param string $key     * @param array $value     * @return array|bool     */    public function hMset($key,$value)    {        if(!is_array($value))            return false;        return $this->redis->hMset($key,$value);    }    /**     * 为hash表多个字段设定值。     * @param string $key     * @param array|string $value string以','号分隔字段     * @return array|bool     */    public function hMget($key,$field)    {        if(!is_array($field))            $field=explode(',', $field);        return $this->redis->hMget($key,$field);    }    /**     * 为hash表设这累加,可以负数     * @param string $key     * @param int $field     * @param string $value     * @return bool     */    public function hIncrBy($key,$field,$value)    {        $value=intval($value);        return $this->redis->hIncrBy($key,$field,$value);    }    /**     * 返回所有hash表的所有字段     * @param string $key     * @return array|bool     */    public function hKeys($key)    {        return $this->redis->hKeys($key);    }    /**     * 返回所有hash表的字段值,为一个索引数组     * @param string $key     * @return array|bool     */    public function hVals($key)    {        return $this->redis->hVals($key);    }    /**     * 返回所有hash表的字段值,为一个关联数组     * @param string $key     * @return array|bool     */    public function hGetAll($key)    {        return $this->redis->hGetAll($key);    }    /*********************有序集合操作*********************/    /**     * 给当前集合添加一个元素     * 如果value已经存在,会更新order的值。     * @param string $key     * @param string $order 序号     * @param string $value 值     * @return bool     */    public function zAdd($key,$order,$value)    {        return $this->redis->zAdd($key,$order,$value);    }    /**     * 给$value成员的order值,增加$num,可以为负数     * @param string $key     * @param string $num 序号     * @param string $value 值     * @return 返回新的order     */    public function zinCry($key,$num,$value)    {        return $this->redis->zinCry($key,$num,$value);    }    /**     * 删除值为value的元素     * @param string $key     * @param stirng $value     * @return bool     */    public function zRem($key,$value)    {        return $this->redis->zRem($key,$value);    }    /**     * 集合以order递增排列后,0表示第一个元素,-1表示最后一个元素     * @param string $key     * @param int $start     * @param int $end     * @return array|bool     */    public function zRange($key,$start,$end)    {        return $this->redis->zRange($key,$start,$end);    }    /**     * 集合以order递减排列后,0表示第一个元素,-1表示最后一个元素     * @param string $key     * @param int $start     * @param int $end     * @return array|bool     */    public function zRevRange($key,$start,$end)    {        return $this->redis->zRevRange($key,$start,$end);    }    /**     * 集合以order递增排列后,返回指定order之间的元素。     * min和max可以是-inf和+inf 表示最大值,最小值     * @param string $key     * @param int $start     * @param int $end     * @package array $option 参数     *     withscores=>true,表示数组下标为Order值,默认返回索引数组     *     limit=>array(0,1) 表示从0开始,取一条记录。     * @return array|bool     */    public function zRangeByScore($key,$start='-inf',$end="+inf",$option=array())    {        return $this->redis->zRangeByScore($key,$start,$end,$option);    }    /**     * 集合以order递减排列后,返回指定order之间的元素。     * min和max可以是-inf和+inf 表示最大值,最小值     * @param string $key     * @param int $start     * @param int $end     * @package array $option 参数     *     withscores=>true,表示数组下标为Order值,默认返回索引数组     *     limit=>array(0,1) 表示从0开始,取一条记录。     * @return array|bool     */    public function zRevRangeByScore($key,$start='-inf',$end="+inf",$option=array())    {        return $this->redis->zRevRangeByScore($key,$start,$end,$option);    }    /**     * 返回order值在start end之间的数量     * @param unknown $key     * @param unknown $start     * @param unknown $end     */    public function zCount($key,$start,$end)    {        return $this->redis->zCount($key,$start,$end);    }    /**     * 返回值为value的order值     * @param unknown $key     * @param unknown $value     */    public function zScore($key,$value)    {        return $this->redis->zScore($key,$value);    }    /**     * 返回集合以score递增加排序后,指定成员的排序号,从0开始。     * @param unknown $key     * @param unknown $value     */    public function zRank($key,$value)    {        return $this->redis->zRank($key,$value);    }    /**     * 返回集合以score递增加排序后,指定成员的排序号,从0开始。     * @param unknown $key     * @param unknown $value     */    public function zRevRank($key,$value)    {        return $this->redis->zRevRank($key,$value);    }    /**     * 删除集合中,score值在start end之间的元素 包括start end     * min和max可以是-inf和+inf 表示最大值,最小值     * @param unknown $key     * @param unknown $start     * @param unknown $end     * @return 删除成员的数量。     */    public function zRemRangeByScore($key,$start,$end)    {        return $this->redis->zRemRangeByScore($key,$start,$end);    }    /**     * 返回集合元素个数。     * @param unknown $key     */    public function zCard($key)    {        return $this->redis->zCard($key);    }    /*********************队列操作命令************************/    /**     * 在队列尾部插入一个元素     * @param unknown $key     * @param unknown $value     * 返回队列长度     */    public function rPush($key,$value)    {        return $this->redis->rPush($key,$value);    }    /**     * 在队列尾部插入一个元素 如果key不存在,什么也不做     * @param unknown $key     * @param unknown $value     * 返回队列长度     */    public function rPushx($key,$value)    {        return $this->redis->rPushx($key,$value);    }    /**     * 在队列头部插入一个元素     * @param unknown $key     * @param unknown $value     * 返回队列长度     */    public function lPush($key,$value)    {        return $this->redis->lPush($key,$value);    }    /**     * 在队列头插入一个元素 如果key不存在,什么也不做     * @param unknown $key     * @param unknown $value     * 返回队列长度     */    public function lPushx($key,$value)    {        return $this->redis->lPushx($key,$value);    }    /**     * 返回队列长度     * @param unknown $key     */    public function lLen($key)    {        return $this->redis->lLen($key);    }    /**     * 返回队列指定区间的元素     * @param unknown $key     * @param unknown $start     * @param unknown $end     */    public function lRange($key,$start,$end)    {        return $this->redis->lrange($key,$start,$end);    }    /**     * 返回队列中指定索引的元素     * @param unknown $key     * @param unknown $index     */    public function lIndex($key,$index)    {        return $this->redis->lIndex($key,$index);    }    /**     * 设定队列中指定index的值。     * @param unknown $key     * @param unknown $index     * @param unknown $value     */    public function lSet($key,$index,$value)    {        return $this->redis->lSet($key,$index,$value);    }    /**     * 删除值为vaule的count个元素     * PHP-REDIS扩展的数据顺序与命令的顺序不太一样,不知道是不是bug     * count>0 从尾部开始     *  >0 从头部开始     *  =0 删除全部     * @param unknown $key     * @param unknown $count     * @param unknown $value     */    public function lRem($key,$count,$value)    {        return $this->redis->lRem($key,$value,$count);    }    /**     * 删除并返回队列中的头元素。     * @param unknown $key     */    public function lPop($key)    {        return $this->redis->lPop($key);    }    /**     * 删除并返回队列中的尾元素     * @param unknown $key     */    public function rPop($key)    {        return $this->redis->rPop($key);    }    /*************redis字符串操作命令*****************/    /**     * 设置一个key     * @param unknown $key     * @param unknown $value     */    public function set($key,$value)    {        return $this->redis->set($key,$value);    }    /**     * 得到一个key     * @param unknown $key     */    public function get($key)    {        return $this->redis->get($key);    }    /**     * 设置一个有过期时间的key     * @param unknown $key     * @param unknown $expire     * @param unknown $value     */    public function setex($key,$expire,$value)    {        return $this->redis->setex($key,$expire,$value);    }    /**     * 设置一个key,如果key存在,不做任何操作.     * @param unknown $key     * @param unknown $value     */    public function setnx($key,$value)    {        return $this->redis->setnx($key,$value);    }    /**     * 批量设置key     * @param unknown $arr     */    public function mset($arr)    {        return $this->redis->mset($arr);    }    /*************redis 无序集合操作命令*****************/    /**     * 返回集合中所有元素     * @param unknown $key     */    public function sMembers($key)    {        return $this->redis->sMembers($key);    }    /**     * 求2个集合的差集     * @param unknown $key1     * @param unknown $key2     */    public function sDiff($key1,$key2)    {        return $this->redis->sDiff($key1,$key2);    }    /**     * 添加集合。由于版本问题,扩展不支持批量添加。这里做了封装     * @param unknown $key     * @param string|array $value     */    public function sAdd($key,$value)    {        if(!is_array($value))            $arr=array($value);        else            $arr=$value;        foreach($arr as $row)            $this->redis->sAdd($key,$row);    }    /**     * 返回无序集合的元素个数     * @param unknown $key     */    public function scard($key)    {        return $this->redis->scard($key);    }    /**     * 从集合中删除一个元素     * @param unknown $key     * @param unknown $value     */    public function srem($key,$value)    {        return $this->redis->srem($key,$value);    }    /*************redis管理操作命令*****************/    /**     * 选择数据库     * @param int $dbId 数据库ID号     * @return bool     */    public function select($dbId)    {        $this->dbId=$dbId;        return $this->redis->select($dbId);    }    /**     * 清空当前数据库     * @return bool     */    public function flushDB()    {        return $this->redis->flushDB();    }    /**     * 返回当前库状态     * @return array     */    public function info()    {        return $this->redis->info();    }    /**     * 同步保存数据到磁盘     */    public function save()    {        return $this->redis->save();    }    /**     * 异步保存数据到磁盘     */    public function bgSave()    {        return $this->redis->bgSave();    }    /**     * 返回最后保存到磁盘的时间     */    public function lastSave()    {        return $this->redis->lastSave();    }    /**     * 返回key,支持*多个字符,?一个字符     * 只有* 表示全部     * @param string $key     * @return array     */    public function keys($key)    {        return $this->redis->keys($key);    }    /**     * 删除指定key     * @param unknown $key     */    public function del($key)    {        return $this->redis->del($key);    }    /**     * 判断一个key值是不是存在     * @param unknown $key     */    public function exists($key)    {        return $this->redis->exists($key);    }    /**     * 为一个key设定过期时间 单位为秒     * @param unknown $key     * @param unknown $expire     */    public function expire($key,$expire)    {        return $this->redis->expire($key,$expire);    }    /**     * 返回一个key还有多久过期,单位秒     * @param unknown $key     */    public function ttl($key)    {        return $this->redis->ttl($key);    }    /**     * 设定一个key什么时候过期,time为一个时间戳     * @param unknown $key     * @param unknown $time     */    public function exprieAt($key,$time)    {        return $this->redis->expireAt($key,$time);    }    /**     * 关闭服务器链接     */    public function close()    {        return $this->redis->close();    }    /**     * 关闭所有连接     */    public static function closeAll()    {        foreach(static::$_instance as $o)        {            if($o instanceof self)                $o->close();        }    }    /** 这里不关闭连接,因为session写入会在所有对象销毁之后。    public function __destruct()    {    return $this->redis->close();    }     **/    /**     * 返回当前数据库key数量     */    public function dbSize()    {        return $this->redis->dbSize();    }    /**     * 返回一个随机key     */    public function randomKey()    {        return $this->redis->randomKey();    }    /**     * 得到当前数据库ID     * @return int     */    public function getDbId()    {        return $this->dbId;    }    /**     * 返回当前密码     */    public function getAuth()    {        return $this->auth;    }    public function getHost()    {        return $this->host;    }    public function getPort()    {        return $this->port;    }    public function getConnInfo()    {        return array(            'host'=>$this->host,            'port'=>$this->port,            'auth'=>$this->auth        );    }    /*********************事务的相关方法************************/    /**     * 监控key,就是一个或多个key添加一个乐观锁     * 在此期间如果key的值如果发生的改变,刚不能为key设定值     * 可以重新取得Key的值。     * @param unknown $key     */    public function watch($key)    {        return $this->redis->watch($key);    }    /**     * 取消当前链接对所有key的watch     *  EXEC 命令或 DISCARD 命令先被执行了的话,那么就不需要再执行 UNWATCH 了     */    public function unwatch()    {        return $this->redis->unwatch();    }    /**     * 开启一个事务     * 事务的调用有两种模式Redis::MULTI和Redis::PIPELINE,     * 默认是Redis::MULTI模式,     * Redis::PIPELINE管道模式速度更快,但没有任何保证原子性有可能造成数据的丢失     */    public function multi($type=/Redis::MULTI)    {        return $this->redis->multi($type);    }    /**     * 执行一个事务     * 收到 EXEC 命令后进入事务执行,事务中任意命令执行失败,其余的命令依然被执行     */    public function exec()    {        return $this->redis->exec();    }    /**     * 回滚一个事务     */    public function discard()    {        return $this->redis->discard();    }    /**     * 测试当前链接是不是已经失效     * 没有失效返回+PONG     * 失效返回false     */    public function ping()    {        return $this->redis->ping();    }    public function auth($auth)    {        return $this->redis->auth($auth);    }    /*********************自定义的方法,用于简化操作************************/    /**     * 得到一组的ID号     * @param unknown $prefix     * @param unknown $ids     */    public function hashAll($prefix,$ids)    {        if($ids==false)            return false;        if(is_string($ids))            $ids=explode(',', $ids);        $arr=array();        foreach($ids as $id)        {            $key=$prefix.'.'.$id;            $res=$this->hGetAll($key);            if($res!=false)                $arr[]=$res;        }        return $arr;    }    /**     * 生成一条消息,放在redis数据库中。使用0号库。     * @param string|array $msg     */    public function pushMessage($lkey,$msg)    {        if(is_array($msg)){            $msg    =    json_encode($msg);        }        $key    =    md5($msg);        //如果消息已经存在,删除旧消息,已当前消息为准        //echo $n=$this->lRem($lkey, 0, $key)."/n";        //重新设置新消息        $this->lPush($lkey, $key);        $this->setex($key, 3600, $msg);        return $key;    }    /**     * 得到条批量删除key的命令     * @param unknown $keys     * @param unknown $dbId     */    public function delKeys($keys,$dbId)    {        $redisInfo=$this->getConnInfo();        $cmdArr=array(            'redis-cli',            '-a',            $redisInfo['auth'],            '-h',            $redisInfo['host'],            '-p',            $redisInfo['port'],            '-n',            $dbId,        );        $redisStr=implode(' ', $cmdArr);        $cmd="{$redisStr} KEYS /"{$keys}/" | xargs {$redisStr} del";        return $cmd;    }}

最新文章

123

最新摄影

微信扫一扫

第七城市微信公众平台