PHP_Redisカスタムクラス
12199 ワード
最近1つの投票システムをして、元の会社のシステムは本当に冗長すぎて、高くて下ろして、Nginxがなくて、Redisがなくて、すべてsqlのupdateに頼って、鍵をかけてカードをかけないでやっと...
もとはただばらばらにRedisを使うだけで、今度は直接彼を1つのクラスにカプセル化して、後で使うのが便利です.
基本的なredisツールを共有します.
1.インタフェース管理ツール
2.Window_redis(windowsの下で自分で遊ぶことができます)
3.Redis官网(官网查不懂的命令,主要掌握其パラメトリック及返回值,很重要)
4.Redisコマンド(確認準備)
5.Redis関連のガジェット:redis-load、redis-stat
redis-load、redis-statは、Redisの著者antirezが書いた2つの小さなツールです.
redis-loadはRedisの圧力試験ツールである.
redis-statは、Redisの状態監視ツールである
関連コード:https://github.com/antirez/redis-tools
http://blog.nosqlfan.com/html/3537.html
本文はいくつかのRedisがPHPでよく使う操作を羅列して、まだあまり完全ではないかもしれませんが、あるいはいくつかの最適化すべきところがあって、後でゆっくりと改善して、みんなに分かち合います.
もとはただばらばらにRedisを使うだけで、今度は直接彼を1つのクラスにカプセル化して、後で使うのが便利です.
基本的なredisツールを共有します.
1.インタフェース管理ツール
2.Window_redis(windowsの下で自分で遊ぶことができます)
3.Redis官网(官网查不懂的命令,主要掌握其パラメトリック及返回值,很重要)
4.Redisコマンド(確認準備)
5.Redis関連のガジェット:redis-load、redis-stat
redis-load、redis-statは、Redisの著者antirezが書いた2つの小さなツールです.
redis-loadはRedisの圧力試験ツールである.
redis-statは、Redisの状態監視ツールである
関連コード:https://github.com/antirez/redis-tools
Redis資料まとめテーマ
http://blog.nosqlfan.com/html/3537.html
本文はいくつかのRedisがPHPでよく使う操作を羅列して、まだあまり完全ではないかもしれませんが、あるいはいくつかの最適化すべきところがあって、後でゆっくりと改善して、みんなに分かち合います.
<?php
/**
* Class RedisVote redis ， redis
* @time,2016.03.07
*/
class RedisVote{
public $redis_obj = null;//redis
public function __construct($host = '127.0.0.1', $port =6379,$auth = "password") {
$this->redis_obj = new Redis();
$this->redis_obj->connect($host,$port);
$this->redis_obj->auth($auth);
return $this->redis_obj;
}
/*------------------------------------start 1.string ----------------------------------------------------*/
/**
* ，
* @param string $key KEY
* @param string $value
* @param int $timeOut 0
* @return true【 true】
*/
public function set($key, $value, $timeOut=0) {
$setRes = $this->redis_obj->set($key, $value);
if ($timeOut > 0) $this->redis_obj->expire($key, $timeOut);
return $setRes;
}
/**
* ， ， false
* @param $key ,
* @return bool|string ， ， false
*/
public function get($key){
$setRes = $this->redis_obj->get($key);// false
if($setRes === 'false'){
return false;
}
return $setRes;
}
/*------------------------------------1.end string ----------------------------------------------------*/
/*------------------------------------2.start list ----------------------------------------------------*/
/**
* ， ( ， )
* @param String $key KEY
* @param string $value
* @param $timeOut |num
*/
public function lpush($key,$value,$timeOut=0){
// echo "$key - $value
";
$re = $this->redis_obj->LPUSH($key,$value);
if ($timeOut > 0) $this->redis_obj->expire($key, $timeOut);
return $re;
}
/**
* ， ( ， )
* @param string $key KEY
* @param string $value
* @param $timeOut |num
*/
public function rpush($key,$value,$timeOut=0){
// echo "$key - $value
";
$re = $this->redis_obj->RPUSH($key,$value);
if ($timeOut > 0) $this->redis_obj->expire($key, $timeOut);
return $re;
}
/**
* ， （ ）
* @param string $key KEY
* @param int $head
* @param int $tail
*/
public function lranges($key,$head,$tail){
return $this->redis_obj->lrange($key,$head,$tail);
}
/*------------------------------------2.end list ----------------------------------------------------*/
/*------------------------------------3.start set ----------------------------------------------------*/
/**
* ， ( )
* @param string $key Y
* @param string|array $value
* @param int $timeOut 0
* @return
*/
public function sadd($key,$value,$timeOut = 0){
$re = $this->redis_obj->sadd($key,$value);
if ($timeOut > 0) $this->redis_obj->expire($key, $timeOut);
return $re;
}
/**
* ，
* @param string $key
*/
public function smembers($key){
$re = $this->redis_obj->exists($key);// 1， 0
if(!$re) return false;
return $this->redis_obj->smembers($key);
}
/*------------------------------------3.end set ----------------------------------------------------*/
/*------------------------------------4.start sort set ----------------------------------------------------*/
/*
* ， ， ( ), ,
* @param string $key
* @param array $score_value key scoll, value
* @return int 【, 0】
*/
public function zadd($key,$score_value,$timeOut =0){
if(!is_array($score_value)) return false;
$a = 0;//
foreach($score_value as $score=>$value){
$re = $this->redis_obj->zadd($key,$score,$value);// ， ，
$re && $a+=1;
if ($timeOut > 0) $this->redis_obj->expire($key, $timeOut);
}
return $a;
}
/**
* ， ， , ，
* @param $key ,
* @param $min , $min
* @param $max，
* @param $order ，asc ，desc
* @return array|bool ， ， false
*/
public function zrange($key,$min = 0 ,$num = 1,$order = 'desc'){
$re = $this->redis_obj->exists($key);// 1， 0
if(!$re) return false;//
if('desc' == strtolower($order)){
$re = $this->redis_obj->zrevrange($key,$min ,$min+$num-1);
}else{
$re = $this->redis_obj->zrange($key,$min ,$min+$num-1);
}
if(!$re) return false;//
return $re;
}
/**
* key ， member
* @param $key，
* @param $member，scroll
* @param $type ,
* @return bool, false，
*/
public function zrank($key,$member,$type = 'desc'){
$type = strtolower(trim($type));
if($type == 'desc'){
$re = $this->redis_obj->zrevrank($key,$member);// score ( ) ，
}else{
$re = $this->redis_obj->zrank($key,$member);// score ( ) ，
}
if(!is_numeric($re)) return false;//
return $re;
}
/**
* key zset score >= star score <= end
* @param $key
* @param $member
* @param $star，
* @param $end,
* @return array
*/
public function zrangbyscore($key,$star,$end){
return $this->redis_obj->ZRANGEBYSCORE($key,$star,$end);
}
/**
* key zset member score
* @param $key
* @param $member
* @return string , member
*/
function zscore($key,$member){
return $this->redis_obj->ZSCORE($key,$member);
}
/*------------------------------------4.end sort set ----------------------------------------------------*/
/*------------------------------------5.hash ----------------------------------------------------*/
/**
* ， json ,hash
* @param $redis_key |array , $redis_key['key'] ;$redis_key['field'], key
* @param $token, token，
* @param $id, ID，
* @param $data|array ， ,
* @param $timeOut ， ， 0
* @return $number 1【, 0】
*/
public function hset_json($redis_key,$token,$id,$data,$timeOut = 0){
$redis_table_name = $redis_key['key'].':'.$token; //key
$redis_key_name = $redis_key['field'].':'.$id; //field ，
$redis_info = json_encode($data); //field value， json
$re = $this->redis_obj -> hSet($redis_table_name,$redis_key_name,$redis_info);//
if ($timeOut > 0) $this->redis_obj->expire($redis_table_name, $timeOut);//
return $re;
}
/**
* ，json ， ;
* @param $redis,$redis['key'],$redis['field'] hash
* @param $token,$token
* @param $token,$id ID
* @return bool|array, ， false
*/
public function hget_json($redis_key,$token,$id){
$re = $this->redis_obj->hexists($redis_key['key'].':'.$token,$redis_key['field'].':'.$id);// hash field
if($re){
$info = $this->redis_obj->hget($redis_key['key'].':'.$token,$redis_key['field'].':'.$id);
$info = json_decode($info,true);
}else{
$info = false;
}
return $info;
}
/**
* ， hash
* @param $key ,
* @param $data |array ，
* @param $timeOut |num
* @return $number OK【 ok】
*/
public function hmset($key,$data,$timeOut=0){
$re = $this->redis_obj -> hmset($key,$data);
if ($timeOut > 0) $this->redis_obj->expire($key, $timeOut);
return $re;
}
/**
* ，
* @param $key, hash
* @return array 。 ， false
*/
public function hval($key){
$re = $this->redis_obj->exists($key);// 1， 0
if(!$re) return false;
$vals = $this->redis_obj -> hvals($key);
$keys = $this->redis_obj -> hkeys($key);
$re = array_combine($keys,$vals);
foreach($re as $k=>$v){
if(!is_null(json_decode($v))){
$re[$k] = json_decode($v,true);//true json
}
}
return $re;
}
/**
*
* @param $key
* @param $filed
* @return bool|string
*/
public function hget($key,$filed){
$re = $this->redis_obj->hget($key,$filed);
if(!$re){
return false;
}
return $re;
}
/*------------------------------------end hash ----------------------------------------------------*/
/*------------------------------------ ----------------------------------------------------*/
/**
* ,
* @param $key ，
* @param int $num ， ， 1
* @param string $member ， zset hash， member filed
* @param string $type， ，default , :zset,hash
* @return bool|int scroll ， false
*/
public function incre($key,$num = 1,$member = '',$type=''){
$num = intval($num);
switch(strtolower(trim($type))){
case "zset":
$re = $this->redis_obj->zIncrBy($key,$num,$member);//
break;
case "hash":
$re = $this->redis_obj->hincrby($key,$member,$num);// hashmap
break;
default:
if($num > 0){
$re = $this->redis_obj->incrby($key,$num);//
}else{
$re = $this->redis_obj->decrBy($key,-$num);//
}
break;
}
if($re) return $re;
return false;
}
/**
*
* @param int $type 0， ；1
*/
function flush($type = 0){
if($type) {
$this->redis_obj->flushAll();//
}else{
$this->redis_obj->flushdb();//
}
}
/**
*
* @param $keys ，
* @param string $type， ，
* @param string $field。 hash ， $field
* @return bool
*/
public function exists($keys,$type = '',$field=''){
switch(strtolower(trim($type))){
case 'hash':
$re = $this->redis_obj->hexists($keys,$field);// 1， 0
break;
default:
$re = $this->redis_obj->exists($keys);
break;
}
return $re;
}
/**
*
* @param string|array $key，
* @param $type， ， ， hash,zset
* @param string $field,hash=> $field ，set=> value,zset=> value ，list
* @return int | ，
*/
public function delete($key,$type,$field = ''){
switch(strtolower(trim($type))){
case 'hash':
$re = $this->redis_obj->hDel($key,$field);//
break;
case 'set':
$re = $this->redis_obj->sRem($key,$field);//
break;
case 'zset':
$re = $this->redis_obj->zDelete($key,$field);//
break;
default:
$re = $this->redis_obj->del($key);//
break;
}
return $re;
}
//
public function logger($log_content,$position = 'user')
{
$max_size = 1000000; // 1000K
$log_dir = './log';//
if(!file_exists($log_dir)) mkdir($log_dir,0777);// ，
if($position == 'user'){
$log_filename = "{$log_dir}/User_redis_log.txt"; //
}else{
$log_filename = "{$log_dir}/Wap_redis_log.txt"; //
}
//
if(file_exists($log_filename) && (abs(filesize($log_filename)) > $max_size)){
unlink($log_filename);
}
// ， ， ，
file_put_contents($log_filename, date('Y-m-d_H:i:s')." ".$log_content."
", FILE_APPEND);
}
function __destruct()
{
$this->redis_obj->close();
}
}
?>