php操作redies封装的类_php

 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操作redies封装的类_php》,跪求各位点评,若觉得好的话请收藏本文，by 搞代码

喜欢 (0)赏

[搞代码]

分享 (0)