python访问memcached

memcached介绍

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

memcached安装

安装

在linux下安装

• 安装libevent

  Libevent 是一个异步事件处理软件函式库，以 BSD 许可证释出。Memcached 依赖 Libevent，因此必须先安装 Libevent。

  1	yum install libevent-devel

• 安装memcached

  123456

  cd /usr/local/srcwget http://memcached.org/latesttar zxf memcached-1.5.7.tar.gzmv memcached-1.5.7 memcachedcd memcached/./configure && make && make install

启动

1

memcached -d -u root

启动参数说明

123456

[root@VM_0_4_centos memcached]# ps aux|grep memcacheroot     24421  0.0  0.0 413792  1080 ?        Ssl  07:45   0:00 memcached -d -u rootroot     24436  0.0  0.0 112644   964 pts/0    R+   07:45   0:00 grep --color=auto memcache[root@VM_0_4_centos memcached]# netstat -lntp|grep memcachedtcp        0      0 0.0.0.0:11211           0.0.0.0:*               LISTEN      24421/memcached     tcp6       0      0 :::11211                :::*                    LISTEN      24421/memcached

python访问memcached

python访问memcached需要安装python-memcached模块。

1

pip install python-memcached

操作实例

12345

import memcachemem = memcache.Client(["118.24.18.158:11211"])mem.set("db", "oracle")print(mem.get("db"))    #输出结果：oracle

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

1234

主机IP        权重1.1.1.1        11.1.1.2        21.1.1.3        1

那么内存中主机列表为：host_list = [“1.1.1.1”, “1.1.1.2”,”1.1.1.2”,”1.1.1.3”,]

1234567

#!/usr/bin/env python3#coding:utf8import memcachemc = memcache.Client([('1.1.1.1:11211', 1), ('1.1.1.2:11211', 2),('1.1.1.3:11211',1)])mc.set('k1','value1')ret = mc.get('k1')print (ret)

memcached常用操作

• set(key, val)
  在memcache中设置key的值为val。若key不存在则创建，否则修改。
• get(key)
  获取memcache中key对应的值或者None。
• set_multi(mapping)
  一次设置多个key/value对。以列表方式传入。若key不存在则创建，否则修改。

• get_multi(keys)

  一次获取多个keys

  1234	mem.set_multi({"db1": "oracle", "db2": "mysql"})mem.set("db3", "memcache")print(mem.get("db1")) #输出结果：oracleprint(mem.get_multi(["db2", "db3"])) #输出结果：{'db2': 'mysql', 'db3': 'memcache'}

• add(key, val)

  在memcache中添加新的键值对。若已存在则返回False。

  123	print(mem.add("db", "memcache")) #输出结果：Trueprint(mem.get("db")) #输出结果：memcacheprint(mem.add("db", "memcache")) #输出结果：False

• replace(key, val)

  修改key的值为val，若不存在则返回False。

  1234	mem.add("db", "memcache")print(mem.replace("db", "redis")) #输出结果：Trueprint(mem.get("db")) #输出结果：redisprint(mem.replace("db1", "redis")) #输出结果：False

• delete(key)

  删除一个指定的key/value对。

• delete_multi(keys)

  删除多个指定的key/value对。

  1234	mem.set_multi({"db1": "oracle", "db2": "mysql", "db3": "memcache"})mem.delete("db1")mem.delete_multi(["db2", "db3"])print(mem.get_multi(["db1", "db2", "db3"])) #输出结果：{}

• append(key, val)

  在指定key对应的value后面追加内容。

• prepend(key, val)
  在指定key对应的额value前面追加内容。

• stats

  查看历史操作

  1234567

  mem.set("db", "oracle")print(mem.get("db")) #输出结果：oraclemem.append("db", " or mysql")print(mem.get("db")) #输出结果：oracle or mysqlmem.prepend("db", "redis or ")print(mem.get("db")) #输出结果：redis or oracle or mysqlprint(mem.stats) #输出结果：{'set': 1, 'get': 3, 'append': 1, 'prepend': 1}

• gets和cas

  使用缓存系统共享数据资源就必然绕不开数据争夺和脏数据（数据混乱）的问题。
  假设商城某件商品的剩余个数保存在memcache中，product_count = 900，
  A用户刷新页面从memecache中读取到product_count = 900，
  B用户刷新页面从memecache中读取到product_count = 900，
  A,B用户均购买商品，并修改product_count的值。
  A修改后，product_count = 899；
  B修改后，product_count = 899；
  然而正确数字应该是898，数据就混乱了。
  如果想要避免这种情况的发生，则可以使用gets和cas。

  12345

  mem = memcache.Client(["118.24.18.158:11211"])mem.set("count", "100")print(mem.get("count")) #输出结果：100print(mem.cas("count", "99")) #输出结果：Trueprint(mem.gets("count")) #输出结果：99

gets和cas一起使用，cas是check and set操作。它仅当当前客户端最后一次取值后，该key对应的值没有被其他客户端修改的情况下，才能够将值写入。