PHPはrediesによってカプセル化されたクラスを操作します

/**
 * Redis 操作、マスター/スレーブ ロード クラスターをサポート
 *
 * @author jackluo
*/
class RedisCluster{

 // M/S 読み取り/書き込みクラスター ソリューションを使用するかどうか
 private $_isUseCluster = false;

 // スレーブ ハンドルtag
 private $_sn = 0;

 // サーバー接続ハンドル
 private $_linkHandle = array(
 'master'=>null,// 1 つのマスターのみサポート
 'slave'=>array(),//はい、複数のスレーブがあります
 );

 /**
 * コンストラクター
 *
 * @param boolean $isUseCluster M/S スキームを使用するかどうか
*/
 public function __construct($isUseCluster=false){
 $this->_isUseCluster = $isUseCluster
 }

 /**
 * サーバーに接続します。注意: ここでは効率を上げるために長い接続が使用されていますが、自動的には閉じられません
 *
 * @param array $config Redis サーバー設定
 * @param boolean $isMaster 現在追加されているサーバーがマスターかどうかサーバー
 * @ return boolean
 * /
 public function 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
* /
 public function close($flag=2){
 switch($flag){
 // マスターを閉じる
 case 0:
 $this->getRedis()->close();
 //スレーブを閉じる
 ケース 1:
 for($i=0; $i_sn; ++$i){
 $this->_linkHandle['slave'][$i]->close (); }
 Break;
 // すべて閉じる
 ケース 1:
 $i=0; $i_sn ; ++$i){
 $this->_linkHandle['slave'][$i]->close();
 ブレーク
 }

 /**
 * より多くの操作を行うために元の Redis オブジェクトを取得します
 *
 * @param boolean $isMaster サーバーのタイプを返します true: マスターを返します false: スレーブを返します
 * @param boolean $slaveOne スレーブの選択を返します true: 負荷分散はランダムに A を返しますスレーブ選択 false: すべてのスレーブ選択を返します
 * @return redis オブジェクト
*/
 public function getRedis($isMaster=true,$slaveOne=true){
 // マスターのみを返す
 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 失敗した場合は false を返し、string を返します成功について
*/
 public function get ($key){
 // 複数の値を一度に取得するかどうか
 $func = is_array($key) ? 'mGet' : 'get'
 // M/S は使用されません
 if(! $this -> _isUseCluster){
 $this->getRedis()->{$func}($key); }
 // M/S を使用します
 return $this->_getSlaveRedis()->{$func}($key);
 }


/*
 // マジック関数
 public function __call($name,$arguments){
 return call_user_func($name,$arguments);
 }
*/
 /**
 * キャッシュを設定するための条件形式。キーが存在しない場合、設定は失敗します。
 *
 * @param string $value キャッシュ値。
 * @return ブール値
*/
 public function setnx($key, $value){
 return $this->getRedis()->setnx($key, $value);
 }

 /**
 * キャッシュを削除します
 *
 * @param string || 配列 $key キャッシュ KEY、単一のキー: "key1" または複数のキーをサポートします: array('key1','key2')
 * @return int selected key 数量
*/
 public function Remove($key){
 // $key => "キー1" || array('key1','key2')
 return $this->getRedis()->delete($key);
 }

 /**
 * ++$i と同様の値の加算演算。キーが存在しない場合、自動的に 0 に設定されてから加算演算が実行されます
 *
 * @param string $key Cache 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 と同様の値の減算操作。キーが存在しない場合、自動的に 0 に設定されてから減算されます。
 *
 * @param string $key Cache 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();
 }

 /* =================== 以下、私有方法 =================== */

 /**
 * Redis スレーブサーバーハンドルを取得するためのランダムハッシュ
 *
 * @return redis オブジェクト
*/
 private function _getSlaveRedis(){
 // 就一台スレーブ机を直接返す
 if($this->_sn  return $this->_linkHandle[ 'スレーブ'][0];
 }
 //随机ハッシュがスレーブに到達する句文
 $hash = $this->_hashId(mt_rand(), $this->_sn);
 return $this->_linkHandle['slave'][$hash];
 }

 /**
 * IDを元にハッシュ化後の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 {
 //相加模式ハッシュ
 $h += substr($b,$i*2,2);
 }
 $hash = ($h*1)%$m;
 $hash を返します;
 }

 /**
 * プシュ
*/
 public function lpush($key,$value){
 return $this->getRedis()->lpush($key,$value);
 }

 /**
 * lpopを追加します
*/
 public function lpop($key){
 return $this->getRedis()->lpop($key);
 }
 /**
 * lrange
*/
 public function lrange($key,$start,$end){
 return $this->getRedis()->lrange($key,$start,$end) ;
 }

 /**
 * ハッシュ操作の設定
*/
 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);
 }
 /**
 * ハッシュ操作を取得します
*/
 public function hget($name,$key = null,$serialize=true){
 if($key){
 $row = $this->getRedis()- >hget($name,$key);
 if($row && $serialize){
 unserialize($row);
 }
 $row を返します。
 }
 return $this->getRedis()->hgetAll($name);
 }

 /**
 * ハッシュ操作を削除します
*/
 public function hdel($name,$key = null){
 if($key){
 return $this->getRedis()->hdel($name ,$キー);
 }
 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_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 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、レディ