memcache通用类包括hash分配-PHP源码
1. class.php
config = array(
'host' => '127.0.0.1',
'port' => 11211,
'persistent' => false,
'weight' => 1,
//超时时间
'timeout' => 1,
//重试间隔时间
'retry_interval' => 15,
'status' => false,
//=============================
//是否打开压缩
'threshold' => 1,
//压缩率
'min_savings' => 0.2,
//最大重试次数
'max_connect_retries' => 5
);
//不带一致性hash分配方案
if (!isset($config['memcache_deploy']) || !is_callable($config['memcache_deploy'])) {
$config['memcache_deploy'] = array(
__CLASS__,
'default_memcache_deploy'
);
}
//带一致性hash分配方案
if (!isset($config['memcache_hdeploy']) || !is_callable($config['memcache_hdeploy'])) {
$config['memcache_hdeploy'] = array(
__CLASS__,
'default_memcache_hdeploy'
);
}
//错误处理
if (!isset($config['failure_callback']) || !is_callable($config['failure_callback'])) {
$config['failure_callback'] = array(
__CLASS__,
'default_error_hander'
);
}
$this->config = array_merge($this->config, $config);
$this->memcache_obj = new \Memcache;
}
public function host($host_list = '')
{
$this->host_list = $host_list;
return $this;
}
//默认错误处理
static public function default_error_hander($host = array())
//var_dump($host);
{
}
static public function default_memcache_hdeploy($host, $hash = '')
{
static $node_object;
if (!($node_object instanceof yhash)) {
$config = array(
//虚拟节点20个
'replicas' => 20
);
$node_object = new yhash($config);
//添加节点
$node_object->addTargets(array_keys($host));
}
return $node_object->lookup($hash);
}
static public function default_memcache_deploy($host)
{
$keys = array_keys($host);
$key = array_rand($keys, 1);
return $keys[$key];
}
public function alink()
{
$default_host = array(
'host' => $this->config['host'],
'port' => $this->config['port'],
'persistent' => $this->config['persistent'],
'weight' => $this->config['weight'],
'timeout' => $this->config['timeout'],
'retry_interval' => $this->config['retry_interval'],
'status' => $this->config['status'],
'failure_callback' => $this->config['failure_callback'],
'threshold' => $this->config['threshold'],
'min_savings' => $this->config['min_savings']
);
$failure_callback = '';
if (!empty($this->host_list)) {
foreach ($this->host_list as $_host) {
$_host = array_merge($default_host, $_host);
$failure_callback = function($host = '', $port = 11211) use ($_host)
{
return call_user_func_array($_host['failure_callback'], array(
$_host
));
};
$this->memcache_obj->addServer($_host['host'], $_host['port'], $_host['persistent'], $_host['weight'], $_host['timeout'], $_host['retry_interval'], $_host['status'], $failure_callback);
if ($_host['threshold']) {
$this->memcache_obj->setCompressThreshold($_host['threshold'], $_host['min_savings']);
}
}
} else {
$failure_callback = function($host = '', $port = 11211) use ($default_host)
{
return call_user_func_array($default_host['failure_callback'], array(
$default_host
));
};
$this->memcache_obj->addServer($default_host['host'], $default_host['port'], $default_host['persistent'], $default_host['weight'], $default_host['timeout'], $default_host['retry_interval'], $default_host['status'], $failure_callback);
if ($default_host['threshold']) {
$this->memcache_obj->setCompressThreshold($default_host['threshold'], $default_host['min_savings']);
}
}
}
public function link()
{
$default_host = '';
$host_no = -1;
$return = false;
$_host = array();
if (!empty($this->host_list)) {
$host_no = call_user_func_array($this->config['memcache_deploy'], array(
$this->host_list
));
$_host = $this->host_list[$host_no];
}
$default_host = array(
'host' => $this->config['host'],
'port' => $this->config['port'],
'persistent' => $this->config['persistent'],
//'weight'=>$this->config['weight'],
'timeout' => $this->config['timeout'],
'retry_interval' => $this->config['retry_interval'],
//'status'=>$this->config['status'],
'failure_callback' => $this->config['failure_callback'],
'threshold' => $this->config['threshold'],
'min_savings' => $this->config['min_savings']
);
$_host = array_merge($default_host, $_host);
if ($_host['persistent']) {
$return = @$this->memcache_obj->pconnect($_host['host'], $_host['port'], $_host['timeout']);
} else {
$return = @$this->memcache_obj->connect($_host['host'], $_host['port'], $_host['timeout']);
}
if (!$return) {
$this->connectFailures++;
if ($this->connectFailures <= $this->config['max_connect_retries']) {
if (count($this->host_list) > 1) {
call_user_func_array($_host['failure_callback'], array(
$_host
));
usleep($_host['interval_time']);
unset($this->host_list[$host_no]);
$this->link();
} else {
$this->connectFailures = 0;
call_user_func_array($_host['failure_callback'], array(
$_host
));
}
} else {
$this->connectFailures = 0;
call_user_func_array($_host['failure_callback'], array(
$_host
));
}
} else {
$this->connectFailures = 0;
if ($_host['threshold']) {
$this->memcache_obj->setCompressThreshold($_host['threshold'], $_host['min_savings']);
}
}
}
public function hlink($hash = '')
{
$default_host = '';
$host_no = -1;
$return = false;
$_host = array();
if (!empty($this->host_list)) {
$host_no = call_user_func_array($this->config['memcache_hdeploy'], array(
$this->host_list,
$hash
));
$_host = $this->host_list[$host_no];
}
$default_host = array(
'host' => $this->config['host'],
'port' => $this->config['port'],
'persistent' => $this->config['persistent'],
//'weight'=>$this->config['weight'],
'timeout' => $this->config['timeout'],
'retry_interval' => $this->config['retry_interval'],
//'status'=>$this->config['status'],
'failure_callback' => $this->config['failure_callback'],
'threshold' => $this->config['threshold'],
'min_savings' => $this->config['min_savings'],
'hash' => $hash
);
$_host = array_merge($default_host, $_host);
if ($_host['persistent']) {
$return = $this->memcache_obj->pconnect($_host['host'], $_host['port'], $_host['timeout']);
} else {
$return = $this->memcache_obj->connect($_host['host'], $_host['port'], $_host['timeout']);
}
if (!$return) {
$this->connectFailures = 0;
call_user_func_array($_host['failure_callback'], array(
$_host
));
} else {
if ($_host['threshold']) {
$this->memcache_obj->setCompressThreshold($_host['threshold'], $_host['min_savings']);
}
}
}
/*
type类型 值reset, malloc, maps, cachedump, slabs, items, sizes
slabid slab的id
limit 返回的最大条数
*/
public function _server($type = '', $slabid = 1, $limit = 1000000)
{
//$this->memcache_obj->close();
if ($type === '')
return $this->memcache_obj->getStats();
if ($type != 'cachedump')
return $this->memcache_obj->getStats($type);
return $this->memcache_obj->getStats($type, $slabid, $limit);
}
public function _allserver($type = '', $slabid = 1, $limit = 1000000)
{
if ($type === '')
return $this->memcache_obj->getExtendedStats();
if ($type != 'cachedump')
return $this->memcache_obj->getExtendedStats($type);
return $this->memcache_obj->getExtendedStats($type, $slabid, $limit);
}
public function close()
{
return $this->memcache_obj->close();
}
public function slabid()
{
$ids = $id = array();
$ids = $this->memcache_obj->getStats('slabs');
foreach ($ids as $k => $v) {
if (is_int($k)) {
$id[] = $k;
}
}
return $id;
}
//!!!!!!!!!!!============================================
public function getallkey($limit = 1000000)
{
$ids = $this->slabid();
$arr = array();
foreach ($ids as $id) {
$arr = array_merge(array_keys($this->memcache_obj->getStats('cachedump', $id, $limit)), $arr);
}
return $arr;
}
public function set($key, $var, $expire = 0, $flag = MEMCACHE_COMPRESSED)
{
return $this->memcache_obj->set($key, $var, $flag, $expire);
}
public function add($key, $var, $expire = 0, $flag = MEMCACHE_COMPRESSED)
{
return $this->memcache_obj->add($key, $var, $flag, $expire);
}
public function get($key, &$flag = 0)
{
$gflag = 0;
$return = $this->memcache_obj->get($key, $gflag);
$flag = $gflag;
return $return;
}
public function delete($key, $timeout = 0)
{
if ($key === 'all') {
return $this->memcache_obj->flush();
}
return $this->memcache_obj->delete($key, $timeout);
}
public function replace($key, $var, $expire = 0, $flag = MEMCACHE_COMPRESSED)
{
return $this->memcache_obj->replace($key, $var, $flag, $expire);
}
public function increment($key, $var)
{
return $this->memcache_obj->increment($key, (int) $var);
}
public function decrement($key, $var)
{
return $this->memcache_obj->decrement($key, (int) $var);
}
public function append($key, $var, $expire = 0, $flag = MEMCACHE_COMPRESSED)
{
$return = $this->memcache_obj->get($key);
if (empty($return))
return false;
return $this->memcache_obj->replace($key, $return . $var, $flag, $expire);
}
public function prepend($key, $var, $expire = 0, $flag = MEMCACHE_COMPRESSED)
{
$return = $this->memcache_obj->get($key);
if (empty($return))
return false;
return $this->memcache_obj->replace($key, $var . $return, $flag, $expire);
}
public function cas($key, $key2)
{
$return1 = $this->memcache_obj->get($key);
if (empty($return1))
return false;
$return2 = $this->memcache_obj->get($key2);
if (empty($return2))
return false;
return ($this->memcache_obj->replace($key, $return2)) && ($this->memcache_obj->replace($key2, $return));
}
}
2. memcache.php
'127.0.0.1',
//端口
'port' => 11211,
//是否长连接
'persistent' => false,
//比重
'weight' => 1,
//超时时间
'timeout' => 1,
//重试间隔时间
'retry_interval' => 15,
//状态
'status' => false,
//=============================
//是否打开压缩
'threshold' => 1,
//压缩率
'min_savings' => 0.2,
//最大重试次数
'max_connect_retries' => 5,
//不带一致性hash分配方案
//回调函数
//参数 主机数组
'memcache_deploy' => 'default_memcache_deploy',
//带一致性hash分配方案
//回调函数
//参数 主机数组 hash值
'memcache_hdeploy' => 'default_memcache_hdeploy',
//错误处理
//回调函数
//参数 主机数组
'failure_callback' => 'default_error_hander'
);
//====================================================================================
//连接
/*memcahe 三种连接方式
1.连接池addserver
2.普通connect/pconnect
3.带hash的connect/pconnect
*/
//1.连接池
$memcache = new memcache();
$host = array(
array(
'host' => 'localhost',
'port' => '11211'
),
array(
'host' => '127.0.0.1',
'port' => '11211'
),
array(
'host' => 'localhost',
'port' => '11212'
),
array(
'host' => '127.0.0.1',
'port' => '11212'
)
);
$memcache->host($host);
$memcache->alink();
//print_r($memcache->_allserver());
//-------------------------------------------------------------
//2.普通connect/pconnect
$memcache2 = new memcache();
$host = array(
array(
'host' => 'localhost',
'port' => '11211'
),
array(
'host' => '127.0.0.1',
'port' => '11211'
),
array(
'host' => 'localhost',
'port' => '11212'
),
array(
'host' => '127.0.0.1',
'port' => '11212'
)
);
$memcache2->host($host);
$memcache2->link();
//print_r($memcache2->_allserver());
//--------------------------------------------------------------
//3.带hash的connect/pconnect
//导入算法类
include('../lib/hash/class.php');
$memcache3 = new memcache();
$host = array(
array(
'host' => 'localhost',
'port' => '11211'
),
array(
'host' => '127.0.0.1',
'port' => '11211'
),
array(
'host' => 'localhost',
'port' => '11211'
),
array(
'host' => '127.0.0.1',
'port' => '11211'
)
);
$memcache3->host($host);
//$memcache3->hlink('233ybl');
//print_r($memcache3->_allserver());
//==================================================================================
//内置函数
//set($key, $var, $expire = 0, $flag = MEMCACHE_COMPRESSED)
//add($key, $var, $expire = 0, $flag = MEMCACHE_COMPRESSED)
//get($key, &$flag = 0)
//delete($key, $timeout = 0)
//replace($key, $var, $expire = 0, $flag = MEMCACHE_COMPRESSED)
//increment($key, $var)
//decrement($key, $var)
//append($key, $var, $expire = 0, $flag = MEMCACHE_COMPRESSED)
//prepend($key, $var, $expire = 0, $flag = MEMCACHE_COMPRESSED)
// cas($key, $key2)
$memcache3->hlink('32ybl');
$memcache3->set('32ybl', 55);
//$memcache3->increment('32ybl',333);
echo $memcache3->get('32ybl');
//======================================================================
//系统函数
//获取当前连接服务器信息
//_server($type = '', $slabid = 1, $limit = 1000000)
//获取所有连接服务器信息
//_allserver($type = '', $slabid = 1, $limit = 1000000)
//获取所有key名
//getallkey($limit=1000000)
var_dump($memcache->getallkey());
PHP之友评论