masyarakat
Belajar
Perpustakaan Alatan
Alat AI
Masa lapang
cari
Melayu
Jadual Kandungan
" >2. memcache.php 
Rumah 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));
    }
 }
Salin selepas log masuk

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());
Salin selepas log masuk

                           

       

Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn

Alat AI Hot

Undresser.AI Undress

Undresser.AI Undress

Apl berkuasa AI untuk mencipta foto bogel yang realistik

AI Clothes Remover

AI Clothes Remover

Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

Undress AI Tool

Undress AI Tool

Gambar buka pakaian secara percuma

Clothoff.io

Clothoff.io

Penyingkiran pakaian AI

Video Face Swap

Video Face Swap

Tukar muka dalam mana-mana video dengan mudah menggunakan alat tukar muka AI percuma kami!

Tunjukkan Lagi

Artikel Panas

<🎜>: Tumbuh Taman - Panduan Mutasi Lengkap
3 minggu yang lalu By DDD
<🎜>: Bubble Gum Simulator Infinity - Cara Mendapatkan dan Menggunakan Kekunci Diraja
3 minggu yang lalu By 尊渡假赌尊渡假赌尊渡假赌
Bagaimana untuk memperbaiki KB5055612 gagal dipasang di Windows 10?
3 minggu yang lalu By DDD
Putera Biru: Cara sampai ke ruangan bawah tanah
1 bulan yang lalu By DDD
Nordhold: Sistem Fusion, dijelaskan
3 minggu yang lalu By 尊渡假赌尊渡假赌尊渡假赌
Tunjukkan Lagi

Alat panas

Notepad++7.3.1

Notepad++7.3.1

Editor kod yang mudah digunakan dan percuma

SublimeText3 versi Cina

SublimeText3 versi Cina

Versi Cina, sangat mudah digunakan

Hantar Studio 13.0.1

Hantar Studio 13.0.1

Persekitaran pembangunan bersepadu PHP yang berkuasa

Dreamweaver CS6

Dreamweaver CS6

Alat pembangunan web visual

SublimeText3 versi Mac

SublimeText3 versi Mac

Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

Tunjukkan Lagi

Topik panas

Tutorial Java
1664
14
Tutorial CakePHP
1423
52
Tutorial Laravel
1321
25
Tutorial PHP
1269
29
Tutorial C#
1249
24
Tunjukkan Lagi