当前位置：首页 >服务端 > NoSQL之【memcached】学习

NoSQL之【memcached】学习

摘要：

NOSQL的优势

易扩展: NoSQL数据库种类繁多，但是一个共同的特点都是去掉关系数据库的关系型特性。数据之间无关系，这样就非常容易扩展。也无形之间，在架构的层面上带来了可扩展的能力。

大数据量，高性能: NoSQL数据库都具有非常高的读写性能，尤其在大数据量下，同样表现优秀。这得益于它的无关系性，数据库的结构简单。一般MySQL使用Query Cache，每次表的更新Cache就失效，是一种大粒度的Cache，在针对web2.0的交互频繁的应用，Cache性能不高。而NoSQL的Cache是记录级的，是一种细粒度的Cache，所以NoSQL在这个层面上来说就要性能高很多了。

灵活的数据模型: NoSQL无需事先为要存储的数据建立字段，随时可以存储自定义的数据格式。而在关系数据库里，增删字段是一件非常麻烦的事情。如果是非常大数据量的表，增加字段简直就是一个噩梦。这点在大数据量的web2.0时代尤其明显。

高可用: NoSQL在不太影响性能的情况，就可以方便的实现高可用的架构。比如Cassandra，HBase模型，通过复制模型也能实现高可用。

总的来说，NoSQL数据库的出现，弥补了关系数据（比如MySQL）在某些方面的不足，在某些方面能极大的节省开发成本和维护成本。

安装：
mcached属于临时性键值存储的NoSQL数据库（官网:http://memcached.org）。好处和坏处请看《NoSQL 数据库入门》第2章节。
(ubuntu 12.04)

apt-get install memcached

查看进程：

memcache  2795  0.0  0.1  46356  1076 ?Sl22:340:00 /usr/bin/memcached -m 64 -p 11211 -u memcache -l 127.0.0.1

参数意义：

默认端口（-p）：11211默认用户（-u）：memcache，需要修改成nobody默认大小（-m）：64M最大连结数（-c）：1024 监听服务器（-l）：IP 地址，默认是本地
后台运行：-d

操作语法：

set <key> <flag> <expires> <byte>Flag 用于指定是否压缩数据，0不压缩，1压缩Expires 指定数据保存的时间，一种方法是秒数（不能超过30天），另一种可以使用unix时间戳指定，0为有效期无限Byte 保存值的字节数

操作方法：

#链接方法root@m2:~# telnet localhost 11211Trying 127.0.0.1...Connected to localhost.Escape character is '^]'.#赋值set test 0 0 9zhoujinyiSTORED#取值get testVALUE test 0 9zhoujinyiEND#加法set test1 0 0 19STOREDincr test1 1#加110get test1VALUE test1 0 210END#减法decr test1 5#减55get test1VALUE test1 0 15END#删除delete test1#删除keyDELETEDget test1END#追加get testVALUE test 0 9zhoujinyiENDappend test 0 0 3#最后追加ABCSTOREDget testVALUE test 0 12zhoujinyiABCENDprepend test 0 0 3  #最先追加CBASTOREDget testVALUE test 0 15CBAzhoujinyiABCEND#清除所有数据flush_allok

#退出
quit

开启多个Memcached：

#第2个节点，端口11212root@m2:~# memcached -d -m 64 -p 11212 -u nobody -l 127.0.0.1#第2个节点，端口11213root@m2:~# memcached -d -m 64 -p 11213 -u nobody -l 127.0.0.1

查看进程：

memcache  2795  0.0  0.2  47380  2124 ?Sl22:340:00 /usr/bin/memcached -m 64 -p 11211 -u memcache -l 127.0.0.1memcache  3339  0.0  0.0  46356616 ?Ssl  23:190:00 memcached -d -m 64 -p 11212 -u memcache -l 127.0.0.1memcache  3346  0.0  0.0  46356616 ?Ssl  23:190:00 memcached -d -m 64 -p 11213 -u memcache -l 127.0.0.1

以上完成了memcached的安装和基本操作。现在用Python 操作memcache。

Python 操作memcache：

apt-get install python-setuptoolseasy_install python-memcached

#导入memcache模块>>> import memcache#链接memcache>>> mc=memcache.Client(['127.0.0.1:11211'],debug=1)#赋值>>> mc.set('a',1)True>>> mc.set('b',2)True>>> mc.set('c',3)True#取值>>> print mc.get('a')1>>> print mc.get('c')3#增加，存在则增加失败>>> mc.add('a',1)MemCached: while expecting 'STORED', got unexpected response 'NOT_STORED'False>>> mc.add('d',4)True#替换，不存在则添加，存在则替换>>> mc.replace('e',5)True>>> mc.get('d')4>>> mc.get('e')5>>> mc.replace('d',44)True>>> mc.get('d')44#整数加法，默认是1>>> mc.get('a')1>>> mc.incr('a')2>>> mc.incr('a',3)5>>> mc.get('a')5#整数减法，默认是1>>> mc.decr('a')4>>> mc.decr('a',3)1>>> mc.get('a')1#多个取值，返回字典形式>>> mc.get_multi(['a','b','c','d','e']){'a': 1, 'c': 3, 'b': 2, 'e': 5, 'd': 44}#多个赋值，返回空列表>>> mc.set_multi({'A':11,'B':22,'C':33})==[]True>>> mc.get ('A')11>>> mc.get ('B')22>>> mc.get ('C')33#删除>>> mc.delete('A')1>>> mc.delete('B')1>>> mc.delete('C')1>>> mc.get ('B')>>> 
#更改
>>> mc.set('z','a')
True
>>> mc.get('z')
'a'
>>> mc.cas('z','A')
True
>>> mc.get('z')
'A

#指定失效时间

>>> mc.set('name','zjy',30) #有效时间30s

True

>>> mc.get('name')

'zjy'

>>> mc.get('name') #30s后

脚本示例

#!/usr/bin/env python#coding=utf-8#memcache读取和MySQL读取的差距import MySQLdbimport memcacheimport sysimport timedef get_data(mysql_conn):mc = memcache.Client(['127.0.0.1:11211'],debug=1)t1 =time.time()value = mc.get('zjy')if value == None:t1 = time.time()query = "select count(*) from uc_user_offline where realName like '%º¥¶ûÄá%'"cursor= mysql_conn.cursor()cursor.execute(query)item = cursor.fetchone()t2 = time.time()t = round(t2-t1)print "from mysql cost %s sec" %tfor row in item:print "The values is : %s" %rowmc.set('zjy',row,30)else :t2 = time.time()t=round(t2-t1)print "from memcache cost %s sec" %tprint "The values is : %s" %valueif __name__ =='__main__':mysql_conn = MySQLdb.connect(host='127.0.0.1',user='root',passwd='123456',db='test',port=3306,charset='utf8')get_data(mysql_conn)