PHP_Redis自定類

最近在做一個投票系統，原公司的系統實在太備援了，高并發下，沒有Nginx，沒有Redis，全靠sql的update,鎖了不卡才...

原來也隻是零散的使用Redis,這回直接把他封裝成一個類吧，友善以後使用。

先分享一下基本redis工具：

1.界面管理工具

2.Window_redis (可以在windows下自己玩玩)

3.Redis官網（官網查不懂的指令，主要掌握其參數以及傳回值，很關鍵）

4.Redis指令（備查）

5.Redis相關的小工具：redis-load、redis-stat

redis-load、redis-stat是Redis作者antirez寫的兩個小工具，其中：

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 \n";
		$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 \n";
		$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."\n", FILE_APPEND);
	}


	function __destruct()
	{
		$this->redis_obj->close();
	}


}

?>

PHP_Redis自定類

Redis資料彙總專題

繼續閱讀

秒懂JVM的三大參數類型，就靠這十個小實驗了初級—中級—進階三個級别的大廠面試真題阿裡雲——Java 實習生/初級美團——Java 中級螞蟻金服——Java 進階基礎篇JVM 篇MySQL 篇Redis 篇

CentOs7 安裝redis4.0 遇到的坑一、CentOs7連接配接網絡二、make檔案的時候出錯三、安裝ruby的redis插件時候報錯最後

docker 搭建Redis 問題解決

如何解決Redis緩存擊穿、雪崩、穿透問題

java 版本的redis-stat不能運作在背景和daemon

redis管理常用指令

django短信驗證碼的後端實作

Redis訂閱了一段時間後訂閱失效了（ redisTemplate.convertAndSend）

2022秋招面試總結（cpp+java+測開）百度測開一面位元組後端一面蝦皮後端一面蝦皮後端二面

資料遷移方法資料遷移原則資料遷移之雙寫方案資料遷移之級聯同步方案

微服務-性能壓測\緩存redis和分布式鎖redisson和SpringCache

Nacos 2.0 更新前後性能對比壓測

Spring資料和Redis

redis叢集資料一緻性_RedisRaft為Redis叢集帶來強大的資料一緻性

supervisor 管理redis 和httpd 環境centos7

Redis簡介一(單機版)發展曆程Redis