首頁 後端開發 php教程 PHPRedis封裝類別完整實例

PHPRedis封裝類別完整實例

Jul 29, 2016 am 09:00 AM
gt key return this

PHPRedis封裝類別完整實例

本文透過摘錄,主題為收藏經典。望一起分享共論。
class RedisCluster{
// 是否使用 M/S 的讀寫叢集方案
private is ster =false;/;/ lave priva te_sn = 0; // 伺服器連線句柄 private $_linkHandle = array( ‘master’=>null,// 只支援一台 Master ‘slave’=>array(),// 可以有多台 Slave );

<code>/**
 * 构造函数
 * @param boolean $isUseCluster 是否采用 M/S 方案
 */
public function __construct($isUseCluster=false){
    $this->_isUseCluster = $isUseCluster;
}
/**
 * 连接服务器,注意:这里使用长连接,提高效率,但不会自动关闭
 *
 * @param array $config Redis服务器配置
 * @param boolean $isMaster 当前添加的服务器是否为 Master 服务器
 * @return boolean
 */
public function connect($c $isMaster=true){
    // default port
    if(!isset($config['port'])){
        $config['port'] = 6379;
    }
    // 设置 Master 连接
    if($isMaster){
        $this->_linkHandle['master'] = new Redis();
        $ret = $this->_linkHandle['master']->pconnect($config['host'],$config['port']);
    }else{
        // 多个 Slave 连接
        $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:关闭 Master 1:关闭 Slave 2:关闭所有
 * @return boolean
 */
public function close($flag=2){
    switch($flag){
        // 关闭 Master
        case 0:
            $this->getRedis()->close();
            break;
        // 关闭 Slave
        case 1:
            for($i=0; $i_sn; ++$i){
                $this->_linkHandle['slave'][$i]->close();
            }
            break;
        // 关闭所有
        case 1:
            $this->getRedis()->close();
            for($i=0; $i_sn; ++$i){
                $this->_linkHandle['slave'][$i]->close();
            }
            break;
    }
    return true;
}
/**
 * 得到 Redis 原始对象可以有更多的操作
 *
 * @param boolean $isMaster 返回服务器的类型 true:返回Master false:返回Slave
 * @param boolean $slaveOne 返回的Slave选择 true:负载均衡随机返回一个Slave选择 false:返回所有的Slave选择
 * @return redis object
 */
public function getRedis($isMaster=true,$slave
    // 只返回 Master
    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 || 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);
}
/**
 * 条件形式设置缓存,如果 key 不存时就设置,存在时设置失败
 *
 * @param string $key 缓存KEY
 * @param string $value 缓存值
 * @return boolean
 */
public function setnx($key, $value){
    return $this->getRedis()->setnx($key, $value);
}
/**
 * 删除缓存
 *
 * @param string || array $key 缓存KEY,支持单个健:"key1" 或多个健:array('key1','key2')
 * @return int 删除的健的数量
 */
public function remove($key){
    // $key => "key1" || 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(){
    // 就一台 Slave 机直接返回
    if($this->_sn _linkHandle['slave'][0];
    }
    // 随机 Hash 得到 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;$igetRedis()->lpush($key,$value);
}
/**
 *  add lpop
 */
public function lpop($key){
    return $this->getRedis()->lpop($key);
}
/**
 * lrange
 */
public function lrange($key,$start,$end){
    return $this->getRedis()->lrange($key,$start,$end);
}
/**
 *  set hash opeation
 */
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);
}
/**
 *  get hash opeation
 */
public function hget($name,$key = null,$serialize=true){
    if($key){
        $row = $this->getRedis()->hget($name,$key);
        if($row && $serialize){
            unserialize($row);
        }
        return $row;
    }
    return $this->getRedis()->hgetAll($name);
}
/**
 *  delete hash opeation
 */
public function hdel($name,$key = null){
    if($key){
        return $this->getRedis()->hdel($name,$key);
    }
    return $this->getRedis()->hdel($name);
}
/**
 * Transaction start
 */
public function multi(){
    return $this->getRedis()->multi();
}
/**
 * Transaction send
 */
public function exec(){
    return $this->getRedis()->exec();
}
</code>
登入後複製
}').addClass('pre-numbering').hide(); $(this).addClass('has-numbering').parent().append($numbering); for (i = 1; i ').text(i)); }; $numbering.fadeIn(1700); }); }); 以上就介紹了PHPRedis封裝類別完整實例,包含了面向的內容,希望對PHP教學有興趣的朋友有幫助。

本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

AI Hentai Generator

AI Hentai Generator

免費產生 AI 無盡。

熱門文章

R.E.P.O.能量晶體解釋及其做什麼(黃色晶體)
2 週前 By 尊渡假赌尊渡假赌尊渡假赌
倉庫:如何復興隊友
4 週前 By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island冒險:如何獲得巨型種子
3 週前 By 尊渡假赌尊渡假赌尊渡假赌

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強大的PHP整合開發環境

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

SublimeText3 Mac版

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

華為GT3 Pro和GT4的差異是什麼? 華為GT3 Pro和GT4的差異是什麼? Dec 29, 2023 pm 02:27 PM

華為GT3 Pro和GT4的差異是什麼?

C語言return的用法詳解 C語言return的用法詳解 Oct 07, 2023 am 10:58 AM

C語言return的用法詳解

SQL中的identity屬性是什麼意思? SQL中的identity屬性是什麼意思? Feb 19, 2024 am 11:24 AM

SQL中的identity屬性是什麼意思?

SpringBoot怎麼監聽redis Key變化事件 SpringBoot怎麼監聽redis Key變化事件 May 26, 2023 pm 01:55 PM

SpringBoot怎麼監聽redis Key變化事件

修復:截圖工具在 Windows 11 中不起作用 修復:截圖工具在 Windows 11 中不起作用 Aug 24, 2023 am 09:48 AM

修復:截圖工具在 Windows 11 中不起作用

Java中return和finally語句的執行順序是怎樣的? Java中return和finally語句的執行順序是怎樣的? Apr 25, 2023 pm 07:55 PM

Java中return和finally語句的執行順序是怎樣的?

不可修補的 Yubico 二因素驗證金鑰漏洞破壞了大多數 Yubikey 5、安全金鑰和 YubiHSM 2FA 設備的安全性 不可修補的 Yubico 二因素驗證金鑰漏洞破壞了大多數 Yubikey 5、安全金鑰和 YubiHSM 2FA 設備的安全性 Sep 04, 2024 pm 06:32 PM

不可修補的 Yubico 二因素驗證金鑰漏洞破壞了大多數 Yubikey 5、安全金鑰和 YubiHSM 2FA 設備的安全性

redis批量刪除key值的問題怎麼解決 redis批量刪除key值的問題怎麼解決 May 31, 2023 am 08:59 AM

redis批量刪除key值的問題怎麼解決

See all articles