php操作redies封裝的類

/**
 * 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);
 }


/*
 // 마법 함수
 public function __call($name,$arguments){
 return call_user_func($name,$arguments);
 }
*/
 /**
 * 조건부 형식으로 캐시를 설정합니다. 키가 존재하지 않으면 설정이 실패합니다.
 *
 * @param string $key Cache KEY
 * @param string $value 캐시 값
 * @return 부울
*/
 공개 함수 setnx($key, $value){
 return $this->getRedis()->setnx ($키, $값);
 }

 /**
 * 캐시 삭제
 *
 * @param string || 배열 $key 캐시 KEY, 단일 키 지원: "key1" 또는 다중 키: array('key1','key2')
 * @return int 삭제된 키의 개수
*/
 공개 함수 제거($key){
 // $key => "키1" || array('key1','key2')
 return $this->getRedis()->delete($key);
 }

 /**
 * 값 추가 연산은 $i와 마찬가지로 키가 존재하지 않으면 자동으로 0으로 설정된 후 추가 연산을 수행합니다.
 *
 * @param string $key 캐시 KEY
 * @param int $ default 연산 중 기본값
 * @return int 연산 후 값
*/
 공개 함수 incr($key,$default=1){
 if($default == 1){
 return $this->getRedis()->incr($key);
 }else{
 return $this->getRedis()->incrBy($key, $default);
 }
 }

 /**
 * --$i와 유사한 값 빼기 연산, 키가 존재하지 않으면 자동으로 0으로 설정된 후 빼기
 *
 * @param string $key 캐시 KEY
 * @param int $default 작업 중 기본값
 * @return int 작업 후 값
*/
 공용 함수 decr($key,$default=1){
 if($default == 1){
 return $this->getRedis()->decr($key);
 }else{
 return $this->getRedis()->decrBy($key, $default);
 }
 }

 /**
 * 현재 데이터베이스 비우기
 *
 * @return boolean
*/
 공용 함수clear(){
 return $this->getRedis()->flushDB();
 }

 /* =================== 以下私유방법 ================ === */

 /**
 * Redis 슬레이브 서버 핸들을 얻기 위한 무작위 HASH
 *
 * @return redis 객체
*/
 private function _getSlaveRedis(){
 // 就一台 슬레이브 机直接返回
 if($this-> _sn <= 1){
 return $this->_linkHandle['slave'][0];
 }
 // 随机 Hash 得到 Slave 的句柄
 $hash = $this->_hashId(mt_rand(), $this->_sn);
 return $this->_linkHandle['slave'][$hash];
 }

 /**
 * ID를 기준으로 해싱한 후 0에서 m-1 사이의 값을 가져옵니다.
 *
 * @param string $id
 * @param int $m
 * @return int
*/
 비공개 함수 _hashId($id,$m=10)
 {
 //把字符串K转换为 0~ m-1 之间的一个值work为对应记录的散列地址
 $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;
 $hash를 반환합니다.
 }

 /**
 * lpush
*/
 공개 함수 lpush($key,$value){
 return $this->getRedis()->lpush($ 키,$값);
 }

 /**
 * lpop 추가
*/
 공용 함수 lpop($key){
 return $this->getRedis()->lpop($key);
 }
 /**
 *레인지
*/
 공용 함수 lrange($key,$start,$end){
 return $this->getRedis()->lrange($ 키,$시작,$끝);
 }

 /**
 * 해시 연산 설정
*/
 공개 함수 hset($name,$key,$value){
 if(is_array($value)){
 return $this->getRedis()->hset($name,$key,serialize($value));
 }
 return $this->getRedis()->hset($name,$key,$value);
 }
 /**
 * 해시 연산 가져오기
*/
 공개 함수 hget($name,$key = null,$serialize=true){
 if($key){
 $row = $this->getRedis()->hget($name,$key);
 if($row && $serialize){
 unserialize($row);
 }
 $행 반환;
 }
 return $this->getRedis()->hgetAll($name);
 }

 /**
 * 刪除雜湊操作
*/
 public function hdel($name,$key = null){
 if($key){
 return $this- >getRedis()->hdel($name,$key);
 }
 return $this->getRedis()- >hdel($name);
 }
 /**
 * 交易開始
*/
 public function multi(){
 return $this->getRedis()->multi();
 }
 /**
 * 交易發送
*/

 public function exec(){
 return $this->getRedis()->exec();
 }



}// 結束課程

// ================= 測試示範== ======== =======

// 只有一個Redis 的應用
$redis = new RedisCluster();
$redis->connect(array('host'=>'127.0. 0.1','port'=>6379));


//*
$cron_id = 10001;
$CRON_KEY = 'CRON_LIST'; //
 '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 as $phone) {
 $redis->lpush($PHONE_KEY,$phone);
 }
 $redis->exec( );
 }
}

print_r($phone_list);


/*$list = $redis->hget($cron_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，雷迪斯