<?php/** * redis操作類(lèi) * 說(shuō)明，任何為false的串，存在redis中都是空串。 * 只有在key不存在時(shí)，才會(huì )返回false。 * 這點(diǎn)可用于防止緩存穿透 * */class Redis{ private $redis; //當前數據庫ID號 protected $dbId=0; //當前權限認證碼 protected $auth; /** * 實(shí)例化的對象,單例模式. * @var \iphp\db\Redis */ static private $_instance=array(); private $k; //連接屬性數組 protected $attr=array( //連接超時(shí)時(shí)間，redis配置文件中默認為300秒 'timeout'=>30, //選擇的數據庫。 'db_id'=>0, ); //什么時(shí)候重新建立連接 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 = $config['port'] ? $config['port'] : 6379; $this->host = $config['host']; $this->redis->connect($this->host, $this->port, $this->attr['timeout']); if($config['auth']) { $this->auth($config['auth']); $this->auth = $config['auth']; } $this->expireTime = time() + $this->attr['timeout']; } /** * 得到實(shí)例化的對象. * 為每個(gè)數據庫建立一個(gè)連接 * 如果連接超時(shí)，將會(huì )重新建立一個(gè)連接 * @param array $config * @param int $dbId * @return \iphp\db\Redis */ public static function getInstance($config, $attr = array()) { //如果是一個(gè)字符串，將其認為是數據庫的ID號。以簡(jiǎn)化寫(xiě)法。 if(!is_array($attr)) { $dbId = $attr; $attr = array(); $attr['db_id'] = $dbId; } $attr['db_id'] = $attr['db_id'] ? $attr['db_id'] : 0; $k = md5(implode('', $config).$attr['db_id']); 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表中一個(gè)字段的值 * @param string $key 緩存key * @param string $field 字段 * @return string|false */ public function hGet($key,$field) { return $this->redis->hGet($key,$field); } /** * 為hash表設定一個(gè)字段的值 * @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表元素個(gè)數 * @param string $key 緩存key * @return int|bool */ public function hLen($key) { return $this->redis->hLen($key); } /** * 為hash表設定一個(gè)字段的值,如果字段存在，返回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表多個(gè)字段設定值。 * @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表多個(gè)字段設定值。 * @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表的字段值，為一個(gè)索引數組 * @param string $key * @return array|bool */ public function hVals($key) { return $this->redis->hVals($key); } /** * 返回所有hash表的字段值，為一個(gè)關(guān)聯(lián)數組 * @param string $key * @return array|bool */ public function hGetAll($key) { return $this->redis->hGetAll($key); } /*********************有序集合操作*********************/ /** * 給當前集合添加一個(gè)元素 * 如果value已經(jīng)存在，會(huì )更新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表示第一個(gè)元素，-1表示最后一個(gè)元素 * @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表示第一個(gè)元素，-1表示最后一個(gè)元素 * @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開(kāi)始，取一條記錄。 * @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開(kāi)始，取一條記錄。 * @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開(kāi)始。 * @param unknown $key * @param unknown $value */ public function zRank($key,$value) { return $this->redis->zRank($key,$value); } /** * 返回集合以score遞增加排序后，指定成員的排序號，從0開(kāi)始。 * @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); } /** * 返回集合元素個(gè)數。 * @param unknown $key */ public function zCard($key) { return $this->redis->zCard($key); } /*********************隊列操作命令************************/ /** * 在隊列尾部插入一個(gè)元素 * @param unknown $key * @param unknown $value * 返回隊列長(cháng)度 */ public function rPush($key,$value) { return $this->redis->rPush($key,$value); } /** * 在隊列尾部插入一個(gè)元素 如果key不存在，什么也不做 * @param unknown $key * @param unknown $value * 返回隊列長(cháng)度 */ public function rPushx($key,$value) { return $this->redis->rPushx($key,$value); } /** * 在隊列頭部插入一個(gè)元素 * @param unknown $key * @param unknown $value * 返回隊列長(cháng)度 */ public function lPush($key,$value) { return $this->redis->lPush($key,$value); } /** * 在隊列頭插入一個(gè)元素 如果key不存在，什么也不做 * @param unknown $key * @param unknown $value * 返回隊列長(cháng)度 */ public function lPushx($key,$value) { return $this->redis->lPushx($key,$value); } /** * 返回隊列長(cháng)度 * @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個(gè)元素 * PHP-REDIS擴展的數據順序與命令的順序不太一樣，不知道是不是bug * count>0 從尾部開(kāi)始 * >0 從頭部開(kāi)始 * =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字符串操作命令*****************/ /** * 設置一個(gè)key * @param unknown $key * @param unknown $value */ public function set($key,$value) { return $this->redis->set($key,$value); } /** * 得到一個(gè)key * @param unknown $key */ public function get($key) { return $this->redis->get($key); } /** * 設置一個(gè)有過(guò)期時(shí)間的key * @param unknown $key * @param unknown $expire * @param unknown $value */ public function setex($key,$expire,$value) { return $this->redis->setex($key,$expire,$value); } /** * 設置一個(gè)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 無(wú)序集合操作命令*****************/ /** * 返回集合中所有元素 * @param unknown $key */ public function sMembers($key) { return $this->redis->sMembers($key); } /** * 求2個(gè)集合的差集 * @param unknown $key1 * @param unknown $key2 */ public function sDiff($key1,$key2) { return $this->redis->sDiff($key1,$key2); } /** * 添加集合。由于版本問(wèn)題，擴展不支持批量添加。這里做了封裝 * @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); } /** * 返回無(wú)序集合的元素個(gè)數 * @param unknown $key */ public function scard($key) { return $this->redis->scard($key); } /** * 從集合中刪除一個(gè)元素 * @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(); } /** * 返回當前庫狀態(tài) * @return array */ public function info() { return $this->redis->info(); } /** * 同步保存數據到磁盤(pán) */ public function save() { return $this->redis->save(); } /** * 異步保存數據到磁盤(pán) */ public function bgSave() { return $this->redis->bgSave(); } /** * 返回最后保存到磁盤(pán)的時(shí)間 */ public function lastSave() { return $this->redis->lastSave(); } /** * 返回key,支持*多個(gè)字符，?一個(gè)字符 * 只有* 表示全部 * @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); } /** * 判斷一個(gè)key值是不是存在 * @param unknown $key */ public function exists($key) { return $this->redis->exists($key); } /** * 為一個(gè)key設定過(guò)期時(shí)間 單位為秒 * @param unknown $key * @param unknown $expire */ public function expire($key,$expire) { return $this->redis->expire($key,$expire); } /** * 返回一個(gè)key還有多久過(guò)期，單位秒 * @param unknown $key */ public function ttl($key) { return $this->redis->ttl($key); } /** * 設定一個(gè)key什么時(shí)候過(guò)期，time為一個(gè)時(shí)間戳 * @param unknown $key * @param unknown $time */ public function exprieAt($key,$time) { return $this->redis->expireAt($key,$time); } /** * 關(guān)閉服務(wù)器鏈接 */ public function close() { return $this->redis->close(); } /** * 關(guān)閉所有連接 */ public static function closeAll() { foreach(static::$_instance as $o) { if($o instanceof self) $o->close(); } } /** 這里不關(guān)閉連接，因為session寫(xiě)入會(huì )在所有對象銷(xiāo)毀之后。 public function __destruct() { return $this->redis->close(); } **/ /** * 返回當前數據庫key數量 */ public function dbSize() { return $this->redis->dbSize(); } /** * 返回一個(gè)隨機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 ); } /*********************事務(wù)的相關(guān)方法************************/ /** * 監控key,就是一個(gè)或多個(gè)key添加一個(gè)樂(lè )觀(guān)鎖 * 在此期間如果key的值如果發(fā)生的改變，剛不能為key設定值 * 可以重新取得Key的值。 * @param unknown $key */ public function watch($key) { return $this->redis->watch($key); } /** * 取消當前鏈接對所有key的watch * EXEC 命令或 DISCARD 命令先被執行了的話(huà)，那么就不需要再執行 UNWATCH 了 */ public function unwatch() { return $this->redis->unwatch(); } /** * 開(kāi)啟一個(gè)事務(wù) * 事務(wù)的調用有兩種模式Redis::MULTI和Redis::PIPELINE， * 默認是Redis::MULTI模式， * Redis::PIPELINE管道模式速度更快，但沒(méi)有任何保證原子性有可能造成數據的丟失 */ public function multi($type=\Redis::MULTI) { return $this->redis->multi($type); } /** * 執行一個(gè)事務(wù) * 收到 EXEC 命令后進(jìn)入事務(wù)執行，事務(wù)中任意命令執行失敗，其余的命令依然被執行 */ public function exec() { return $this->redis->exec(); } /** * 回滾一個(gè)事務(wù) */ public function discard() { return $this->redis->discard(); } /** * 測試當前鏈接是不是已經(jīng)失效 * 沒(méi)有失效返回+PONG * 失效返回false */ public function ping() { return $this->redis->ping(); } public function auth($auth) { return $this->redis->auth($auth); } /*********************自定義的方法,用于簡(jiǎn)化操作************************/ /** * 得到一組的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); //如果消息已經(jīng)存在，刪除舊消息，已當前消息為準 //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; }}
聯(lián)系客服
