|
一、memcache缓存类文件:'ci\system\libraries\Cache\drivers\Cache_memcached.php'
<?php if ( ! defined('BASEPATH')) exit('No direct script access allowed');
/**
* CodeIgniter
*
* An open source application development framework for PHP 4.3.2 or newer
*
* @packageCodeIgniter
* @authorExpressionEngine Dev Team
* @copyrightCopyright (c) 2006 - 2012 EllisLab, Inc.
* @licensehttp://codeigniter.com/user_guide/license.html
* @linkhttp://codeigniter.com
* @sinceVersion 2.0
* @filesource
*/
// ------------------------------------------------------------------------
/**
* CodeIgniter Memcached Caching Class
*
* @packageCodeIgniter
* @subpackageLibraries
* @categoryCore
* @authorExpressionEngine Dev Team
* @link
*/
class CI_Cache_memcached extends CI_Driver {
private $_memcached;// Holds the memcached object
protected $_memcache_conf = array(
/*
'default' => array(
'default_host'=> '127.0.0.1',
'default_port'=> 11211,
'default_weight'=> 1
),
*/
);
function __construct()
{
if(!is_object($this->_memcached)) {
$this->_memcached = new Memcache;
$this->_memcached -> connect("127.0.0.1", 11211);
}
log_message('debug', '_memcached Driver Class Initialized');
}
// ------------------------------------------------------------------------
/**
* Fetch from cache
*
* @param mixedunique key id
* @return mixeddata on success/false on failure
*/
public function get($id)
{
$data = $this->_memcached->get($id);
return (is_array($data)) ? $data[0] : FALSE;
}
// ------------------------------------------------------------------------
/**
* Save
*
* @param stringunique identifier
* @param mixeddata being cached
* @param inttime to live
* @return boolean true on success, false on failure
*/
public function save($id, $data, $ttl = 60)
{
if (get_class($this->_memcached) == 'Memcached')
{
return $this->_memcached->set($id, array($data, time(), $ttl), $ttl);
}
else if (get_class($this->_memcached) == 'Memcache')
{
return $this->_memcached->set($id, array($data, time(), $ttl), 0, $ttl);
}
return FALSE;
}
// ------------------------------------------------------------------------
/**
* Delete from Cache
*
* @param mixedkey to be deleted.
* @return boolean true on success, false on failure
*/
public function delete($id)
{
return $this->_memcached->delete($id);
}
// ------------------------------------------------------------------------
/**
* Clean the Cache
*
* @return booleanfalse on failure/true on success
*/
public function clean()
{
return $this->_memcached->flush();
}
// ------------------------------------------------------------------------
/**
* Cache Info
*
* @param nulltype not supported in memcached
* @return mixed array on success, false on failure
*/
public function cache_info($type = NULL)
{
return $this->_memcached->getStats();
}
// ------------------------------------------------------------------------
/**
* Get Cache Metadata
*
* @param mixedkey to get cache metadata on
* @return mixedFALSE on failure, array on success.
*/
public function get_metadata($id)
{
$stored = $this->_memcached->get($id);
if (count($stored) !== 3)
{
return FALSE;
}
list($data, $time, $ttl) = $stored;
return array(
'expire'=> $time + $ttl,
'mtime'=> $time,
'data'=> $data
);
}
// ------------------------------------------------------------------------
/**
* Setup memcached.
*/
private function _setup_memcached()
{
// Try to load memcached server info from the config file.
$CI =& get_instance();
if ($CI->config->load('memcached', TRUE, TRUE))
{
$memcache_config = $CI->config->config['memcached']['memcached'];
if (is_array($memcache_config))
{
$this->_memcache_conf = NULL;
foreach ($memcache_config as $name => $conf)
{
$this->_memcache_conf[$name] = $conf;
}
}
}
$this->_memcached = new Memcached();
$this->_memcached->setOption(Memcached::OPT_HASH, Memcached::HASH_CRC);
$this->_memcached->setOption(Memcached::OPT_DISTRIBUTION, Memcached::DISTRIBUTION_CONSISTENT);
foreach ($this->_memcache_conf as $name => $cache_server)
{
if ( ! array_key_exists('hostname', $cache_server))
{
$cache_server['hostname'] = $this->_default_options['default_host'];
}
if ( ! array_key_exists('port', $cache_server))
{
$cache_server['port'] = $this->_default_options['default_port'];
}
if ( ! array_key_exists('weight', $cache_server))
{
$cache_server['weight'] = $this->_default_options['default_weight'];
}
$this->_memcached->addServer(
$cache_server['hostname'], $cache_server['port'], $cache_server['weight']
);
}
}
// ------------------------------------------------------------------------
/**
* Is supported
*
* Returns FALSE if memcached is not supported on the system.
* If it is, we setup the memcached object & return TRUE
*/
public function is_supported()
{
if ( ! extension_loaded('memcached'))
{
//log_message('error', 'The Memcached Extension must be loaded to use Memcached Cache.');
return FALSE;
}
$this->_setup_memcached();
return TRUE;
}
/**
* Replace the cache
*
* @param stringunique key
* @param mixeddata to store
* @param intlength of time (in seconds) the cache is valid
*- Default is 60 seconds
* @return booleantrue on success/false on failure
*/
public function replace($id, $data, $ttl = 60)
{
$result = $this->_memcached->replace($id, array($data, time(), $ttl), $ttl);
if($result === FALSE)
{
$result = $this->save($id, $data, $ttl);
}
return $result;
}
// ------------------------------------------------------------------------
}
// End Class
/* End of file Cache_memcached.php */
/* Location: ./system/libraries/Cache/drivers/Cache_memcached.php */
版权声明:本文为博主原创文章,未经博主允许不得转载。 |
|