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);
 }
*/
 /**
 * 條件形式設定緩存，如果key 不存時就設置，存在時設定失敗
 *
 * @param string $key 緩存KEY
 * @param string $value 快取值
 * @return boolean
*/
 public function setnx($key, $value){
 return $this->getRedis()->setnx （$鍵，$值）;
 }

 /**
 * 刪除快取
 *
 * @param string || array $key 快取KEY，支援單一健:"key1" 或多個健:array('key1','key2')
 * @return int 刪除的健的數量
*/
 public function remove($key){
 // $key =>; “區域1”|| 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(){
 // 就一個從機直接回傳
 if($this -> ; _sn  回傳 $this->_linkHandle['slave'][0];
 }
 // 隨機雜湊得到 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 {
 //相加模式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 );
 }
 /**
 * 範圍
*/
 public function lrange($key,$start,$end){
 return $this->getRedis()->lrange($鍵,$開始,$結束);
 }

 /**
 * 設定哈希操作
*/
 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();
 }



}// 수업 종료

// ================= 테스트 데모 == ===============

// 只有一台 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'));

PHP, 레디스