python操作redis缓存-字符串类型
首先要安装redis-py模块
python连接redis方式，有两种连接方式，一种是直接连接，一张是通过连接池连接
注意：以后我们都用的连接池方式连接，直接连接不推荐
1、直接连接方式：【不推荐】
Redis()配置连接信息
set()写入数据
get()读取数据
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 r = redis.Redis(host='127.0.0.1', port=6379) #配置连接信息
r.set('foo', 'asdvc344') #写入数据
hc = r.get('foo') #读取数据
print(hc)
2、连接池连接方式【推荐】
redis-py使用connection pool来管理对一个redis server的所有连接，避免每次建立、释放连接的开销。默认，每个Redis实例都会维护一个自己的连接池。可以直接建立一个连接池，然后作为参数Redis，这样就可以实现多个Redis实例共享一个连接池。
ConnectionPool()配置连接池连接信息
Redis()连接连接池
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('foo', 'Bar1111111111') #写入数据
r.get('foo') #获取数据
字符串数据类型操作
String字符串类型操作，redis中的String在在内存中按照一个name对应一个value来存储。如图：
set(name, value, ex=None, px=None, nx=False, xx=False)写入数据参数
在Redis中设置值，默认，不存在则创建，存在则修改
参数：
ex，过期时间（秒）
px，过期时间（毫秒）
nx，如果设置为True，则只有name不存在时，当前set操作才执行，用于创建
xx，如果设置为True，则只有name存在时，当前set操作才执行，用于修改
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('foo', 'Bar',ex=20) #写入数据
hc = r.get('foo') #获取数据
print(hc)
setnx(name, value)只有name不存在时，执行设置操作（添加）
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.setnx('foo', 'Bar22') #写入数据setnx(name, value)只有name不存在时，执行设置操作（添加）
hc = r.get('foo') #获取数据
print(hc)
setex(name, value, time)设置值，参数：time，过期时间（数字秒 或 timedelta对象）
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.setex('foo', 'Bar22',5) #setex(name, value, time)设置值，参数：time，过期时间（数字秒 或 timedelta对象）
hc = r.get('foo') #获取数据
print(hc)
psetex(name, time_ms, value)设置值，参数：time_ms，过期时间（数字毫秒 或 timedelta对象）
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.psetex('foo',5, 'Bar22') #psetex(name, time_ms, value)设置值，参数：time_ms，过期时间（数字毫秒 或 timedelta对象）
hc = r.get('foo') #获取数据
print(hc)
mset(*args, **kwargs)批量设置
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.mset(k1='v1', k2='v2') #mset(*args, **kwargs)批量设置
#或者
r.mset({'k3': 'v1', 'k4': 'v2'})
mget(keys, *args)批量获取
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.mset(k1='v1', k2='v2') #mset(*args, **kwargs)批量设置
#或者
r.mset({'k3': 'v3', 'k4': 'v4'}) #mget(keys, *args)批量获取
a = r.mget('k1', 'k2')
#或者
b = r.mget(['k3', 'k4'])
print(a,b)
#返回：[b'v1', b'v2'] [b'v3', b'v4']
getset(name, value)设置新值并获取原来的值
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('k1','v1') #添加
a = r.get('k1') #获取
print(a) #getset(name, value)设置新值并获取原来的值
b = r.getset('k1','v222')
print(b)
getrange(name, start, end)获取指定名称的字符串里指定范围的字符
name,要获取的名称
start,要获取的字符串起始位置(字节)
end要获取的字符串结束位置(字节)
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('k1','afadfnanr') #添加
a = r.getrange('k1',2,5) #getrange(name, start, end)获取指定名称的字符串里指定范围的字符
print(a)
#返回：adfn
setrange(name, offset, value)从指定字符串索引开始向后替换（新值太长时，则向后添加）
offset，字符串的索引，字节（一个汉字三个字节）
value，要设置的值
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('k1','afadfnanr') #添加
r.setrange('k1',2,'') #setrange(name, offset, value)从指定字符串索引开始向后替换（新值太长时，则向后添加）
a = r.get('k1')
print(a)
#返回：af111nanr
setbit('name', 7, 1)，将指定名称里的内容转换成0和1表示的二进制，在从二进制指定的位置替换成指定的值，要替换的值只能是0或者1
字符串转换成二进制
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('k1','foo') #添加
a = r.get('k1') #获取内容
print(a) #得到字节类型 c = str(a,encoding='utf-8') #将字节转换成字符串
print(c) #得到字符串类型 for i in c: #循环字符串
num = ord(i) #将循环到的字符串，转换成十进制
print(bin(num).replace('b', '')) #将十进制转换成二进制，返回的二进制里有个b，表示二进制的意思，将b替换成空 #那么字符串，foo，的二进制表示就是01100110 01101111 01101111 r.setbit('k1',7,1) #setbit('name', 7, 1)，将指定名称里的内容转换成0和1表示的二进制，在从二进制指定的位置替换成指定的值，要替换的值只能是0或者1
e = r.get('k1')
print(e) f = str(e,encoding='utf-8')
print(f)
for i in f:
num = ord(i)
print(bin(num).replace('b', '')) #转换过程
# b'foo'
# foo
#
#
#
# b'goo'
# goo
#
#
# #原始数据：foo 二进制表示：01100110 01101111 01101111
#通过setbit('k1',7,1)：用1替换了二进制表示的第7个位置
#替换后变成：goo 二进制表示：01100111 01101111 01101111
getbit(name, offset)将指定名称的内容，转换成0和1表示的二进制，获取二进制里指定位置的二进制表示
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('k1','foo') #添加
a = r.getbit('k1',7) #将指定名称的内容，转换成0和1表示的二进制，获取二进制里指定位置的二进制表示
print(a)
bitcount(name, start, end)将指定名称的内容，转换成二进制位表示，然后计算出1表示的个数
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('k1','foo') #添加
a = r.bitcount('k1',0,7) #将指定名称的内容，转换成0和1表示的二进制，获取二进制里指定位置的二进制表示
print(a) #bitcount(name, start, end)将指定名称的内容，转换成二进制位表示，然后计算出1表示的个数
#返回：16 #二进制表示
#
#
#
bitop(operation, dest, *keys)获取Redis中n1,n2,n3对应的值，然后将所有的值做二进制位运算（求并集），然后将结果保存 new_name 对应的值中
operation,AND（并） 、 OR（或） 、 NOT（非） 、 XOR（异或）
dest, 新的Redis的name
*keys,要查找的Redis的name
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('k1','') #添加
r.set('k2','') #添加
r.set('k3','') #添加 r.bitop("AND", 'new_name', 'k1', 'k2', 'k3') #bitop(operation, dest, *keys)获取Redis中n1,n2,n3对应的值，然后将所有的值做二进制位运算（求并集），然后将结果保存 new_name 对应的值中 d = r.get('new_name')
print(d)
strlen(name)返回name对应值的字节长度（一个汉字3个字节）
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('k1','林贵秀') #添加 d = r.strlen('k1') #strlen(name)返回name对应值的字节长度（一个汉字3个字节） print(d)
#返回9
incr(self, name, amount=1)必须整数自增，自增 name对应的值，当name不存在时，则创建name＝amount，否则，则自增。
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('k1','') #添加 d = r.incr('k1',amount=1) #incr(self, name, amount=1)整数自增，自增 name对应的值，当name不存在时，则创建name＝amount，否则，则自增。 print(d)
incrbyfloat(self, name, amount=1.0)浮点数自增，整数自增负数自减 name对应的值，当name不存在时，则创建name＝amount，否则，则自增。
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('k1','') #添加 d = r.incrbyfloat('k1',amount=1.5) #incrbyfloat(self, name, amount=1.0)浮点数自增，整数自增负数自减 name对应的值，当name不存在时，则创建name＝amount，否则，则自增。 print(d)
#返回：3.5
decr(self, name, amount=1)整数自减 name对应的值，当name不存在时，则创建name＝amount，否则，则自减。
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('k1','') #添加 d = r.decr('k1',amount=1) #decr(self, name, amount=1)整数自减 name对应的值，当name不存在时，则创建name＝amount，否则，则自减。 print(d)
#返回：1
append(name, value)在redis name对应的值后面追加内容
#!/usr/bin/env python
# -*- coding:utf-8 -*- import redis #导入操作redis模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池
r.set('k1','') #添加 r.append('k1','') #append(name, value)在redis name对应的值后面追加内容 d = r.get('k1')
print(d)
#返回：222
利用字符串方式缓存网页应用
Tornado框架
write()方法：web.py文件里的write()方法，接收字符串显示给用户
使用的Tornado框架，但是Tornado框架在将html转换成字符串显示给用户后，就删除了，所以我们需要修改一下源码，添加一个字段保存一下html字符串接，在web.py文件里的write()方法里修改源码，添加一个字段self._response_html = chunk 保存html文件转换的字符串，这样我们方便得到html转换的字符串
在web.py文件里的write()方法里修改源码
封装一个缓存处理模块
#!/usr/bin/env python
#coding:utf-8 import redis #导入操作redis缓存模块 pool = redis.ConnectionPool(host='127.0.0.1', port=6379) #配置连接池连接信息 r = redis.Redis(connection_pool=pool) #连接连接池 class huancuen:
"""
处理缓存对象
"""
def __init__(self,_self,name):
"""
self._self 接收创建对象时传进来的对象
self.name 接收创建对象时传进来的缓存名称
self.shi_jian 设置缓存有效时间，（秒）
"""
self._self = _self
self.name = name
self.shi_jian = 10 def hc_get(self):
"""
hc_get()方法：无参，返回缓存内容
根据创建对象时传进来的缓存名称，到缓存里获取到对应名称的缓存
判断此缓存如果存在，就读取缓存显示给用户
"""
html = r.get(self.name)
if html:
self._self.write(html)
return html def hc_set(self):
"""
r.set()方法：无参，无返回
获取到用户请求的html字符串，将htnl字符串作为值，创建对象时传入的缓存名称作为名称，写入缓存
缓存有效时间，是对象里的self.shi_jian字段值
"""
r.set(self.name,self._self._response_html,ex=self.shi_jian)
逻辑处理调用
#!/usr/bin/env python
#coding:utf-8 import tornado.ioloop
import tornado.web #导入tornado模块下的web文件
import time
import huanc #逻辑处理
class MainHandler(tornado.web.RequestHandler): #定义一个类，继承tornado.web下的RequestHandler类
def get(self): #get()方法，接收get方式请求
shjan = time.time() hc = huanc.huancuen(self,'index') #创建缓存对象
if hc.hc_get(): #获取缓存展现给用户，会返回一个htnl字符串，判断字符串存在说明缓存存在
return #返回不执行下面代码
self.render("index.html",shjan = shjan) #显示cshi.html文件,将shjan变量传到模板语言里渲染
hc.hc_set() #将html字符串写入缓存
self.write() class DluHandler(tornado.web.RequestHandler):
def get(self, *args, **kwargs):
shjan = time.time() hc = huanc.huancuen(self,'dlu')
if hc.hc_get():
return
self.render("dlu.html", shjan=shjan)
hc.hc_set() settings = { #html文件归类配置，设置一个字典
"template_path":"views", #键为template_path固定的，值为要存放HTML的文件夹名称
"static_path":"static", #键为static_path固定的，值为要存放js和css的文件夹名称
} #路由映射
application = tornado.web.Application([ #创建一个变量等于tornado.web下的Application方法
(r"/index", MainHandler), #判断用户请求路径后缀是否匹配字符串index,如果匹配执行MainHandler方法
(r"/dlu", DluHandler),
],**settings) #将html文件归类配置字典，写在路由映射的第二个参数里 if __name__ == "__main__":
#内部socket运行起来
application.listen(8888) #设置端口
tornado.ioloop.IOLoop.instance().start()