Gemeinschaft
Lernen
Tools-Bibliothek
KI-Tools
Freizeit
suchen
Deutsch
Inhaltsverzeichnis
" >2. memcache.php 
Heim php教程 PHP源码 memcache通用类 包括hash分配

memcache通用类 包括hash分配

PHP中文网
PHP中文网
May 23, 2016 am 08:39 AM

1.  class.php

<?php
namespace YBL;
class memcache
{
    protected $config = array();
    public $memcache_obj = &#39;&#39;;
    protected $host_list = &#39;&#39;;
    protected $connectFailures = 0;
    public function __construct($config = array())
    //默认配置
    {
        $this->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));
    }
 }
Nach dem Login kopieren

2. memcache.php 

 
<?php
namespace YBL;
require_once(&#39;../lib/memcache/class.php&#39;);
//====================================================================================
//默认配置
$dconfig  = 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分配方案
    //回调函数
    //参数 主机数组
    &#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());
Nach dem Login kopieren

                           

       

Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn

Heiße KI -Werkzeuge

Undresser.AI Undress

Undresser.AI Undress

KI-gestützte App zum Erstellen realistischer Aktfotos

AI Clothes Remover

AI Clothes Remover

Online-KI-Tool zum Entfernen von Kleidung aus Fotos.

Undress AI Tool

Undress AI Tool

Ausziehbilder kostenlos

Clothoff.io

Clothoff.io

KI-Kleiderentferner

Video Face Swap

Video Face Swap

Tauschen Sie Gesichter in jedem Video mühelos mit unserem völlig kostenlosen KI-Gesichtstausch-Tool aus!

Mehr anzeigen

Heißer Artikel

<🎜>: Wachsen Sie einen Garten - Komplette Mutationsführer
3 Wochen vor By DDD
<🎜>: Bubble Gum Simulator Infinity - So erhalten und verwenden Sie Royal Keys
3 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌
Wie kann ich KB5055612 in Windows 10 nicht installieren?
3 Wochen vor By DDD
Nordhold: Fusionssystem, erklärt
3 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌
Mandragora: Flüstern des Hexenbaum
3 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌
Mehr anzeigen

Heiße Werkzeuge

Notepad++7.3.1

Notepad++7.3.1

Einfach zu bedienender und kostenloser Code-Editor

SublimeText3 chinesische Version

SublimeText3 chinesische Version

Chinesische Version, sehr einfach zu bedienen

Senden Sie Studio 13.0.1

Senden Sie Studio 13.0.1

Leistungsstarke integrierte PHP-Entwicklungsumgebung

Dreamweaver CS6

Dreamweaver CS6

Visuelle Webentwicklungstools

SublimeText3 Mac-Version

SublimeText3 Mac-Version

Codebearbeitungssoftware auf Gottesniveau (SublimeText3)

Mehr anzeigen

Heiße Themen

Java-Tutorial
1664
14
CakePHP-Tutorial
1423
52
Laravel-Tutorial
1321
25
PHP-Tutorial
1269
29
C#-Tutorial
1249
24
Mehr anzeigen