`
zhengdl126
  • 浏览: 2536492 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类

多台memcache 研究

阅读更多

第一种方法是通过设置特殊key前缀实现分布,基本可以实现memcache和key的一对多关系,好处在于不会混淆,代码如下:

<?php
$key='en_key2';
//print_r(mem_arr($key));
$mem_arr=mem_arr($key);
$mem = new Memcache;
$mem->connect($mem_arr['host'],$mem_arr['port']);
if(!$result=$mem->get('$key')){
	$mem->set($key, 'This is a memcached test!', 0, 60);
	$result=$mem->get($key);
  }
echo $result."---------".$mem_arr['host'].'--'.$mem_arr['port'];

function mem_arr($key)
{
	$memcached = array(  

	'cn'=>array('192.168.1.101',11212),

	'en'=>array('192.168.1.102',11212)

	);

	if(substr($key,0,2)=='cn')
	{
		$mem['host']=$memcached['cn'][0];
		$mem['port']=$memcached['cn'][1];
	}else
	{
		$mem['host']=$memcached['en'][0];
		$mem['port']=$memcached['en'][1];
	}
	return $mem;	
}


------------在102上查看
<?php
$mem = new Memcache;
$mem->connect("92.168.1.102", 11212);
$val = $mem->get('en_key2');
echo $val; 

?>

 

 

 

第二种方法是用的网上的一个方法,重写了memcache类,实现数组操作,这种方法对memcache服务器的扩展性不好

 

MemcacheOpt.class.php

<?php
/**
 * Memcache 操作类 (支持同步和分组访问)
 * author     : heiyeluren <http://blog.csdn.net/heiyeshuwu>
 * created    : 2007-06-21
 * lastModifed: 2007-06-21
 */

/** * Memcache操作类 */
class MemcacheOpt
{
    //---------------------
    //  属性定义
    //---------------------
    /**     * 是否进行多组同步      */
    var $isGroup    = true;
    /**
     * 多组同步情况下是否使用减轻负载的随机存取 
     */
    var $isRandom   = true;

    /** 默认的Memcache服务器端口  */
    var $mmcPort    = 11211;

    /** 保存原始组信息*/
    var $groups     = array();

    /** 保存第一、二组Memcache服务器信息*/
    var $group1     = array();
    var $group2     = array();
    /** * 保存第一、二组连接对象  */
    var $mmc1       = ''; 
    var $mmc2       = ''; 
    

    //---------------------
    //   内部操作方法
    //---------------------

    /** 显示错误信息     *
     * @param string $msg 需要显示消息的内容
     * @param string $type 消息类型,error是普通错误消息,fatal 是致命错误,将终止程序执行, message 是普通消息,缺省状

态
     * @return bool true
     */
    function showMessage($msg, $type){
        $msg .= " ";
        switch($type){
            case 'error':
                echo("Memcache Error: ". $msg);
                break;
            case 'fatal':
                die("Memcache Fatal: ". $msg);
                break;
            case 'message':
                echo("Memcache Message: ". $msg);
                break;
            default:
                echo("Memcache Error: ". $msg);
        }
        return true;
    }


    /**
     * 构造函数 (初始化分组和连接到服务器)
     */
    function MemcacheOpt($hostArray, $hostArray2=array()){
        if (!is_array($hostArray) || empty($hostArray)){
            $this->showMessage('Memcache host list invalid', 'fatal');
        }
        $this->groups = array_merge($hostArray, $hostArray2);
        $this->splitGroup($hostArray, $hostArray2);
        $this->connect();
    }

    /**
     * 对组进行切分 (按照是否需要分组进行相应的切分)
     *
     * @param array $hostArray 主机数组列表1
     * @param array $hostArray2 主机数组列表2
     * @return void
     */
    function splitGroup($hostArray, $hostArray2=array()){
        //如果只有一台机器则不使用分组
        if (count($hostArray) < 2 && empty($hostArray2)){  $this->isGroup = false;  }

        //使用分组
        if ($this->isGroup){
            if (is_array($hostArray2) && !empty($hostArray2)){
                $this->group1 = $hostArray;
                $this->group2 = $hostArray2;
            }else{
                $count = ceil(count($hostArray) / 2);
                $this->group1 = array_splice($hostArray, 0, $count);
                $this->group2 = array_splice($hostArray, 0);
            }
        }else{  $this->group1 = $hostArray;         } 
    }

    /**     * 连接到Memcache服务器     */
    function connect(){
        if (!is_array($this->group1) || empty($this->group1)){
            $this->showMessage("Memcache host1 array invalid", 'error');
            return false;
        }

        //连接第一组Memcache服务器
        $this->mmc1 = new Memcache;
        foreach($this->group1 as $hosts){
            $tmp = explode(":", $hosts);
            $host = $tmp[0];
            $port = (!isset($tmp[1]) || $tmp[1]=='') ? $this->mmcPort : $tmp[1];
            $this->mmc1->addServer($host, $port);
        }

        //如果需要分组则连接第二组Memcache服务器
        if ($this->isGroup){
            if ( !is_array($this->group2) || empty($this->group2) ){
                $this->showMessage("Memcache host2 array invalid", 'error');
                return false;
            }
            $this->mmc2 = new Memcache;
            foreach($this->group2 as $hosts){
                $tmp = explode(":", $hosts);
                $host = $tmp[0];
                $port = (!isset($tmp[1]) || $tmp[1]=='') ? $this->mmcPort : $tmp[1];
                $this->mmc2->addServer($host, $port);
            }
        }
    }

    /**     * 关闭Memcache服务器连接     */
    function close(){
        if (is_object($this->mmc1)){            $this->mmc1->close();        }
        if (is_object($this->mmc1)){            $this->mmc1->close();        }        
        return true;
    }

    /**
     * 数据操作核心函数
     *
     * @param string $optType 操作类型,主要有 add, set, replace, delete, flush
     * @param string $key 关键字,如果是 add,set,replace,delete 需要提交key参数
     * @param string $val 关键字对应的值,如果是 add, set,replace 需要提交value参数
     * @param int $expire 数据有效期,如果是 add,set,replace需要提交expire参数
     * @return mixed 不同的需要产生不同的返回
     */
    function opt($optType, $key='', $val='', $expire=''){
        if (!is_object($this->mmc1)){
            $this->showMessage("Not availability memcache connection object", 'fatal');
        }
        if ($this->isGroup && !is_object($this->mmc2)){
            $this->showMessage("Group 2 memcache host connection object not availability", 'error');
        }

        //加入数据操作
        if ($optType=='add' || $optType=='set' || $optType=='replace'){
            $this->mmc1->set($key, $val, false, $expire);
            if ($this->isGroup && is_object($this->mmc2)){
                $this->mmc2->set($key, $val, false, $expire);
            }
            return true;
        }

        //获取数据操作
        if ($optType == 'get'){

            //缺省获取第一组数据
            if (!$this->isGroup || !is_object($this->mmc2)){
                return $this->mmc1->get($key);        
            }

            //分组情况下逐组访问
            $num = ( $this->isRandom ? rand(1, 2) : 1 );
            $obj = "mmc". $num;
            $val = $this->$obj->get($key);

            //如果没有提取到数据,则访问另外一组
            if ($val == ""){
                switch($num){
                    case 1: $val = $this->mmc2->get($key); break;
                    case 2: $val = $this->mmc1->get($key); break;
                    default: $val = $this->mmc1->get($key);
                }
            }
            return $val;
        }

        //删除数据操作
        if ($optType == 'delete'){
            $this->mmc1->delete($key, $expire);
            if ($this->isGroup && is_object($this->mmc2)){
                $this->mmc2->delete($key);        
            }
            return true;
        }

        //清空数据操作     
        if($optType == 'flush'){
            $this->mmc1->flush();
            if ($this->isGroup && is_object($this->mmc2)){
                $this->mmc2->flush();        
            }
            return true;
        }
        
    }
    //---------------------
    //   外部操作方法
    //---------------------

    //增加一个元素
    function add($key, $val, $expire=''){   return $this->opt('add', $key, $val, $expire);     }

    //增加一个元素
    function set($key, $val, $expire=''){        return $this->opt('set', $key, $val, $expire);    }

    //替换一个元素
    function replace($key, $val, $expire=''){        return $this->opt('replace', $val, $expire);    }

    //获取一个元素
    function get($key){        return $this->opt('get', $key);    }

    //删除一个元素
    function delete($key, $timeout=''){      return $this->opt('delete', $key, '', $timeout);    }

    //让所有的元素过期 (本接口不要轻易使用)
    function flush(){       return $this->opt('flush');     }


    /**     * 获取所有Memcache服务器状态     */
    function getStats(){
        $status = array();

        //单独连接到每台Memcache
        foreach($this->groups as $key=>$hosts){
            $tmp = explode(":", $hosts);
            $host = $tmp[0];
            $port = (!isset($tmp[1]) || $tmp[1]=='') ? $this->mmcPort : $tmp[1];

            $conn = new Memcache;
            $conn->connect($host, $port);
            $s = $conn->getStats();
            $s['host'] = $host;
            $s['port'] = $port;
            $status[$key] = $s;
        }
        return $status;
    }

    /**
     * 获取所有Memcache服务器版本号
     */
    function getVersion(){
        $version = array();
        $stats = $this->getStats();
        foreach($stats as $key=>$s){
            $v['host'] = $s['host'];
            $v['port'] = $s['port'];
            $v['version'] = $s['version'];
            $version[$key] = $v;
        }
        return $version;
    }

}
?>

101:
memcached -d -m 50 -p 11212 -u root
memcached -d -m 50 -p 11213 -u root


102:
memcached -d -m 50 -p 11212 -u root
memcached -d -m 50 -p 11213 -u root

<?php
require_once("MemcacheOpt.class.php");

//操作代码
$hostArray = array("192.168.1.101:11212", "192.168.1.101:11213","192.168.1.102:11212","192.168.1.102:11213");
$m = new MemcacheOpt($hostArray);

$m->add("key1", "key1_value", 30);
$m->add("key2", "key2_value", 30);
$m->add("key3", "key3_value", 30);
$m->add("key4", "key4_value", 30);
echo $m->get("key1"). " ";
echo $m->get("key2"). " ";
echo $m->get("key3"). " ";
echo $m->get("key4"). " ";
print_r($m->getStats());
print_r($m->getVersion());

?>

 

 

今天测试还碰到一个奇怪的问题,下面三段代码都应该是可以执行的,最后一段却报错不能连接,不解。

 

-----------ok
<?php
$mem = new Memcache;
$mem->connect("127.0.0.1", 11211);
$mem->set('key', 'This is a memcached test!', 0, 60);
$val = $mem->get('key');
echo $val; 

?>


--------ok
101:
memcached -d -m 50 -p 11212 -u root
memcached -d -m 50 -p 11213 -u root
<?php
$mem = new Memcache;
$mem->connect("192.168.1.101",11212);
$mem->set('keysss', 'This is a memcached test!', 0, 60);
$val = $mem->get('keysss');
echo $val;

?>

------------------------Warning: Memcache::connect() [memcache.connect]: Can't connect to 192.168.1.101:11211, Connection refused (111) in /var/www/mem3.php on line 3

memcached启动的时候有一项是指定ip的,如果已经指定了IP.那么可能就无法再使用localhost或127.0.0.1(猜的,不知道是不是这样,俺一般是不指定的,所以默认localhost或127.0.0.1都是可以的)



<?php
$mem = new Memcache;
$mem->connect("192.168.1.101",11211);
$mem->set('keysdf', 'This is a memcached test!', 0, 60);
$val = $mem->get('keysdf');
echo $val;

?>

 

 

 

分享到:
评论

相关推荐

    memcached_termkqh_memcache_

    1. **分布式缓存**:memcached作为分布式缓存系统,可以在多台服务器之间共享数据,通过一致性哈希算法来分配键值对,从而实现负载均衡和高可用性。 2. **键值对存储**:memcached使用简单的键值对数据结构,其中键...

    一个很棒的开源项目

    喜欢自己研究的朋友可以到这里下载,将里面的压缩文件《一个很棒的开源项目》上传到你的SAE上就可以用了,当然别忘了导入数据库、新建storage、启用kvdb、设置Memcache为8M就OK啦。想部署到本地的朋友里面有详细的...

    阿里巴巴-林星辰1

    此外,他还掌握Redis、Memcache缓存技术,以及MySQL、MongoDB、OpenTSDB、ElasticSearch数据库。在流式计算和异步队列方面,他熟悉Kafka、ZooKeeper、多线程和协程计算,以及RabbitMQ。对于版本管理,他使用Git和SVN...

    免费thinkPHP3.2.3框架

    随着经验积累,可以深入研究路由、模型、控制器的高级用法,以及如何利用Composer管理和集成第三方库。对于高级开发者,ThinkPHP3.2.3提供了丰富的API和钩子系统,可以进行深度定制和扩展,打造个性化的开发环境。 ...

    互联网广告平台系统架构设计

    集群服务器构成的物理基础是整个系统的物理支撑,多台服务器共同组成群集,以实现负载均衡和高可用性。在这样的体系下,任何一个节点的故障都不会导致整体服务的中断,确保了系统的稳定运行。 前端访问代理的引入...

    程序员简历模板-单页单色53.docx

    在自我评价部分,求职者表达了自己重视基础知识、技术研究、创新、团队合作和沟通交流的态度,这有助于展现其软技能和职业素养。 总的来说,这份【程序员简历模板】通过精简且专业的设计,帮助应聘者有效地呈现他们...

    windows 下安装memched及使用demo

    2. **分布式缓存**: 学习如何在多台服务器上部署Memcached以构建分布式缓存系统。 3. **安全性**: 设置访问控制,防止未授权的访问。 4. **监控与管理**: 使用工具监控Memcached的性能和内存使用情况,以便及时发现...

    PHP工程师简历-简洁橙色-1-3年经验.docx

    4. **缓存技术**:了解Memcache和Redis这两种缓存系统,说明工程师懂得如何提高数据读取速度,减少数据库压力,提高整体系统响应时间。 5. **Web前端技术**:对XML、HTML、JavaScript和Ajax有理解,表示工程师能...

    spring+gae

    4. **云服务集成**:Spring可以用来管理GAE的其他服务,如Memcache、Mail服务等,提供更一致的编程模型。 5. **Spring MVC**:Spring MVC可以作为GAE应用的前端控制器,处理HTTP请求,提供模板引擎支持,如...

    Memcached Study

    ### Memcached 研究与应用 #### 一、Memcached 概述 Memcached 是一个高性能、分布式内存对象缓存系统,具有通用性特点,主要用于通过减轻数据库负载来加速动态 Web 应用程序的速度。它能够显著提高网站性能,减少...

    LoJackmyKids_GAE2:Lo Jack My Kids GAE服务器-版本2.0

    在深入研究这个项目之前,你需要解压文件并查看其内容。这可能包括源代码文件、配置文件、README文档等,它们将提供更详细的信息,如如何构建和运行项目,以及可能包含的特定库和技术。如果项目使用了版本控制系统如...

Global site tag (gtag.js) - Google Analytics