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