<?php/** * redis操作類 * 說明，任何為false的串，存在redis中都是空串。 * 只有在key不存在時，才會返回false。 * 這點可用于防止緩存穿透 * */class Redis{  private $redis;  //當(dāng)前數(shù)據(jù)庫ID號  protected $dbId=0;  //當(dāng)前權(quán)限認(rèn)證碼  protected $auth;  /**   * 實例化的對象,單例模式.   * @var /iphp/db/Redis   */  static private $_instance=array();  private $k;  //連接屬性數(shù)組  protected $attr=array(    //連接超時時間，redis配置文件中默認(rèn)為300秒    'timeout'=>30,    //選擇的數(shù)據(jù)庫。    '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    =  $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ù)據(jù)庫建立一個連接   * 如果連接超時，將會重新建立一個連接   * @param array $config   * @param int $dbId   * @return /iphp/db/Redis   */  public static function getInstance($config, $attr = array())  {    //如果是一個字符串，將其認(rèn)為是數(shù)據(jù)庫的ID號。以簡化寫法。    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號庫，選擇一下數(shù)據(jù)庫。      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號庫，選擇一下數(shù)據(jù)庫。      if($attr['db_id']!=0){        static::$_instance[$k]->select($attr['db_id']);      }    }    return static::$_instance[$k];  }  private function __clone(){}  /**   * 執(zhí)行原生的redis操作   * @return /Redis   */  public function getRedis()  {    return $this->redis;  }  /*****************hash表操作函數(shù)*******************/  /**   * 得到hash表中一個字段的值   * @param string $key 緩存key   * @param string $field 字段   * @return string|false   */  public function hGet($key,$field)  {    return $this->redis->hGet($key,$field);  }  /**   * 為hash表設(shè)定一個字段的值   * @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表元素個數(shù)   * @param string $key 緩存key   * @return int|bool   */  public function hLen($key)  {    return $this->redis->hLen($key);  }  /**   * 為hash表設(shè)定一個字段的值,如果字段存在，返回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表多個字段設(shè)定值。   * @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表多個字段設(shè)定值。   * @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表設(shè)這累加，可以負(fù)數(shù)   * @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表的字段值，為一個索引數(shù)組   * @param string $key   * @return array|bool   */  public function hVals($key)  {    return $this->redis->hVals($key);  }  /**   * 返回所有hash表的字段值，為一個關(guān)聯(lián)數(shù)組   * @param string $key   * @return array|bool   */  public function hGetAll($key)  {    return $this->redis->hGetAll($key);  }  /*********************有序集合操作*********************/  /**   * 給當(dāng)前集合添加一個元素   * 如果value已經(jīng)存在，會更新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,可以為負(fù)數(shù)   * @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 參數(shù)   *   withscores=>true，表示數(shù)組下標(biāo)為Order值，默認(rèn)返回索引數(shù)組   *   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 參數(shù)   *   withscores=>true，表示數(shù)組下標(biāo)為Order值，默認(rèn)返回索引數(shù)組   *   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之間的數(shù)量   * @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 刪除成員的數(shù)量。   */  public function zRemRangeByScore($key,$start,$end)  {    return $this->redis->zRemRangeByScore($key,$start,$end);  }  /**   * 返回集合元素個數(shù)。   * @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);   }  /**   * 返回隊列指定區(qū)間的元素   * @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);  }  /**   * 設(shè)定隊列中指定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擴(kuò)展的數(shù)據(jù)順序與命令的順序不太一樣，不知道是不是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字符串操作命令*****************/  /**   * 設(shè)置一個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);  }  /**   * 設(shè)置一個有過期時間的key   * @param unknown $key   * @param unknown $expire   * @param unknown $value   */  public function setex($key,$expire,$value)  {    return $this->redis->setex($key,$expire,$value);  }  /**   * 設(shè)置一個key,如果key存在,不做任何操作.   * @param unknown $key   * @param unknown $value   */  public function setnx($key,$value)  {    return $this->redis->setnx($key,$value);  }  /**   * 批量設(shè)置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);  }  /**   * 添加集合。由于版本問題，擴(kuò)展不支持批量添加。這里做了封裝   * @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);  }  /**   * 返回?zé)o序集合的元素個數(shù)   * @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管理操作命令*****************/  /**   * 選擇數(shù)據(jù)庫   * @param int $dbId 數(shù)據(jù)庫ID號   * @return bool   */  public function select($dbId)  {    $this->dbId=$dbId;    return $this->redis->select($dbId);  }  /**   * 清空當(dāng)前數(shù)據(jù)庫   * @return bool   */  public function flushDB()  {    return $this->redis->flushDB();  }  /**   * 返回當(dāng)前庫狀態(tài)   * @return array   */  public function info()  {    return $this->redis->info();  }  /**   * 同步保存數(shù)據(jù)到磁盤   */  public function save()  {    return $this->redis->save();  }  /**   * 異步保存數(shù)據(jù)到磁盤   */  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設(shè)定過期時間 單位為秒   * @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);  }  /**   * 設(shè)定一個key什么時候過期，time為一個時間戳   * @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寫入會在所有對象銷毀之后。  public function __destruct()  {    return $this->redis->close();  }  **/  /**   * 返回當(dāng)前數(shù)據(jù)庫key數(shù)量   */  public function dbSize()  {    return $this->redis->dbSize();  }  /**   * 返回一個隨機(jī)key   */  public function randomKey()  {    return $this->redis->randomKey();  }  /**   * 得到當(dāng)前數(shù)據(jù)庫ID   * @return int   */  public function getDbId()  {    return $this->dbId;  }  /**   * 返回當(dāng)前密碼   */  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)方法************************/  /**   * 監(jiān)控key,就是一個或多個key添加一個樂觀鎖   * 在此期間如果key的值如果發(fā)生的改變，剛不能為key設(shè)定值   * 可以重新取得Key的值。   * @param unknown $key   */  public function watch($key)  {    return $this->redis->watch($key);  }  /**   * 取消當(dāng)前鏈接對所有key的watch   * EXEC 命令或 DISCARD 命令先被執(zhí)行了的話，那么就不需要再執(zhí)行 UNWATCH 了   */  public function unwatch()  {    return $this->redis->unwatch();  }  /**   * 開啟一個事務(wù)   * 事務(wù)的調(diào)用有兩種模式Redis::MULTI和Redis::PIPELINE，   * 默認(rèn)是Redis::MULTI模式，   * Redis::PIPELINE管道模式速度更快，但沒有任何保證原子性有可能造成數(shù)據(jù)的丟失   */  public function multi($type=/Redis::MULTI)  {    return $this->redis->multi($type);  }  /**   * 執(zhí)行一個事務(wù)   * 收到 EXEC 命令后進(jìn)入事務(wù)執(zhí)行，事務(wù)中任意命令執(zhí)行失敗，其余的命令依然被執(zhí)行   */  public function exec()  {    return $this->redis->exec();  }  /**   * 回滾一個事務(wù)   */  public function discard()  {    return $this->redis->discard();  }  /**   * 測試當(dāng)前鏈接是不是已經(jīng)失效   * 沒有失效返回+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數(shù)據(jù)庫中。使用0號庫。   * @param string|array $msg   */  public function pushMessage($lkey,$msg)  {    if(is_array($msg)){      $msg  =  json_encode($msg);    }    $key  =  md5($msg);    //如果消息已經(jīng)存在，刪除舊消息，已當(dāng)前消息為準(zhǔn)    //echo $n=$this->lRem($lkey, 0, $key)."/n";    //重新設(shè)置新消息    $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;  }}