# RedisHash.php
該代碼在10月31日進行過更新
~~~
<?php
/**
* Created by PhpStorm.
* Power By Mikkle
* Email:776329498@qq.com
* Date: 2017/6/21
* Time: 21:03
*/
namespace app\base\controller;
use think\Db;
use think\Exception;
class RedisHash
{
protected $redisHash = null;//redis實例化時靜態變量
static protected $instance;
protected $sn;
protected $index = 11; //Hash 我個人默認使用11庫
protected $table ;
public $hashKey;
protected $prefix="HASH:"; //HashKey前綴
protected $host="127.0.0.1";
protected $port=6379;
protected $auth="redisPassword";
public function __construct($options=[]){
$host = trim(isset($options["host"]) ? $options["host"] : $this->host);
$port = trim(isset($options["port"]) ? $options["port"] : $this->port );
$auth = trim(isset($options["auth"]) ? $options["auth"] : $this->auth );
$index = trim(isset($options["index"]) ? $options["index"] : $this->index );
if (!is_integer($index) && $index>16) {
$index = $this->index;
}
$sn = md5("{$host}{$port}{$auth}{$index}");
$this->sn = $sn;
if (!isset($this->redisHash[$this->sn])){
$this->redisHash[$this->sn]=new \Redis();
$this->redisHash[$this->sn]->connect($host,$port);
$this->redisHash[$this->sn]->auth($auth);
$this->redisHash[$this->sn]->select($index);
}
$this->redisHash[$this->sn]->sn=$sn;
$this->redisHash[$this->sn]->prefix=$this->prefix;
$this->index = $index;
return ;
}
/**
* User: Mikkle
* Q Q:776329498
* @param array $options
* @return RedisHash
*/
public static function instance($options=[])
{
return new RedisHash($options);
}
/**
* 設置key值(table名稱)
* User: Mikkle
* Q Q:776329498
* @param $table
* @return $this
*/
public function setTable($table){
$this->redisHash[$this->sn]->table=$table;
$this->redisHash[$this->sn]->hashKey=null;
return $this;
}
/**
* 設置key值(PK值)
* User: Mikkle
* Q Q:776329498
* @param $key
* @return $this
*/
public function setKey($key){
$this->redisHash[$this->sn]->key=$key;
$this->redisHash[$this->sn]->hashKey=null;
return $this;
}
/**
* 設置過期時間 或指定過期的時間戳
* User: Mikkle
* Q Q:776329498
* @param int $time
* @return bool
*/
public function setExpire($time=0){
$hash_key = $this->getHashKey();
if(!$hash_key){
return false;
}
switch (true){
case ($time==0):
return $this->redisHash[$this->sn]->expire($hash_key,0);
break;
case ($time>time()):
$this->redisHash[$this->sn]->expireAt($hash_key,$time);
break;
default:
return $this->redisHash[$this->sn]->expire($hash_key,$time);
}
}
static function quickGet($key,$field=[]){
return (new RedisHash())->quickFindByHashKey($key,$field);
}
/**
* 快速獲取 不存在查表寫入
* Power: Mikkle
* Email:776329498@qq.com
* @param $key
* @param array $field
* @return bool
*/
public function quickFindByHashKey($key,$field=[]){
$return_data = $this->getByHashKey($key,$field);
if(!empty($return_data)||$return_data==0){
return $return_data;
}else{
$key_array = explode(":",$key);
switch (true){
case (count($key_array)!=2):
return false;
break;
case (is_numeric($key_array[1])):
$pk = "id";
break;
case (is_string($key_array[1])):
$pk = "guid";
break;
default:
return false;
}
$data = Db::table($key_array[0])->where([$pk=>$key_array[1]])->find();
if ($data){
$this->setHashKey($key)->set($data);
}else{
return false;
}
return $this->getByHashKey($key,$field);
}
}
/**
* 通過Hash獲取
* Power: Mikkle
* Email:776329498@qq.com
* @param $key
* @param array $field
* @return bool
*/
public function getByHashKey($key,$field=[]){
switch (true){
case (empty($key)):
return false;
break;
case (is_string($key)&&empty($field)):
$key=$this->getTrueHashKeyByHashKey($key);
$return_data = $this->redisHash[$this->sn]->hGetAll($key);
break;
case (is_string($key)&&!empty($field)):
$key=$this->getTrueHashKeyByHashKey($key);
$field = is_string($field)?explode(",",$field) : $field;
$return_data = $this->redisHash[$this->sn]->hMget($key,$field);
break;
default:
return false;
}
return $return_data;
}
protected function getTrueHashKeyByHashKey($key){
if(substr($key,0,count($this->prefix))!="$this->prefix"){
$key=$this->prefix."$key";
}
return $key;
}
/**
* Power: Mikkle
* Email:776329498@qq.com
* @param $key
* @return bool
*/
public function exists($key){
switch (true){
case (empty($key)):
return false;
break;
case (is_string($key)):
$return_data = $this->redisHash[$this->sn]->exists($key);
break;
default:
return false;
}
return $return_data;
}
/**
* 通用設置字段值
* User: Mikkle
* Q Q:776329498
* @param $field
* @param string $value
* @return bool
*/
public function set($field,$value=""){
switch(true) {
//判斷為空
case (is_array($field)&&empty($value)):
return $this->setAll($field);
break;
case (is_object($field)&&empty($value)):
return $this->setAll($field->toArray());
break;
case (is_string($field)&&is_string($value)):
return $this->setField($field,$value);
break;
default:
return false;
}
}
/**
* 設置指定字段值
* User: Mikkle
* Q Q:776329498
* @param $field
* @param $value
* @return bool
*/
protected function setField($field,$value){
$hash_key = $this->getHashKey();
if(!$hash_key){
return false;
}
if(is_string($field)||is_string($value)){
return $this->redisHash[$this->sn]->hSet( $hash_key, $field, $value );
}
return false;
}
/**
* 批量設置字段
* User: Mikkle
* Q Q:776329498
* @param $data 數組
* @return bool
*/
protected function setAll($data){
$hash_key = $this->getHashKey();
if(!$hash_key){
return false;
}
if(is_array($data)){
return $this->redisHash[$this->sn]->hMset($hash_key,$data);
}else{
return false;
}
}
/**
* 獲取字段值 支持單字段 字符串逗號分割 數組
* User: Mikkle
* Q Q:776329498
* @param array $field 支持單字段 字符串逗號分割 數組
* @return bool
*/
public function get($field=[]){
switch(true) {
//判斷為空
case empty($field):
return $this->getAll();
break;
case is_string($field):
$field_list = explode(",",$field);
if (count($field_list)==1){
return $this->getByField($field_list[0]);
}else{
return $this->getByArray($field_list);
}
break;
case is_numeric($field):
return $this->getByField($field);
break;
case is_array($field):
return $this->getByArray($field);
break;
case is_object($field):
return false;
break;
default:
return $this->getByField($field);
}
}
/**
* 通過數組獲取指定字段值
* User: Mikkle
* Q Q:776329498
* @param array $field_list
* @return bool
*/
protected function getByArray($field_list=[]){
$hash_key = $this->getHashKey();
if(!$hash_key){
return false;
}
if(empty($field_list)){
return false;
}
return $this->redisHash[$this->sn]->hMget($hash_key,$field_list);
}
/**
* 獲取指定字段值
* User: Mikkle
* Q Q:776329498
* @param $field
* @return bool
*/
protected function getByField($field){
$hash_key = $this->getHashKey();
if(!$hash_key){
return false;
}
if(empty($field)){
return false;
}
return $this->redisHash[$this->sn]->hGet($hash_key,$field);
}
/**
* 獲取全部字段值
* User: Mikkle
* Q Q:776329498
* @return bool
*/
protected function getAll(){
$hash_key = $this->getHashKey();
if(!$hash_key){
return false;
}
return $this->redisHash[$this->sn]->hGetAll($hash_key);
}
/**
* 直接設置HashKey值
* Power: Mikkle
* Email:776329498@qq.com
* @param $hash_key
* @return $this
*/
public function setHashKey($hash_key){
$this->redisHash[$this->sn]->hashKey=$this->redisHash[$this->sn]->prefix.$hash_key;
$this->redisHash[$this->sn]->table=null;
$this->redisHash[$this->sn]->key=null;
return $this;
}
/**
* 獲取HashKey值
* User: Mikkle
* Q Q:776329498
* @return bool|string
*/
protected function getHashKey()
{
try {
if (isset($this->redisHash[$this->sn]->hashKey)){
return $this->redisHash[$this->sn]->hashKey;
}
if (!isset($this->redisHash[$this->sn]->table) || !isset($this->redisHash[$this->sn]->key)) {
throw new Exception("數據表或者PK鍵未建立");
}
$this->redisHash[$this->sn]->hashKey = $this->redisHash[$this->sn]->table . ":" . $this->redisHash[$this->sn]->key;
return $this->redisHash[$this->sn]->prefix .$this->redisHash[$this->sn]->table . ":" . $this->redisHash[$this->sn]->key;
} catch (Exception $e) {
return false;
}
}
public function keys($pattern=""){
if(!empty($pattern)){
return $this->redisHash[$this->sn]->keys($pattern);
}
elseif(empty($pattern)&&isset($this->redisHash[$this->sn]->table)){
return $this->redisHash[$this->sn]->keys($this->redisHash[$this->sn]->table.":*");
}else{
return $this->redisHash[$this->sn]->keys("*");
}
return false;
}
public function delete($hashKey1, $hashKey2 = null, $hashKeyN = null){
$key = $this->getHashKey();
return $this->redisHash[$this->sn]->hDel( $key,$hashKey1, $hashKey2, $hashKeyN );
}
public function deleteByKey($key1=null, $key2 = null, $key3 = null ) {
$key1 = empty($key1)?$this->getHashKey():$key1;
return $this->redisHash[$this->sn]->delete( $key1, $key2 , $key3 );
}
public function clear($pattern="") {
if(!empty($pattern)){
return $this->redisHash[$this->sn]->delete($this->keys($pattern));
}
if(empty($pattern)&&isset($this->redisHash[$this->sn]->table)){
return $this->redisHash[$this->sn]->delete($this->keys($this->redisHash[$this->sn]->table.":*"));
}
return false;
}
public function clearAll() {
return $this->redisHash[$this->sn]->flushDB();
}
/**
* 魔術方法 有不存在的操作的時候執行
* @access public
* @param string $method 方法名
* @param array $args 參數
* @return mixed
*/
public function __call($method, $args)
{
call_user_func_array([$this->redisHash[$this->sn], $method], $args);
}
}
~~~
- 序言及更新日志
- 前言一 開發PHP必備的環境(你可以不看)
- LinUX系統ThinkPHP5鏈接MsSQL數據庫的pdo_dblib擴展
- centos7.2掛載硬盤攻略
- Centos系統Redis安裝及Redis的PHP擴展安裝
- Centos系統增加Swap(系統交換區)的方法
- 前言二 開發PHP軟件配置和介紹(你依然可以不看)
- 數據庫SQL文件
- 本地Git(版本控制)的搭建
- GIT遠程倉庫的克隆和推送
- Git常用命令
- PHP面向對象思想實戰經驗領悟
- PHP面向對象實戰----命名空間
- PHP面向對象實戰----繼承
- 基類實戰--底層方法封裝
- 基類實戰--構造函數實戰
- 基類實戰--析構函數的使用
- TP5實戰開發前篇---控制器(controller)
- 控制器中Request類的使用
- 控制器中基類的使用
- TP5實戰開發前篇---模型篇(model)
- TP5實戰開發前篇---驗證器篇(Validate)
- TP5實戰課程入門篇---花拳繡腿
- 模塊以及類的文件的建立
- Api開發------單條信息顯示
- Api開發---單條信息復雜關聯顯示
- Api開發---查詢信息緩存Cache的應用
- TP5實戰技巧---開發思路 引路造橋
- TP5實戰技巧---整合基類 化繁為簡
- TP5實戰課程入門篇---數據操作
- Api開發---數據的添加和修改
- API開發---快速開發API通用接口
- TP5專用微信sdk使用教程
- THINKPHP5微信SDK更新記錄及升級指導
- TP5專用SDK 微信參數配置方法
- 微信公眾號推送接口對接教程
- 微信推送接口對接示例含掃描登錄微信端部分
- TP5專用微信支付SDK使用簡介
- TP5專用支付寶支付SDK使用說明
- 使用NW將開發的網站打包成桌面應用
- TP5高階實戰課程 進階篇概述
- 進階篇一 實戰開發之習慣及要求
- 進階篇二 實戰開發之控制器
- 控制器基類之控制器基類使用方法
- 控制器基類之控制器基類常用方法分享
- 控制器基類之構造函數的使用方法
- 進階篇三 實戰開發之權限控制
- TP5實戰源碼 --- 全局用戶信息驗證類Auth
- TP5實戰源碼 --- 微信Auth實戰開發源碼
- 進階篇四 實戰開發之模型
- 模型基類之模型基類的用途
- 模型基類之常用數據處理方法
- 模型邏輯層之實戰代碼(含事務)
- 模型實戰開發之模型常用方法
- 模型實戰源碼 --- 樂觀鎖的應用
- 模型實戰技巧---Model事件功能的使用
- 模型事件實戰應用---數據庫操作日志
- 進階篇五 實戰開發之緩存(Cache)
- TP5實戰源碼---應用緩存獲取城市信息
- TP5實戰源碼---應用緩存獲取分類詳情
- 進階篇六 TP5類庫的封裝和使用
- DataEdit快捷操作類庫
- ShowCode快捷使用類庫
- 阿里大于 短信API接口 TP5專用類庫
- DatabaseUpgrade數據庫對比及更新類庫
- AuthWeb權限類使用說明
- 進階篇七 服務層的應用
- 服務層源碼示例
- 服務層基類源碼
- 進階篇八 應用層Redis數據處理基類
- Redis服務層基類源碼
- 進階篇九 使用Redis類庫處理一般的搶購(秒殺)活動示例
- 進階篇十 某大型項目應用本Redis類源碼示例(含事務 樂觀鎖)
- 進階篇十一 邏輯層的應用
- 邏輯層基類源碼
- 進階篇 服務層代碼示例
- 高階實戰課程 進階篇持續新增中
- 高階篇一 TP5命令行之守護任務源碼
- TP5實戰源碼 --- 命令行
- TP5實戰源碼 --- 通過shell建立PHP守護程序
- 高階篇二 使用Redis隊列發送微信模版消息
- 高階篇二 之 Worker隊列基類源碼
- 高階篇三 TP5實戰之Redis緩存應用
- Redis實戰源碼之Hash專用類庫源碼
- Redis實戰源碼之Model類結合
- Redis實戰源碼之模型Hash基類源碼
- Redis實戰源碼之Hash查詢使用技巧
- Redis實戰源碼之 shell腳本中redis賦值和取值
- 高階篇四 Swoole的實戰應用
- swoole基類代碼
- Swoole擴展WebsocketServer專用類
- 基于Swoole的多Room聊天室的程序
- Swoole守護服務shell源碼
- 高階篇五 命令行異步多進程隊列類的應用
- tp_worker類源碼
- WorkerBase
- WorkerCommand
- WorkerRedis
- Redis類
- CycleWorkBase
- WorkerHookBase異步鉤子
- 隊列日志SQL
- 高階篇六 定時執行隊列類庫以及使用方法
- 定時隊列類庫源碼
- 高階篇七 異步執行循環隊列類庫以及使用教程
- CycleWorkBase源碼
- 高階實戰課程 進階篇持續新增中
- Extend便捷類庫源碼庫
- 阿里相關類庫
- SendSms--驗證碼API接口文件
- 權限相關類庫目錄
- AuthWeb 權限驗證類庫
- Redis便捷操作類庫(20171224更新)
- Redis
- Tools工具類庫集
- Curl類庫
- DataEdit
- Rand類庫
- ShowCode類庫
- Upload類庫
- 附件集合
- 附件一:微信支付 實戰開發源碼
- 微信支付類庫源代碼
- Common_util_pub.php
- DownloadBill_pub.php
- JsApi_pub.php
- NativeCall_pub.php
- NativeLink_pub.php
- OrderQuery_pub.php
- Refund_pub.php
- RefundQuery_pub.php
- SDKRuntimeException.php
- ShortUrl_pub.php
- UnifiedOrder_pub.php
- Wxpay_client_pub.php
- Wxpay_server_pub.php
- WxPayConf_pub.php
- 微信支付回調頁面源碼
- 附件二 順豐快遞BSP接口實戰開發源碼
- 順豐快遞BSP接口實戰開發源碼
- 順豐BSP基類
- 順豐BSP基礎代碼
- 順豐BSP下單接口
- 順豐BSP查單接口
- 順豐BSP確認/取消接口
- 附件三 APP注冊登陸接口源碼(含融云平臺接口)
- 附件四 TP5訂單Model(含事務 獲取器 修改器等方法)
- 附錄五 RSA加密解密
- Rsa文件源碼
- 附件六 阿里大于短信接口
- 附件七 AES加解密類
- AES加解密類源碼
- 附件八 TP5路由設置源碼
- 附件九 TP5 Excel導入導出下載便捷類庫
- Excel類庫TP5源碼
- 附件十 TP5便捷操作Redis類庫源碼
- TP5源碼 Redis操作便捷類庫
- 附件十一 TP5源碼 上傳文件入庫類源碼
- 上傳類Upload源碼
- Upload類上傳配置文件
- 存儲圖像文件的數據庫SQL文件
- 存儲文件的數據庫SQL文件
- 附件十二 TP5 圖片處理增強類 支持縮略圖在線顯示
- 附件十三 微信推送消息接口類庫源碼
- 附件十三 微信推送消息接口類庫源碼 之 基類
- 附件十四 存儲微信昵稱的處理方法