python学习—Day39—memcache常用方法

（一）

首先环境：

[root@localhost bin]#  ./memcached -d -u root -p 11211

[root@localhost bin]# netstat -anpt | grep memcache

tcp        0      0 0.0.0.0:11211               0.0.0.0:*                   LISTEN      3232/./memcached    

tcp        0      0 :::11211                    :::*                        LISTEN      3232/./memcached    

[root@localhost bin]# iptables -F

[root@localhost bin]# /etc/init.d/iptables save

#@File :memcache_changyong.py
import memcache
mc = memcache.Client(["192.168.172.20:11211"], debug=True)
print(dir(mc))
#add(key, value)
mc.add("k1", "v1")
print(mc.get("k1"))

#replace
mc.replace("k1", "hello world")
print(mc.get("k1"))

#set(key value)
mc.set("k2", "v2")
print(mc.get("k2"))

#set 和add 的区别
#set = add + replace.如果key值存在add就会报错。set不会报错，会进行赋值覆盖。

#set_multi(dict)，一次设置多个key-value
#get_multi(list),一次获取到多个keys,多个key要以list形式作为参数，进行传入，返回类型为字典。
#get(key)  获得该key对应的value的值
mc.set_multi({"k100": "v100", "k101": "v101"})
print(mc.get_multi(["k100", "k101"]))               #注意这里的中括号

['MemcachedKeyCharacterError', 'MemcachedKeyError', 'MemcachedKeyLengthError', 'MemcachedKeyNoneError', 'MemcachedKeyTypeError', 'MemcachedStringEncodingError', '_FLAG_COMPRESSED', '_FLAG_INTEGER', '_FLAG_LONG', '_FLAG_PICKLE',
'_SERVER_RETRIES', '__class__', '__delattr__', '__dict__', '__doc__', '__format__', '__getattribute__', '__hash__', '__init__', '__module__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__',
'_deletetouch', '_encode_cmd', '_encode_key', '_expect_cas_value', '_expectvalue', '_get', '_get_server', '_incrdecr', '_init_buckets', '_map_and_prefix_keys', '_recv_value', '_set', '_statlog', '_val_to_store_info', 'add', 'append', 'buckets', 'cache_cas',
'cas', 'cas_ids', 'check_key', 'compressor', 'dead_retry', 'debug', 'debuglog', 'decompressor', 'decr', 'delete', 'delete_multi', 'disconnect_all', 'do_check_key', 'flush_all', 'flush_on_reconnect', 'forget_dead_hosts', 'get', 'get_multi', 'get_slab_stats',
'get_slabs', 'get_stats', 'gets', 'incr', 'persistent_id', 'persistent_load', 'pickleProtocol', 'pickler', 'picklerIsKeyword', 'prepend', 'replace', 'reset_cas', 'server_max_key_length', 'server_max_value_length', 'servers', 'set', 'set_multi', 'set_servers',
'socket_timeout', 'stats', 'touch', 'unpickler']

MemCached: while expecting 'STORED', got unexpected response 'NOT_STORED'

hello world

hello world

v2

{'k100': 'v100', 'k101': 'v101'}

开始的两条打印语句与后面的语句有冲突，所以返回中带有一些小错误，注意即可。

详解：

存储命令： set/add/replace/append/prepend/cas

获取命令： get/gets

其他命令： delete/stats..

add方法

添加一条键值对，如果已经存在的key，重复执行add操作会报异常。

import memcache

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

# mc.set("foo", "bar")

# ret = mc.get("foo")

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

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

# print(ret)

replace方法

replace修改某个key的值，如果key不存在，则异常。

import memcache

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

# mc.set("foo", "bar")

# ret = mc.get("foo")

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

# mc.add('k1','v1')

# print(ret)

mc.replace("k1", "666")

print(mc.get("k1"))

结果：

666

set和set_multi方法

set ：设置一个键值对，如果key不存在，则创建，如果key存在，则修改；

set_multi：设置多个键值对，如果key不存在，则创建，如果key存在，则修改。

import memcache

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

mc.set("k10", "v10")

mc.set_multi({"k11":"v11", "k12": "v12"})

 

set方法和add方法的区别

set = add + replace

1、memcache::add 方法：add方法用于向memcache服务器添加一个要缓存的数据。

注意：如果memcache服务器中已经存在要存储的key，此时add方法调用失败。

2、memcache::set 方法：set方法用于设置一个指定key的缓存内容，set方法是add方法和replace方法的集合体。

注意：

1）、如果要设置的key不存在时，则set方法与add方法的效果一致；

2）、如果要设置的key已经存在时，则set方法与replace方法效果一样。

3、 mmecache::replace方法： replace方法用于替换一个指定key的缓存内容，如果key不存在则返回false

（二）

#@File :memcache_changyong.py
import memcache
mc = memcache.Client(["192.168.172.20:11211"], debug=True)

#append  prepend     追加
mc.set_multi({"test1": "v1", "test2": "v2", "test3": "v3", "test4": "v4"})

mc.append("test1", "xiao")
print(mc.get("test1"))
mc.prepend("test2", "hello")
print(mc.get("test2"))

#incr  默认自增+1，第二个参数指定增加数字为多少    decr  默认自减—1，第二个参数指定减少多少。
mc.set("shop", 1000)
mc.incr("shop")
print(mc.get("shop"))
mc.incr("shop", 100)
print(mc.get("shop"))

mc.decr("shop")
print(mc.get("shop"))
mc.decr("shop", 500)
print(mc.get("shop"))

{'test1': 'v1', 'test3': 'v3', 'test2': 'v2', 'test4': 'v4'}

{'test4': 'v4'}

v1xiao

hellov2

1001

1101

1100

600

其他：

gets和cas：

如商城商品剩余个数，假设改值保存在memcache中，product_count =9000

    A用户刷新页面从memcache中读取到product_count= 900

    B用户刷新页面从memcache中读取到product_count= 900

 如果A、B用户均购买商品：

    A用户修改商品剩余个数product_count = 899

    B用户修改商品剩余个数product_count= 899

 如此一来缓存内的数据便不再正确，两个用户购买商品后，商品剩余还是899，如果使用python的set和get来操作以上过程，那么程序就会如上述所示情况，数据不准确。

 如果想要避免此情况的发生，只要使用gets和cas即可，如：

#!/usr/bin/env python

# -*- coding: utf-8 -*-

#Author:HaiFeng Di

import memcache

 

mc =memcache.Client(['192.168.10.128:12000'], debug=True)

v = mc.gets('product_count')

print(v)

#如果有人在gets之后和cas之前修改了product_count,那么下面的设置将会执行失败，抛出异常，从而避免非正常数据的产出

v1 =mc.cas('product_count',"899")

print(v1)

#结果：

899

True

本质上每次执行gets时，会从memcache中获取一个自增的数字，通过cas去修改gets的值时，会携带之前获取的自增值和memcache中的自增值进行比较，如果相等，则可以提交，如果不相等，那表示在gets和cas执行之间，又有其他人执行了gets(获取了缓冲的指定值)，如此一来有可能出现非正常数据，则不允许修改。