php操作redies封裝的類-php教程-PHP中文網

/**
* 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，雷迪斯