- 浏览: 2536492 次
- 性别:
- 来自: 深圳
文章分类
- 全部博客 (676)
- linux运维 (157)
- php (65)
- mysql (78)
- nginx (27)
- apche (18)
- framework (6)
- windows (9)
- IDE工具 (23)
- struts2 (7)
- java (13)
- 移动互联网 (14)
- memcache redis (23)
- shell基础/命令/语法 (37)
- shell (50)
- puppet (4)
- C (11)
- python (9)
- 产品经理 (27)
- Sphinx (4)
- svn (12)
- 设计构建 (12)
- 项目管理 (44)
- SEO (1)
- 网站架构 (26)
- 审时度势 (42)
- 网络 (14)
- 激发事业[书&视频] (81)
- 其它 (12)
- 摄影 (8)
- android (21)
最新评论
-
zhongmin2012:
原文的书在哪里
数据库水平切分的实现原理解析---分库,分表,主从,集群,负载均衡器 -
renzhengzhi:
你好,请问个问题,从master同步数据到slave的时候,s ...
数据库水平切分的实现原理解析---分库,分表,主从,集群,负载均衡器 -
ibc789:
你好,看了你的文章,我想请教个问题, 我在用 redis的时候 ...
redis 的两种持久化方式及原理 -
iijjll:
写得非常好
数据库水平切分的实现原理解析---分库,分表,主从,集群,负载均衡器 -
iijjll:
写得非常好
数据库水平切分的实现原理解析---分库,分表,主从,集群,负载均衡器
第一种方法是通过设置特殊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;
?>
发表评论
-
通过Keepalived实现Redis Failover自动故障切换功能[实践分享]
2015-03-12 17:10 7415参考资料:http://patrick-tang.blog ... -
Redis学习手册(主从复制)
2015-03-12 17:05 7348一、Redis的Replication: ... -
redis 的两种持久化方式及原理
2015-03-12 16:52 63325Redis是一种高级key-value数据库。它跟memc ... -
Redis指令手册中文版
2014-08-08 17:09 954连接控制QUIT :退出,关 ... -
Redis服务的监控
2013-01-17 16:00 6710redis 监控工具安装配置http://blog.sin ... -
【汇总】redis
2012-04-16 13:51 1450http://bbs.chinaunix.net/thread ... -
memcache运用代码
2011-07-22 11:38 1417interface ICache { pub ... -
memcache 丢数据解决方案
2011-07-01 11:17 2694一小时以内数据变化都存放到memcached中,无论数据读取或 ... -
Memcached repcached同步
2011-06-10 14:10 2199#安装 wget http://downloads.sour ... -
memcached命中率问题
2011-06-09 21:14 2003http://www.iteye.com/topic/2256 ... -
php遍历memcache所有键值
2011-05-31 17:56 4374很有用的东东,PHP遍历MEMCACHE的所有键,在做管理me ... -
memcached全面剖析和深度剖析
2011-05-15 14:43 1682Memcached深度分析(原创) 2009年2月11日 ... -
【监控】netstat+telnet+m-top+phpmemcached
2011-03-31 22:01 30391G=1024*1024*1024=1073741824 by ... -
centos 下安装memcache配置
2010-09-21 15:01 7447为什么会有Memcache和memca ... -
关于session和memcache的若干问题
2010-09-20 15:17 5595=============================== ... -
Memcached深度分析----转新浪开发者博客
2009-07-11 22:36 1664http://blog.developers.api.sina ... -
Memcache分组和同步机制的实现--这不是memcache集群了么
2009-07-05 21:53 13072首先我们明确了解就是Memcache是一个简单、快速、高效的分 ... -
memcached全面剖析–5. memcached的应用和兼容程序
2009-07-05 21:31 1606memcached的连载终于要结束了。到上次为止,我们介绍了与 ... -
[推荐]memcached全面剖析–4. memcached的分布式算法:Consistent Hashing
2009-07-05 21:20 2519第2次 、 第3次 由前坂介绍了memcached的内部情况 ... -
【汇总】Memcache
2009-07-01 11:40 3711memcached全面剖析和深度剖析.rar ...
相关推荐
1. **分布式缓存**:memcached作为分布式缓存系统,可以在多台服务器之间共享数据,通过一致性哈希算法来分配键值对,从而实现负载均衡和高可用性。 2. **键值对存储**:memcached使用简单的键值对数据结构,其中键...
喜欢自己研究的朋友可以到这里下载,将里面的压缩文件《一个很棒的开源项目》上传到你的SAE上就可以用了,当然别忘了导入数据库、新建storage、启用kvdb、设置Memcache为8M就OK啦。想部署到本地的朋友里面有详细的...
此外,他还掌握Redis、Memcache缓存技术,以及MySQL、MongoDB、OpenTSDB、ElasticSearch数据库。在流式计算和异步队列方面,他熟悉Kafka、ZooKeeper、多线程和协程计算,以及RabbitMQ。对于版本管理,他使用Git和SVN...
随着经验积累,可以深入研究路由、模型、控制器的高级用法,以及如何利用Composer管理和集成第三方库。对于高级开发者,ThinkPHP3.2.3提供了丰富的API和钩子系统,可以进行深度定制和扩展,打造个性化的开发环境。 ...
集群服务器构成的物理基础是整个系统的物理支撑,多台服务器共同组成群集,以实现负载均衡和高可用性。在这样的体系下,任何一个节点的故障都不会导致整体服务的中断,确保了系统的稳定运行。 前端访问代理的引入...
在自我评价部分,求职者表达了自己重视基础知识、技术研究、创新、团队合作和沟通交流的态度,这有助于展现其软技能和职业素养。 总的来说,这份【程序员简历模板】通过精简且专业的设计,帮助应聘者有效地呈现他们...
2. **分布式缓存**: 学习如何在多台服务器上部署Memcached以构建分布式缓存系统。 3. **安全性**: 设置访问控制,防止未授权的访问。 4. **监控与管理**: 使用工具监控Memcached的性能和内存使用情况,以便及时发现...
4. **缓存技术**:了解Memcache和Redis这两种缓存系统,说明工程师懂得如何提高数据读取速度,减少数据库压力,提高整体系统响应时间。 5. **Web前端技术**:对XML、HTML、JavaScript和Ajax有理解,表示工程师能...
4. **云服务集成**:Spring可以用来管理GAE的其他服务,如Memcache、Mail服务等,提供更一致的编程模型。 5. **Spring MVC**:Spring MVC可以作为GAE应用的前端控制器,处理HTTP请求,提供模板引擎支持,如...
### Memcached 研究与应用 #### 一、Memcached 概述 Memcached 是一个高性能、分布式内存对象缓存系统,具有通用性特点,主要用于通过减轻数据库负载来加速动态 Web 应用程序的速度。它能够显著提高网站性能,减少...
在深入研究这个项目之前,你需要解压文件并查看其内容。这可能包括源代码文件、配置文件、README文档等,它们将提供更详细的信息,如如何构建和运行项目,以及可能包含的特定库和技术。如果项目使用了版本控制系统如...