Memcache 操作PHP類

jopen 11年前發布 | 75K 次閱讀緩存服務器 memcached
<?php
/**

Memcache 操作類
*
在config文件中 添加 
  相應配置(可擴展為多memcache server)
 define('MEMCACHE_HOST', '10.35.52.33');
 define('MEMCACHE_PORT', 11211);
 define('MEMCACHE_EXPIRATION', 0);
 define('MEMCACHE_PREFIX', 'licai');
 define('MEMCACHE_COMPRESSION', FALSE);
 demo:
 $cacheObj = new framework_base_memcached();         
 $cacheObj -> set('keyName','this is value');
 $cacheObj -> get('keyName');
 exit;

@access  public
@return  object
@date    2012-07-02
*/
class framework_base_memcached{


private $local_cache = array();
private $m;
private $client_type;
protected $errors = array();


public function __construct()
{
    $this->client_type = class_exists('Memcache') ? "Memcache" : (class_exists('Memcached') ? "Memcached" : FALSE);

    if($this->client_type)
    {
        // 判斷引入類型
        switch($this->client_type)
        {
            case 'Memcached':
                $this->m = new Memcached();
                break;
            case 'Memcache':
                $this->m = new Memcache();
                // if (auto_compress_tresh){
                    // $this->setcompressthreshold(auto_compress_tresh, auto_compress_savings);
                // }
                break;
        }
        $this->auto_connect();   
    }
    else
    {
        echo 'ERROR: Failed to load Memcached or Memcache Class (∩_∩)';
        exit;
    }
}

/**
 * @Name: auto_connect
 * @param:none
 * @todu 連接memcache server
 * @return : none
 * add by cheng.yafei
**/
private function auto_connect()
{
    $configServer = array(
                            'host' => MEMCACHE_HOST, 
                            'port' => MEMCACHE_PORT, 
                            'weight' => 1, 
                        );
    if(!$this->add_server($configServer)){
        echo 'ERROR: Could not connect to the server named '.MEMCACHE_HOST;
    }else{
        //echo 'SUCCESS:Successfully connect to the server named '.MEMCACHE_HOST;   
    }
}

/**
 * @Name: add_server
 * @param:none
 * @todu 連接memcache server
 * @return : TRUE or FALSE
 * add by cheng.yafei
**/
public function add_server($server){
    extract($server);
    return $this->m->addServer($host, $port, $weight);
}

/**
 * @Name: add_server
 * @todu 添加
 * @param:$key key
 * @param:$value 值
 * @param:$expiration 過期時間
 * @return : TRUE or FALSE
 * add by cheng.yafei
**/
public function add($key = NULL, $value = NULL, $expiration = 0)
{
    if(is_null($expiration)){
        $expiration = MEMCACHE_EXPIRATION;
    }
    if(is_array($key))
    {
        foreach($key as $multi){
            if(!isset($multi['expiration']) || $multi['expiration'] == ''){
                $multi['expiration'] = MEMCACHE_EXPIRATION;
            }
            $this->add($this->key_name($multi['key']), $multi['value'], $multi['expiration']);
        }
    }else{
        $this->local_cache[$this->key_name($key)] = $value;
        switch($this->client_type){
            case 'Memcache':
                $add_status = $this->m->add($this->key_name($key), $value, MEMCACHE_COMPRESSION, $expiration);
                break;

            default:
            case 'Memcached':
                $add_status = $this->m->add($this->key_name($key), $value, $expiration);
                break;
        }

        return $add_status;
    }
}

/**
 * @Name   與add類似,但服務器有此鍵值時仍可寫入替換
 * @param  $key key
 * @param  $value 值
 * @param  $expiration 過期時間
 * @return TRUE or FALSE
 * add by cheng.yafei
**/
public function set($key = NULL, $value = NULL, $expiration = NULL)
{
    if(is_null($expiration)){
        $expiration = MEMCACHE_EXPIRATION;
    }
    if(is_array($key))
    {
        foreach($key as $multi){
            if(!isset($multi['expiration']) || $multi['expiration'] == ''){
                $multi['expiration'] = $this->config['config']['expiration'];
            }
            $this->set($this->key_name($multi['key']), $multi['value'], $multi['expiration']);
        }
    }else{
        $this->local_cache[$this->key_name($key)] = $value;
        switch($this->client_type){
            case 'Memcache':
                $add_status = $this->m->set($this->key_name($key), $value, MEMCACHE_COMPRESSION, $expiration);
                break;
            case 'Memcached':
                $add_status = $this->m->set($this->key_name($key), $value, $expiration);
                break;
        }
        return $add_status;
    }
}

/**
 * @Name   get 根據鍵名獲取值
 * @param  $key key
 * @return array OR json object OR string...
 * add by cheng.yafei
**/
public function get($key = NULL)
{
    if($this->m)
    {
        if(isset($this->local_cache[$this->key_name($key)]))
        {
            return $this->local_cache[$this->key_name($key)];
        }
        if(is_null($key)){
            $this->errors[] = 'The key value cannot be NULL';
            return FALSE;
        }

        if(is_array($key)){
            foreach($key as $n=>$k){
                $key[$n] = $this->key_name($k);
            }
            return $this->m->getMulti($key);
        }else{
            return $this->m->get($this->key_name($key));
        }
    }else{
        return FALSE;
    }       
}

/**
 * @Name   delete
 * @param  $key key
 * @param  $expiration 服務端等待刪除該元素的總時間
 * @return true OR false
 * add by cheng.yafei
**/
public function delete($key, $expiration = NULL)
{
    if(is_null($key))
    {
        $this->errors[] = 'The key value cannot be NULL';
        return FALSE;
    }

    if(is_null($expiration))
    {
        $expiration = MEMCACHE_EXPIRATION;
    }

    if(is_array($key))
    {
        foreach($key as $multi)
        {
            $this->delete($multi, $expiration);
        }
    }
    else
    {
        unset($this->local_cache[$this->key_name($key)]);
        return $this->m->delete($this->key_name($key), $expiration);
    }
}

/**
 * @Name   replace
 * @param  $key 要替換的key
 * @param  $value 要替換的value
 * @param  $expiration 到期時間
 * @return none
 * add by cheng.yafei
**/
public function replace($key = NULL, $value = NULL, $expiration = NULL)
{
    if(is_null($expiration)){
        $expiration = MEMCACHE_EXPIRATION;
    }
    if(is_array($key)){
        foreach($key as $multi) {
            if(!isset($multi['expiration']) || $multi['expiration'] == ''){
                $multi['expiration'] = $this->config['config']['expiration'];
            }
            $this->replace($multi['key'], $multi['value'], $multi['expiration']);
        }
    }else{
        $this->local_cache[$this->key_name($key)] = $value;

        switch($this->client_type){
            case 'Memcache':
                $replace_status = $this->m->replace($this->key_name($key), $value, MEMCACHE_COMPRESSION, $expiration);
                break;
            case 'Memcached':
                $replace_status = $this->m->replace($this->key_name($key), $value, $expiration);
                break;
        }

        return $replace_status;
    }
}

/**
 * @Name   replace 清空所有緩存
 * @return none
 * add by cheng.yafei
**/
public function flush()
{
    return $this->m->flush();
}

/**
 * @Name   獲取服務器池中所有服務器的版本信息
**/
public function getversion()
{
    return $this->m->getVersion();
}


/**
 * @Name   獲取服務器池的統計信息
**/
public function getstats($type="items")
{
    switch($this->client_type)
    {
        case 'Memcache':
            $stats = $this->m->getStats($type);
            break;

        default:
        case 'Memcached':
            $stats = $this->m->getStats();
            break;
    }
    return $stats;
}

/**
 * @Name: 開啟大值自動壓縮
 * @param:$tresh 控制多大值進行自動壓縮的閾值。
 * @param:$savings 指定經過壓縮實際存儲的值的壓縮率，值必須在0和1之間。默認值0.2表示20%壓縮率。
 * @return : true OR false
 * add by cheng.yafei
**/
public function setcompressthreshold($tresh, $savings=0.2)
{
    switch($this->client_type)
    {
        case 'Memcache':
            $setcompressthreshold_status = $this->m->setCompressThreshold($tresh, $savings=0.2);
            break;

        default:
            $setcompressthreshold_status = TRUE;
            break;
    }
    return $setcompressthreshold_status;
}

/**
 * @Name: 生成md5加密后的唯一鍵值
 * @param:$key key
 * @return : md5 string
 * add by cheng.yafei
**/
private function key_name($key)
{
    return md5(strtolower(MEMCACHE_PREFIX.$key));
}

/**
 * @Name: 向已存在元素后追加數據
 * @param:$key key
 * @param:$value value
 * @return : true OR false
 * add by cheng.yafei
**/
public function append($key = NULL, $value = NULL)
{



//      if(is_array($key))
//      {
//          foreach($key as $multi)
//          {
//
//              $this->append($multi['key'], $multi['value']);
//          }
//      }
//      else
//      {
            $this->local_cache[$this->key_name($key)] = $value;

        switch($this->client_type)
        {
            case 'Memcache':
                $append_status = $this->m->append($this->key_name($key), $value);
                break;

            default:
            case 'Memcached':
                $append_status = $this->m->append($this->key_name($key), $value);
                break;
        }

        return $append_status;

//      }
    }//END append
}// END class
?></pre>
本文由用戶 jopen 自行上傳分享，僅供網友學習交流。所有權歸原作者，若您的權利被侵害，請聯系管理員。
轉載本站原創文章，請注明出處，并保留原始鏈接、圖片水印。
本站是一個以用戶分享為主的開源技術平臺，歡迎各類分享！
本文地址：http://www.baiduhome.net/lib/view/open1372842855097.html
緩存服務器 memcached
Memcache 操作PHP類

相關經驗

相關資訊

相關文檔

目錄
