PHP实现操作redis的封装类完整实例

Redis  /  管理员 发布于 5年前   345

本文实例讲述了PHP实现操作redis的封装类。分享给大家供大家参考，具体如下：

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'));

希望本文所述对大家PHP程序设计有所帮助。

您可能感兴趣的文章:

• redis+php实现微博（二）发布与关注功能详解
• redis+php实现微博（一）注册与登录功能详解
• PHP+redis实现微博的拉模型案例详解
• PHP+redis实现微博的推模型案例分析
• PHP使用redis消息队列发布微博的方法示例
• PHP基于Redis消息队列实现发布微博的方法
• php结合redis高并发下发帖、发微博的实现方法
• php结合redis实现高并发下的抢购、秒杀功能的实例
• php+redis实现注册、删除、编辑、分页、登录、关注等功能示例
• PHP实现电商订单自动确认收货redis队列
• redis+php实现微博（三）微博列表功能详解