/**

* FileName:RedisCluster

* 配置說明

* 配置為1主多從 或者 1個獨立的服務器

* 寫往主的里面寫

* 讀是從從的里面讀

* 'class'=>'RedisCache',

* 'servers'=>array(

* array(

* 'host'=>'IP1',

* 'port'=>'6380',

* 'master'=>true //主機

* ),

* array(

* 'host'=>'IP2',

* 'port'=>'6381'

* )

*

* 單獨

* 'class'=>'RedisCache',

* 'servers'=>array(

* array(

* 'host'=>'IP1',

* 'port'=>'6380',

* ),

* @author zhonghailin

* @version v1.0

* @since v1.0

* @Date 2015-3-10 下午4:57:02

*/

class ERedisCache extends CCache{

// 是否使用 M/S 的讀寫集群方案

private $_isUseCluster = false;

// Slave 句柄標記

private $_sn = 0;

// 服務器連接句柄

private $_linkHandle = array(

'master'=>null,// 只支持一臺 Master

'slave'=>array(),// 可以有多臺 Slave

);

//配置文件

private $_servers=array();

/**

* 構造函數

*

* @param boolean $isUseCluster 是否采用 M/S 方案

*/

/*

* 初始化

*/

public function init()

{

$this->keyPrefix = "";

parent::init();

if(is_array($this->_servers)){

foreach($this->_servers as $servers){

if($servers->master){

$this->_isUseCluster = true;//如果設置了主服務器那么就是1主多從

$this->connect($servers,true);

}else{

$this->connect($servers);

}

}

}

}

/**

* @return array list of memcache server configurations. Each element is a {@link CMemCacheServerConfiguration}.

*/

public function getServers()

{

return $this->_servers;

}

/**

* @param array $config list of memcache server configurations. Each element must be an array

* with the following keys: host, port, persistent, weight, timeout, retryInterval, status.

* @see http://www.php.net/manual/en/function.Memcache-addServer.php

*/

public function setServers($config)

{

foreach($config as $c)

$this->_servers[]=new CRedisServerConfiguration($c);

}

/**

* 連接服務器,注意：這里使用長連接，提高效率，但不會自動關閉

*

* @param array $config Redis服務器配置

* @param boolean $isMaster 當前添加的服務器是否為 Master 服務器

* @return boolean

*/

public function connect($config, $isMaster=false){

// 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 2:

if(!empty( $this->_linkHandle['master'])){

$this->_linkHandle['master']->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,$slaveOne=true){

// 只返回 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 setValue($key, $value, $expire=0){

// 永不超時

if($expire == 0){

if($this->_isUseCluster){

$ret = $this->getRedis()->set($key, $value);

}else{

$ret = $this->getRedis(false)->set($key, $value);

}

}else{

if($this->_isUseCluster){

$ret = $this->getRedis()->setex($key, $expire, $value);

}else{

$ret = $this->getRedis(false)->setex($key, $expire, $value);

}

}

return $ret;

}

/**

* 讀緩存

*

* @param string $key 緩存KEY,支持一次取多個 $key = array('key1','key2')

* @return string || boolean 失敗返回 false, 成功返回字符串

*/

public function getValue($key){

// 是否一次取多個值

$func = is_array($key) ? 'mGet' : 'get';

// 使用了 M/S

return $this->_getSlaveRedis()->{$func}($key);

}

/**

* 條件形式設置緩存，如果 key 不存時就設置，存在時設置失敗

*

* @param string $key 緩存KEY

* @param string $value 緩存值

* @return boolean

*/

public function setnx($key, $value){

if($this->_isUseCluster){

return $this->getRedis()->setnx($key, $value);

}else{

return $this->getRedis(false)->setnx($key, $value);

}

}

/**

* 刪除緩存

*

* @param string || array $key 緩存KEY，支持單個健:"key1" 或多個健:array('key1','key2')

* @return int 刪除的健的數量

*/

public function remove($key){

if($this->_isUseCluster){

return $this->getRedis()->delete($key);

}else{

return $this->getRedis(false)->delete($key);

}

}

/* (non-PHPdoc)

* @see BaseCache::delete()

*/

public function deleteValue($key){

if($this->_isUseCluster){

return $this->getRedis()->delete($key);

}else{

return $this->getRedis(false)->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(){

if(!empty( $this->_linkHandle['master'])){

$this->_linkHandle['master']->flushDB();

}

for($i=0; $i_sn; ++$i){

$this->_linkHandle['slave'][$i]->flushDB();

}

return true;

}

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

/**

* 隨機 HASH 得到 Redis Slave 服務器句柄

*

* @return redis object

*/

private function _getSlaveRedis(){

// 就一臺 Slave 機直接返回

if($this->_sn <= 1){

return $this->_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;$i$value)

$this->$key=$value;

if($this->host===null)

throw new CException(Yii::t('yii','CMemCache server configuration must have "host" value.'));

}

else

throw new CException(Yii::t('yii','CMemCache server configuration must be an array.'));

}

}

總結

以上是生活随笔為你收集整理的php redis 读写分离类,yii实现redis读写分离的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。