python 操作 memcached

memcache简介

Memcached是一个高性能的分布式内存对象缓存系统，用于动态Web应用以减轻数据库负载。它通过在内存中缓存数据和对象减少读取数据库的次数，从而提高动态、数据库驱动网站的速度。Memcached基于一个存储键/值的hashmap。其守护进程(daemon)是用C语言写的，但是客户端可以用任何语言来编写，并通过memcached协议与守护进程通信。

安装memecached

yum install  libevent-devel -y

cd /usr/local/src

wget

tar -zxvf memcached-1.5.3.tar.gz

cd memcached-1.5.3

./configure --prefix=/usr/local/memcached
 make && make install

启动 memecached
[root@linux-node1 local]# /usr/local/memcached/bin/memcached -d -m 64M -u root -l 127.0.0.1 -p 11211 -c 256 -P /tmp/memcached.pid

-p 指定端口号（默认11211）  
-m 指定最大使用内存大小（默认64MB）  
-l 连接的IP地址, 默认是本机  
-d 以后台守护进程的方式启动
-c 最大同时连接数，默认是1024
-P 制定memecache的pid文件

查看 memecached 是否启动

[root@linux-node1 local]# netstat -lntup |grep 11211
tcp        0      0 127.0.0.1:11211             0.0.0.0:*                   LISTEN      7341/memcached      
udp        0      0 127.0.0.1:11211             0.0.0.0:*                               7341/memcached      

连接  memecached并做数据的读写
[root@linux-node1 local]# telnet 127.0.0.1 11211
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
set foo 0 0 3
bar
STORED
get foo      
VALUE foo 0 3
bar
END
quit

[root@weblamp ~]# vi 1.py 
import memcache


mc = memcache.Client(['10.89.1.10:11211'],debug=True)


mc.set("some_key", "Some value")
value = mc.get("some_key")
print value
print '*'*30
mc.set("another_key", 3)
value1 = mc.get("another_key")
print value1
value2 = mc.delete("another_key")
print value2
print '*'*30
mc.set("key", "1")
mc.incr("key")
mc.decr("key")
~                                                                                                                       
~                                                                                       
"1.py" 17L, 335C written

执行结果：

[root@weblamp ~]# python 1.py 
Some value
******************************
3
1
******************************
[root@weblamp ~]# 

Python操作memcache集群

python-memcachd模块原生支持集群操作，其原理是在内存维护一个主机列表，且集群中主机的权重值和主机在列表中重复出现的次数成正比。

主机    权重

     10.8.1.1   1

     10.8.1.2   2

     10.8.1.3   1

 

#那么在内存中主机列表为：

     host_list=['10.8.1.1','10.8.1.2','10.8.1.3']

 

下面来看一个例子，python操作memcache集群

mc = memcache.Client([('10.8.1.1:12000', 1), ('10.8.1.2:12000', 2), ('10.8.1.3:12000', 1)], debug=True)

mc.set('k1', 'v1')

如果用户要在内存中创建一个键值对(如：k1 = “v1”),那么要执行以下步骤：

根据算法将k1转换成一个数字；

将数字和主机列表长度求余数，得到一个值N(0 <= N < 列表长度)；

在主机列表中根据第2步得到的值为索引获取主机，例如：host_list[N];

连接将第3步中获取的主机，将k1 = 'v1'放置在该服务器的内存中。

上面例子我们通过调用memcache模块来实现对memcached进行存取数据，debug=True表示运行中出现错误时，显示错误信息，上线后移除该参数。