memcache通用类包括hash分配-PHP源码

1. class.php

cOnfig= array(
            &＃39;host&＃39; => &＃39;127.0.0.1&＃39;,
            &＃39;port&＃39; => 11211,
            &＃39;persistent&＃39; => false,
            &＃39;weight&＃39; => 1,
            //超时时间
            &＃39;timeout&＃39; => 1,
            //重试间隔时间
            &＃39;retry_interval&＃39; => 15,
            &＃39;status&＃39; => false,
            //=============================
            //是否打开压缩
            &＃39;threshold&＃39; => 1,
            //压缩率
            &＃39;min_savings&＃39; => 0.2,
            //最大重试次数
            &＃39;max_connect_retries&＃39; => 5
        );
        //不带一致性hash分配方案
        if (!isset($config[&＃39;memcache_deploy&＃39;]) || !is_callable($config[&＃39;memcache_deploy&＃39;])) {
            $config[&＃39;memcache_deploy&＃39;] = array(
                __CLASS__,
                &＃39;default_memcache_deploy&＃39;
            );
        }
        //带一致性hash分配方案
        if (!isset($config[&＃39;memcache_hdeploy&＃39;]) || !is_callable($config[&＃39;memcache_hdeploy&＃39;])) {
            $config[&＃39;memcache_hdeploy&＃39;] = array(
                __CLASS__,
                &＃39;default_memcache_hdeploy&＃39;
            );
        }
        //错误处理
        if (!isset($config[&＃39;failure_callback&＃39;]) || !is_callable($config[&＃39;failure_callback&＃39;])) {
            $config[&＃39;failure_callback&＃39;] = array(
                __CLASS__,
                &＃39;default_error_hander&＃39;
            );
        }
        $this->cOnfig= array_merge($this->config, $config);
        $this->memcache_obj = new \Memcache;
    }
    public function host($host_list = &＃39;&＃39;)
    {
        $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 = &＃39;&＃39;)
    {
        static $node_object;
        if (!($node_object instanceof yhash)) {
            $cOnfig= array(
                //虚拟节点20个
                &＃39;replicas&＃39; => 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(
            &＃39;host&＃39; => $this->config[&＃39;host&＃39;],
            &＃39;port&＃39; => $this->config[&＃39;port&＃39;],
            &＃39;persistent&＃39; => $this->config[&＃39;persistent&＃39;],
            &＃39;weight&＃39; => $this->config[&＃39;weight&＃39;],
            &＃39;timeout&＃39; => $this->config[&＃39;timeout&＃39;],
            &＃39;retry_interval&＃39; => $this->config[&＃39;retry_interval&＃39;],
            &＃39;status&＃39; => $this->config[&＃39;status&＃39;],
            &＃39;failure_callback&＃39; => $this->config[&＃39;failure_callback&＃39;],
            &＃39;threshold&＃39; => $this->config[&＃39;threshold&＃39;],
            &＃39;min_savings&＃39; => $this->config[&＃39;min_savings&＃39;]
        );
        $failure_callback = &＃39;&＃39;;
        if (!empty($this->host_list)) {
            foreach ($this->host_list as $_host) {
                $_host = array_merge($default_host, $_host);
                $failure_callback = function($host = &＃39;&＃39;, $port = 11211) use ($_host)
                {
                    return call_user_func_array($_host[&＃39;failure_callback&＃39;], array(
                        $_host
                    ));
                };
                $this->memcache_obj->addServer($_host[&＃39;host&＃39;], $_host[&＃39;port&＃39;], $_host[&＃39;persistent&＃39;], $_host[&＃39;weight&＃39;], $_host[&＃39;timeout&＃39;], $_host[&＃39;retry_interval&＃39;], $_host[&＃39;status&＃39;], $failure_callback);
                if ($_host[&＃39;threshold&＃39;]) {
                    $this->memcache_obj->setCompressThreshold($_host[&＃39;threshold&＃39;], $_host[&＃39;min_savings&＃39;]);
                }
            }
        } else {
            $failure_callback = function($host = &＃39;&＃39;, $port = 11211) use ($default_host)
            {
                return call_user_func_array($default_host[&＃39;failure_callback&＃39;], array(
                    $default_host
                ));
            };
            $this->memcache_obj->addServer($default_host[&＃39;host&＃39;], $default_host[&＃39;port&＃39;], $default_host[&＃39;persistent&＃39;], $default_host[&＃39;weight&＃39;], $default_host[&＃39;timeout&＃39;], $default_host[&＃39;retry_interval&＃39;], $default_host[&＃39;status&＃39;], $failure_callback);
            if ($default_host[&＃39;threshold&＃39;]) {
                $this->memcache_obj->setCompressThreshold($default_host[&＃39;threshold&＃39;], $default_host[&＃39;min_savings&＃39;]);
            }
             
        }
    }
     
    public function link()
    {
        $default_host = &＃39;&＃39;;
        $host_no      = -1;
        $return       = false;
        $_host        = array();
        if (!empty($this->host_list)) {
            $host_no = call_user_func_array($this->config[&＃39;memcache_deploy&＃39;], array(
                $this->host_list
            ));
            $_host   = $this->host_list[$host_no];
        }
         
        $default_host = array(
            &＃39;host&＃39; => $this->config[&＃39;host&＃39;],
            &＃39;port&＃39; => $this->config[&＃39;port&＃39;],
            &＃39;persistent&＃39; => $this->config[&＃39;persistent&＃39;],
            //&＃39;weight&＃39;=>$this->config[&＃39;weight&＃39;],
            &＃39;timeout&＃39; => $this->config[&＃39;timeout&＃39;],
            &＃39;retry_interval&＃39; => $this->config[&＃39;retry_interval&＃39;],
            //&＃39;status&＃39;=>$this->config[&＃39;status&＃39;],
            &＃39;failure_callback&＃39; => $this->config[&＃39;failure_callback&＃39;],
            &＃39;threshold&＃39; => $this->config[&＃39;threshold&＃39;],
            &＃39;min_savings&＃39; => $this->config[&＃39;min_savings&＃39;]
        );
        $_host        = array_merge($default_host, $_host);
         
        if ($_host[&＃39;persistent&＃39;]) {
            $return = @$this->memcache_obj->pconnect($_host[&＃39;host&＃39;], $_host[&＃39;port&＃39;], $_host[&＃39;timeout&＃39;]);
        } else {
            $return = @$this->memcache_obj->connect($_host[&＃39;host&＃39;], $_host[&＃39;port&＃39;], $_host[&＃39;timeout&＃39;]);
        }
        if (!$return) {
            $this->connectFailures++;
            if ($this->connectFailures <= $this->config[&＃39;max_connect_retries&＃39;]) {
                if (count($this->host_list) > 1) {
                    call_user_func_array($_host[&＃39;failure_callback&＃39;], array(
                        $_host
                    ));
                    usleep($_host[&＃39;interval_time&＃39;]);
                    unset($this->host_list[$host_no]);
                    $this->link();
                } else {
                    $this->cOnnectFailures= 0;
                    call_user_func_array($_host[&＃39;failure_callback&＃39;], array(
                        $_host
                    ));
                }
            } else {
                $this->cOnnectFailures= 0;
                call_user_func_array($_host[&＃39;failure_callback&＃39;], array(
                    $_host
                ));
            }
        } else {
            $this->cOnnectFailures= 0;
            if ($_host[&＃39;threshold&＃39;]) {
                $this->memcache_obj->setCompressThreshold($_host[&＃39;threshold&＃39;], $_host[&＃39;min_savings&＃39;]);
            }
             
        }
    }
     
     
     
    public function hlink($hash = &＃39;&＃39;)
    {
         
        $default_host = &＃39;&＃39;;
        $host_no      = -1;
        $return       = false;
        $_host        = array();
        if (!empty($this->host_list)) {
            $host_no = call_user_func_array($this->config[&＃39;memcache_hdeploy&＃39;], array(
                $this->host_list,
                $hash
            ));
            $_host   = $this->host_list[$host_no];
        }
         
        $default_host = array(
            &＃39;host&＃39; => $this->config[&＃39;host&＃39;],
            &＃39;port&＃39; => $this->config[&＃39;port&＃39;],
            &＃39;persistent&＃39; => $this->config[&＃39;persistent&＃39;],
            //&＃39;weight&＃39;=>$this->config[&＃39;weight&＃39;],
            &＃39;timeout&＃39; => $this->config[&＃39;timeout&＃39;],
            &＃39;retry_interval&＃39; => $this->config[&＃39;retry_interval&＃39;],
            //&＃39;status&＃39;=>$this->config[&＃39;status&＃39;],
            &＃39;failure_callback&＃39; => $this->config[&＃39;failure_callback&＃39;],
            &＃39;threshold&＃39; => $this->config[&＃39;threshold&＃39;],
            &＃39;min_savings&＃39; => $this->config[&＃39;min_savings&＃39;],
            &＃39;hash&＃39; => $hash
        );
        $_host        = array_merge($default_host, $_host);
        if ($_host[&＃39;persistent&＃39;]) {
            $return = $this->memcache_obj->pconnect($_host[&＃39;host&＃39;], $_host[&＃39;port&＃39;], $_host[&＃39;timeout&＃39;]);
        } else {
            $return = $this->memcache_obj->connect($_host[&＃39;host&＃39;], $_host[&＃39;port&＃39;], $_host[&＃39;timeout&＃39;]);
        }
        if (!$return) {
             
            $this->cOnnectFailures= 0;
            call_user_func_array($_host[&＃39;failure_callback&＃39;], array(
                $_host
            ));
             
        } else {
             
            if ($_host[&＃39;threshold&＃39;]) {
                $this->memcache_obj->setCompressThreshold($_host[&＃39;threshold&＃39;], $_host[&＃39;min_savings&＃39;]);
            }
             
        }
    }
    /*
    type类型 值reset, malloc, maps, cachedump, slabs, items, sizes
    slabid slab的id
    limit 返回的最大条数
    */
    public function _server($type = &＃39;&＃39;, $slabid = 1, $limit = 1000000)
    {
        //$this->memcache_obj->close();
        if ($type === &＃39;&＃39;)
            return $this->memcache_obj->getStats();
        if ($type != &＃39;cachedump&＃39;)
            return $this->memcache_obj->getStats($type);
        return $this->memcache_obj->getStats($type, $slabid, $limit);
    }
    public function _allserver($type = &＃39;&＃39;, $slabid = 1, $limit = 1000000)
    {
        if ($type === &＃39;&＃39;)
            return $this->memcache_obj->getExtendedStats();
        if ($type != &＃39;cachedump&＃39;)
            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(&＃39;slabs&＃39;);
        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(&＃39;cachedump&＃39;, $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 === &＃39;all&＃39;) {
            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

 
 &＃39;127.0.0.1&＃39;,
    //端口
    &＃39;port&＃39; => 11211,
    //是否长连接
    &＃39;persistent&＃39; => false,
    //比重
    &＃39;weight&＃39; => 1,
    //超时时间
    &＃39;timeout&＃39; => 1,
    //重试间隔时间
    &＃39;retry_interval&＃39; => 15,
    //状态
    &＃39;status&＃39; => false,
    //=============================
    //是否打开压缩
    &＃39;threshold&＃39; => 1,
    //压缩率
    &＃39;min_savings&＃39; => 0.2,
    //最大重试次数
    &＃39;max_connect_retries&＃39; => 5,
    //不带一致性hash分配方案
    //回调函数
    //参数 主机数组
    &＃39;memcache_deploy&＃39; => &＃39;default_memcache_deploy&＃39;,
    //带一致性hash分配方案
    //回调函数
    //参数 主机数组 hash值
    &＃39;memcache_hdeploy&＃39; => &＃39;default_memcache_hdeploy&＃39;,
    //错误处理
    //回调函数
    //参数 主机数组
    &＃39;failure_callback&＃39; => &＃39;default_error_hander&＃39;
);
//====================================================================================
//连接
/*memcahe 三种连接方式
1.连接池addserver
2.普通connect/pconnect
3.带hash的connect/pconnect
*/
//1.连接池
$memcache = new memcache();
$host     = array(
    array(
        &＃39;host&＃39; => &＃39;localhost&＃39;,
        &＃39;port&＃39; => &＃39;11211&＃39;
    ),
    array(
        &＃39;host&＃39; => &＃39;127.0.0.1&＃39;,
        &＃39;port&＃39; => &＃39;11211&＃39;
    ),
    array(
        &＃39;host&＃39; => &＃39;localhost&＃39;,
        &＃39;port&＃39; => &＃39;11212&＃39;
    ),
    array(
        &＃39;host&＃39; => &＃39;127.0.0.1&＃39;,
        &＃39;port&＃39; => &＃39;11212&＃39;
    )
);
$memcache->host($host);
$memcache->alink();
//print_r($memcache->_allserver());
//-------------------------------------------------------------
//2.普通connect/pconnect
$memcache2 = new memcache();
$host      = array(
    array(
        &＃39;host&＃39; => &＃39;localhost&＃39;,
        &＃39;port&＃39; => &＃39;11211&＃39;
    ),
    array(
        &＃39;host&＃39; => &＃39;127.0.0.1&＃39;,
        &＃39;port&＃39; => &＃39;11211&＃39;
    ),
    array(
        &＃39;host&＃39; => &＃39;localhost&＃39;,
        &＃39;port&＃39; => &＃39;11212&＃39;
    ),
    array(
        &＃39;host&＃39; => &＃39;127.0.0.1&＃39;,
        &＃39;port&＃39; => &＃39;11212&＃39;
    )
);
$memcache2->host($host);
$memcache2->link();
//print_r($memcache2->_allserver());
//--------------------------------------------------------------
//3.带hash的connect/pconnect
//导入算法类
include(&＃39;../lib/hash/class.php&＃39;);
$memcache3 = new memcache();
$host      = array(
    array(
        &＃39;host&＃39; => &＃39;localhost&＃39;,
        &＃39;port&＃39; => &＃39;11211&＃39;
    ),
    array(
        &＃39;host&＃39; => &＃39;127.0.0.1&＃39;,
        &＃39;port&＃39; => &＃39;11211&＃39;
    ),
    array(
        &＃39;host&＃39; => &＃39;localhost&＃39;,
        &＃39;port&＃39; => &＃39;11211&＃39;
    ),
    array(
        &＃39;host&＃39; => &＃39;127.0.0.1&＃39;,
        &＃39;port&＃39; => &＃39;11211&＃39;
    )
);
$memcache3->host($host);
//$memcache3->hlink(&＃39;233ybl&＃39;);
//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(&＃39;32ybl&＃39;);
$memcache3->set(&＃39;32ybl&＃39;, 55);
//$memcache3->increment(&＃39;32ybl&＃39;,333);
echo $memcache3->get(&＃39;32ybl&＃39;);
//======================================================================
//系统函数
//获取当前连接服务器信息
//_server($type = &＃39;&＃39;, $slabid = 1, $limit = 1000000)
//获取所有连接服务器信息
//_allserver($type = &＃39;&＃39;, $slabid = 1, $limit = 1000000)
//获取所有key名
//getallkey($limit=1000000)
var_dump($memcache->getallkey());