PHP达成的Redis多库选拔功用单例类,PHP达成的Redis操作通用类示例

ca88会员登录中心

本文实例讲述了PHP操作redis实现的分页列表,新增,删除功能封装类与用法。分享给大家供大家参考,具体如下:

本文实例讲述了PHP实现的Redis操作通用类。分享给大家供大家参考,具体如下:

本文实例讲述了PHP实现的Redis多库选择功能单例类。分享给大家供大家参考,具体如下:

<?php
/*
 * redis 分页数据类库
 */
class redisPage{
  protected $_redis;
  protected $_redis_ip = '127.0.0.1'; //ip
  protected $_redis_port = 6379; //端口
  protected $_redis_db = 0; //数据库号
  protected $_hash_prefix = 'my_data'; //前缀名称
  public function __construct($ip='',$port='',$db='',$hash_prefix=''){
    if($ip != '') $this->_redis_ip = $ip;
    if($port != '') $this->_redis_port = $port;
    if($db != '') $this->_redis_db = $db;
    if($hash_prefix != '') $this->_hash_prefix = $hash_prefix;
    $this->_redis = new Redis();
    $this->_redis->connect($this->_redis_ip, $this->_redis_port);
    $this->_redis->select($this->_redis_db);
  }
  /*
   * 添加记录
   * @param $id id
   * @param $data hash数据
   * @param $hashName Hash 记录名称
   * @param $SortName Redis SortSet 记录名称
   * @param $redis Redis 对象
   * @return bool
   */
  public function set_redis_page_info($id,$data){
    if(!is_numeric($id) || !is_array($data)) return false;
    $hashName = $this->_hash_prefix.'_'.$id;
    $this->_redis->hMset($hashName, $data);
    $this->_redis->zAdd($this->_hash_prefix.'_sort',$id,$id);
    return true;
  }
  /*
   * 获取分页数据
   * @param $page 当前页数
   * @param $pageSize 每页多少条
   * @param $hashName Hash 记录名称
   * @param $SortName Redis SortSet 记录名称
   * @param $redis Redis 对象
   * @param $key 字段数组 不传为取出全部字段
   * @return array
   */
  public function get_redis_page_info($page,$pageSize,$key=array()){
    if(!is_numeric($page) || !is_numeric($pageSize)) return false;
    $limit_s = ($page-1) * $pageSize;
    $limit_e = ($limit_s + $pageSize) - 1;
    $range = $this->_redis->ZRANGE($this->_hash_prefix.'_sort',$limit_s,$limit_e); //指定区间内,带有 score 值(可选)的有序集成员的列表。
    $count = $this->_redis->zCard($this->_hash_prefix.'_sort'); //统计ScoreSet总数
    $pageCount = ceil($count/$pageSize); //总共多少页
    $pageList = array();
    foreach($range as $qid){
      if(count($key) > 0){
        $pageList[] = $this->_redis->hMGet($this->_hash_prefix.'_'.$qid,$key); //获取hash表中所有的数据
      }else{
        $pageList[] = $this->_redis->hGetAll($this->_hash_prefix.'_'.$qid); //获取hash表中所有的数据
      }
    }
    $data = array(
      'data'=>$pageList, //需求数据
      'page'=>array(
        'page'=>$page, //当前页数
        'pageSize'=>$pageSize, //每页多少条
        'count'=>$count, //记录总数
        'pageCount'=>$pageCount //总页数
      )
    );
    return $data;
  }
  /*
   * 删除记录
   * @param $id id
   * @param $hashName Hash 记录名称
   * @param $SortName Redis SortSet 记录名称
   * @param $redis Redis 对象
   * @return bool
   */
  public function del_redis_page_info($id){
    if(!is_array($id)) return false;
    foreach($id as $value){
      $hashName = $this->_hash_prefix.'_'.$value;
      $this->_redis->del($hashName);
      $this->_redis->zRem($this->_hash_prefix.'_sort',$value);
    }
    return true;
  }
  /*
   * 清空数据
   * @param string $type db:清空当前数据库 all:清空所有数据库
   * @return bool
   */
  public function clear($type='db'){
    if($type == 'db'){
      $this->_redis->flushDB();
    }elseif($type == 'all'){
      $this->_redis->flushAll();
    }else{
      return false;
    }
    return true;
  }
}
//数据库
$host='localhost';
$user='root';
$psd='';
$dbname='china';
$link = @mysql_connect($host,$user,$psd);
mysql_select_db($dbname,$link);
mysql_query("set names utf8");
$SQL = "SELECT * FROM js_collection_node order by nodeid asc limit 100 ";
$query = mysql_query($SQL);
$redis = new redisPage('127.0.0.1',6379,0,'collection_node'); //实例化对象
$redis->clear(); //测试清空数据
while($info = mysql_fetch_assoc($query)){
  $redis->set_redis_page_info($info['nodeid'],$info); //插入数据
}
$redis->del_redis_page_info(array(61)); //删除数据
$data = $redis->get_redis_page_info(1,10,array('nodeid','name')); //获取分页数据
print_r($data);
?>

找到一个比较全的Redis PHP操作类库,分享给大家

前言

更多关于PHP相关内容感兴趣的读者可查看本站专题:《php+redis数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

<?php
/**
 * redis操作类
 * 说明,任何为false的串,存在redis中都是空串。
 * 只有在key不存在时,才会返回false。
 * 这点可用于防止缓存穿透
 *
 */
class Redis
{
  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    =  $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'];
  }
  /**
   * 得到实例化的对象.
   * 为每个数据库建立一个连接
   * 如果连接超时,将会重新建立一个连接
   * @param array $config
   * @param int $dbId
   * @return \iphp\db\Redis
   */
  public static function getInstance($config, $attr = array())
  {
    //如果是一个字符串,将其认为是数据库的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号库,选择一下数据库。
      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;
  }
}

qq群里有同学问redis如何进行多库选择,用php实现了一下,还望各位多多指点

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

更多关于PHP相关内容感兴趣的读者可查看本站专题:《php+redis数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

代码

您可能感兴趣的文章:

  • php操作redis中的hash和zset类型数据的方法和代码例子
  • PHP实现操作redis的封装类完整实例
  • php
    使用redis锁限制并发访问类示例
  • php
    Redis函数用法实例总结【附php连接redis单例类】
  • php实现的redis缓存类定义与使用方法示例
  • PHP实现的Redis多库选择功能单例类
  • PHP基于redis计数器类定义与用法示例
  • PHP实现的Redis操作通用类示例

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

<?php
class MultiRedisConnect
{
  /**
   * hostname
   *
   * @var string
   */
  const REDISHOSTNAME = "127.0.0.1";
  /**
   * port
   *
   * @var int
   */
  const REDISPORT = 6379;
  /**
   * timeout
   *
   * @var int
   */
  const REDISTIMEOUT = 0;
  /**
   * password
   *
   * @var string
   */
  const REDISPASSWORD = "123456";
  /**
   * 类单例数组
   *
   * @var array
   */
  private static $instance = array();
  /**
   * redis连接句柄
   *
   * @var object
   */
  private $redis;
  /**
   * hash的key
   *
   * @var int
   */
  private $hash;
  /**
   * 私有化构造函数,防止类外实例化
   *
   * @param int $dbnumber
   */
  private function __construct ($dbnumber)
  {
    $dbnumber = (int) $dbnumber;
    $this->hash = $dbnumber;
    $this->redis = new Redis();
    $this->redis->connect(self::REDISHOSTNAME, self::REDISPORT, self::REDISTIMEOUT);
    $this->redis->auth(self::REDISPASSWORD);
    $this->redis->select($dbnumber);
  }
  private function __clone ()
  {}
  /**
   * 获取类单例
   *
   * @param int $dbnumber
   * @return object
   */
  public static function getRedisInstance ($dbnumber)
  {
    $hash = (int) $dbnumber;
    if (! isset(self::$instance[$hash])) {
      self::$instance[$hash] = new MultiRedisConnect($dbnumber);
    }
    return self::$instance[$hash];
  }
  /**
   * 获取redis的连接实例
   *
   * @return object
   */
  public function getRedisConnect ()
  {
    return $this->redis;
  }
  /**
   * 关闭单例时做清理工作
   */
  public function __destruct ()
  {
    $key = $this->hash;
    self::$instances[$key]->redis->close();
    self::$instances[$key] = null;
  }
}
?>

您可能感兴趣的文章:

  • php操作redis中的hash和zset类型数据的方法和代码例子
  • PHP实现操作redis的封装类完整实例
  • php
    使用redis锁限制并发访问类示例
  • php
    Redis函数用法实例总结【附php连接redis单例类】
  • php实现的redis缓存类定义与使用方法示例
  • PHP实现的Redis多库选择功能单例类
  • PHP基于redis计数器类定义与用法示例
  • PHP操作redis实现的分页列表,新增,删除功能封装类与用法示例

更多关于PHP相关内容感兴趣的读者可查看本站专题:《php+redis数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结ca88会员登录中心,》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

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

您可能感兴趣的文章:

  • php操作redis中的hash和zset类型数据的方法和代码例子
  • PHP实现操作redis的封装类完整实例
  • php
    使用redis锁限制并发访问类示例
  • php
    Redis函数用法实例总结【附php连接redis单例类】
  • php实现的redis缓存类定义与使用方法示例
  • PHP基于redis计数器类定义与用法示例
  • PHP实现的Redis操作通用类示例
  • PHP操作redis实现的分页列表,新增,删除功能封装类与用法示例

发表评论

电子邮件地址不会被公开。 必填项已用*标注

网站地图xml地图