- /**
- * Redis ??, ???/???? ?? ???? ??
- *
- * @author jackluo
- */
- class RedisCluster{
-
- // M/S ??-?? ?? ?? Cluster Scheme
- private $_isUseCluster = false;
-
- // ???? ?? ??
- private $_sn = 0
-
- // ?? ?? ??
- private $_linkHandle = array (
- 'master'=>null,// ??? ???? ?????
- 'slave'=>array(),// ?? ????? ?? ? ????
- ); *
- * ???
- *
- * @param boolean $isUseCluster M/S ?? ?? ??
- */
- ?? ?? __construct($isUseCluster=false){
- $this->_isUseCluster = $isUseCluster
- }
-
- /**
- * ??? ?????. ??: ????? ???? ??? ?? ? ??? ????? ???? ???? ????.
- *
- * @param array $config Redis ?? ??
- * @param boolean $isMaster ?? ??? ??? ??? ???? ??
- * @return boolean
- * /
- ?? ?? connect($config=array('host'=>'127.0.0.1','port'=>6379), $isMaster=true){
- // ?? ??
- if (!isset($config['port'])){
- $config['port'] = 6379;
- }
- // ??? ?? ??
- if($isMaster){
- $this->_linkHandle['master'] = new Redis()
- $ret = $this->_linkHandle['master']->pconnect($config['host'],$ config ['port']);
- }else{
- // ?? ???? ??
- $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: ??? ?? 1: ???? ?? 2: ?? ??
- * @return boolean
- */
- ?? ?? close($flag=2){
- switch($flag){
- // ??? ??
- ?? 0:
- $this->getRedis()->close()
- break
- // ???? ??;
- ?? 1:
- for($i=0; $i<$this->_sn; $i){
- $this->_linkHandle['slave'][$i] -> ;close();
- }
- break;
- // ?? ??
- ?? 1:
- $this->getRedis()->close(); $i=0; $i<$this->_sn; $i){
- $this->_linkHandle['slave'][$i]->close()
- }
- break;
- }
- true? ?????.
- }
-
- /**
- * ?? Redis ??? ???? ? ?? ??? ??? ? ????.
- *
- * @param boolean $isMaster ?? ??? ?????. true: ???? ?????. false: ????? ?????.
- * @param boolean $ slaveOne ??? ???? ?? true: ?? ???? ??? ???? ??? ?????. false: ?? ???? ??? ?????.
- * @return redis ??
- */
- ?? ?? getRedis($isMaster=true,$slaveOne=true) ??> // ???? ??
- if($isMaster){
- return $this->_linkHandle['master']
- }else{
- return $this- > _getSlaveRedis() : $this->_linkHandle['slave'];
- }
- }
-
- /**
- * ?? ??
- *
- * @param string $key ?? ?? KEY
- * @param string $value ?? ?
- * @param int $expire ?? ??, 0: ?? ??? ?? ??
- */
- ?? ?? ??($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);
- }
-
-
- /*
- // 魔術(shù)函數(shù)
- public function __call($name,$arguments){
- return call_user_func($name,$arguments);
- }
- */
- /**
- * 條件形式設(shè)定緩存,如果key 不存時(shí)就設(shè)置,存在時(shí)設(shè)定失敗
- *
- * @param string $key 緩存KEY
- * @param string $value 快取值
- * @return boolean
- */
- public function setnx($key, $value){
- return $this->getRedis()->setnx ($鍵,$值);
- }
-
- /**
- * 刪除快取
- *
- * @param string || array $key 快取KEY,支援單一健:"key1" 或多個(gè)健:array('key1','key2')
- * @return int 刪除的健的數(shù)量
- */
- public function remove($key){
- // $key =>; “區(qū)域1”|| array('key1','key2')
- return $this->getRedis()->delete($key);
- }
-
- /**
- * 值加上操作,類似$i ,如果key 不存在時(shí)自動(dòng)設(shè)定為0 後進(jìn)行加加操作
- *
- * @param string $key 快取KEY
- * @param int $ default 操作時(shí)的預(yù)設(shè)值
- * @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 不存在時(shí)自動(dòng)設(shè)定為0 後進(jìn)行減減操作
- *
- * @param string $key 快取KEY
- * @param int $default 操作時(shí)的預(yù)設(shè)值
- * @return int 操作後的值
- */
- public function decr($key,$default=1){
- if($default == 1){
- return $this->getRedis()->decr($key);
- }else{
- return $this->getRedis()->decrBy($key, $default);
- }
- }
-
- /**
- * 添空目前資料庫(kù)
- *
- * @return boolean
- */
- public function clear(){
- return $this->getRedis()->flushDB();
- }
-
- /* =======================以下導(dǎo)管方法============ == == === */
-
- /**
- * 隨機(jī) HASH 得到 Redis Slave 伺服器句柄
- *
- * @return redis object
- */
- private function _getSlaveRedis(){
- // 就一個(gè)從機(jī)直接回傳
- if($this -> ; _sn 回傳 $this->_linkHandle['slave'][0];
- }
- // 隨機(jī)雜湊得到 Slave 的句柄
- $hash = $this->_hashId(mt_rand(), $this->_sn);
- return $this->_linkHandle['slave'][$hash];
- }
-
- /**
- * 根據(jù)ID得到 hash 後 0~m-1 之間的值
- *
- * @param string $id
- * @param int $m
- * @return int
- */
- private function _hashId($id,$m=10)
- {
- // 把字串K轉(zhuǎn)換成0~ m-1 之間的一個(gè)值作為對(duì)應(yīng)記錄的雜湊位址
- $k = md5($id);
- $l = strlen($k);
- $b = bin2hex($k);
- $h = 0;
- for($i=0;$i {
- //相加模式HASH
- $h = substr($b,$i*2,2) ;
- }
- $hash = ($h*1)%$m;
- 回傳 $hash;
- }
-
- /**
- * lpush
- */
- public function lpush($key,$value){
- return $this->getRedis()->lpush($鍵, $值);
- }
-
- /**
- * 加 lpop
- */
- public function lpop($key){
- return $this->getRedis()->lpop($key){
- return $this->getRedis()->lpop($key );
- }
- /**
- * 範(fàn)圍
- */
- public function lrange($key,$start,$end){
- return $this->getRedis()->lrange($鍵,$開(kāi)始,$結(jié)束);
- }
-
- /**
- * 設(shè)定哈希操作
- */
- public function hset($name,$key,$value){
- if(is_array ($value)){
- 回傳$this->getRedis()->hset($name,$key,serialize($value));
- }
- return $this->getRedis()- >hset($name,$key,$value);
- }
- /**
- * 取得雜湊操作
- */
- public function hget($name,$key = null,$serialize=true){
- if($key){
- $row = $this->getRedis()->hget($name,$key);
- if($row && $serialize){
- unserialize($行);
- }
- 回傳$行}
- return $this->getRedis()->hgetAll($name);
- }
-
- /**
- * ?? ?? ??
- */
- ?? ?? hdel($name,$key = null){
- if($key){
- return $this- >getRedis()->hdel($name,$key);
- }
- return $this->getRedis()->hdel($name);
- }
- /**
- * ?? ??
- */
- ?? ?? multi(){
- return $this->getRedis()->multi();
- }
- /**
- * ?? ???
- */
-
- ?? ?? exec(){
- return $this->getRedis()->exec();
- }
-
-
-
- }// ?? ??
-
- // ================= ??? ?? == ===============
-
- // 只有一臺(tái) 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 ??
- $cron = $redis->hget($CRON_KEY,$cron_id);
- if(empty($cron)){
-
- $cron = array('id'=>10,'name'=>'jackluo');//mysql ???
- $ redis->hset($CRON_KEY,$cron_id,$cron); // redis ??
- }
- //?? ??
- $phone_list = $redis->lrange($PHONE_KEY,0,-1);
- print_r($phone_list);
- if(empty($phone_list)){
- $phone_list =explode(',','13228191831,18608041585'); //mysql ???
- //?? ??
- if($phone_list){
- $redis->multi();
- foreach ($phone_list? $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('???');
- print_r($lpop);
- $lpop = $redis->lpop('???');
- print_r($lpop);
- $lpop = $redis->lpop('???');
- print_r($lpop);
- */
- // var_dump($redis->get('id'));
復(fù)代碼
|