Redis
Redis是完全开源免费的,遵守BSD协议,是一个高性能的key-value数据库。
Redis有以下特点:
-- Redis支持数据的持久化,可以将内存中的数据保存在磁盘中,重启的时候可以再次加载进行使用。
-- Redis支持五种数据类型。
-- Redis支持数据库备份。
Redis的优势:
-- Redis性能极高,读的速度是110000次/s,写的速度是81000次/s。
-- Redis丰富的数据类型,String,Lists,Hashes,Sets以及Ordered Sets。
-- Redis的所有操作都是原子性的,意思就是要么成功执行,要么完全失败不执行,多个操作支持事物。即MULTI和EXEC指令包起来。
-- Redis有丰富的特性,支持publish/subscribe,通知,key过期等等特性。
Redis 配置
-- 可以通过redis-cli 进入交互模式,使用config命令查看或设置配置项。也可以进入配置文件用vim编辑器进行修改。
# 获取所有配置项
reids 127.0.0.1:> config get *
# 获取单个配置项
redis 127.0.0.1:> config get loglevel
# 编辑配置
redis 127.0.0.1:> config set loglevel "notice"
Redis 数据类型
-- String 字符串
-- redis的string可以包含任何数据,包括图片以及序列化的对象,一个键最大能存储512MB。 -- Hash 哈希
-- redis的hash是一个String类型的key和value的映射表,hash特别适合存储对象,类比python字典。 -- List 列表
-- redis的list是简单的字符串列表,按照插入顺序排序,可以从两端进行添加,类似于双向链表,列表还可以进行阻塞。 -- Set 集合
-- redis的set是字符串类型的无序且不重复集合。集合是通过哈希表实现的,所以添加,删除,查找的时间复杂度都是O()。 -- Zset 有序集合
-- redis的zset和set一样,不同的是每个元素都会关联一个double类型的分数,redis正是通过对分数的排序对集合进行有序存储。
Python 操作Redis
-- 下载 pip install redis
-- 连接
Redis提供两个类Redis和StrictRedis用于实现Redis的命令,StrictRedis用于实现大部分官方的命令,并使用官方的语法和命令,
Redis是StrictRedis的子类,用于向后兼容旧版本的redis-py。
Redis连接实例是线程安全的,可以直接将redis连接实例设置为一个全局变量,直接使用。
如果需要另一个Redis实例(or Redis数据库)时,就需要重新创建redis连接实例来获取一个新的连接
连接redis,加上decode_responses=True,写入的键值对中的value为str类型,不加这个参数写入的则为字节类型。
redis 简单设置值
import redis conn = redis.Redis(host="127.0.0.1", port=6379, decode_responses=True) # conn.set("n1", "v1")
# conn.hset("n2", "k2", "v2") # 设置字典 redis = {n2: {k2: v2}} # ret1 = conn.get("n1")
# ret2 = conn.hget("n2", "k2")
# print(ret1)
# print(ret2) conn.hmset("n3", {"k3": "v3", "k4": "v4"}) # 设置多个值 # ret3 = conn.hget("n3", "k3")
# ret4 = conn.hget("n3", "k4")
# ret5 = conn.hgetall("n3") # 获取所有值
# ret6 = conn.get("xxxx")
# print(ret6) # print(ret3)
# print(ret4)
# print(ret5)
set(name, value, ex=None, px=None, nx=False, xx=False) 在Redis中设置值,默认,不存在则创建,存在则修改
参数:
ex,过期时间(秒)过期后值None
px,过期时间(毫秒)
nx,如果设置为True,则只有name不存在时,当前set操作才执行
xx,如果设置为True,则只有name存在时,当前set操作才执行 注:ex,px,nx,xx可以跟在命令后面 eg: setnx 表示只能创建 hash命令一样适用 get(key) 获取key的值 mset(*args, **kwargs) 批量设置值 mget(key, *args) .....请走入官方文档..... Redis命令之String
Redis的命令 String
hset(name, key, value) 增加单个 不存在则创建 hget(name, key) 获取单个 hmset(name, mapping) 批量增加 mapping为字典 hgetall(name) 获取name对应hash的所有键值 hlen(name) 获取name对应的hash中键值对的个数 hkeys(name) 获取name对应的hash中所有的key的值 hvals(name) 获取name对应的hash中所有的value的值 hexists(name, key) 检查name对应的hash是否存在当前传入的key hdel(name,*keys) 将name对应的hash中指定key的键值对删除 hscan_iter(name, match=None, count=None)
利用yield封装hscan创建生成器,实现分批去redis中获取数据
参数:
match,匹配指定key,默认None 表示所有的key
count,每次分片最少获取个数,默认None表示采用Redis的默认分片个数 Redis命令之Hash
hash
lpush(name,values) 在name对应的list中左边添加元素 没有就新建 llen(name) 获取name对应的列表长度 lrang(name, index1, index2) 按照index切片取出name对应列表里值 lpushx(name, value) 只能添加不能新建 linsert(name, where, refvalue, value)) 在name对应的列表的某一个值前或后插入一个新值
参数:
name,redis的name
where,BEFORE或AFTER
refvalue,标杆值,即:在它前后插入数据
value,要插入的数据 lset(name, index, value) 给指定索引修改值 lrem(name, value, num) 在name对应的list中删除指定的值
参数:
name,redis的name
value,要删除的值
num, num=,删除列表中所有的指定值;
num=,从前到后,删除2个; num=,从前到后,删除左边第1个
num=-,从后向前,删除2个 lindex(name, index) 在name对应的列表中根据索引获取列表元素 Redis命令之List
list
Python Redis 连接池
使用connection pool来管理对一个redis server的所有连接,避免每次建立、释放连接的开销。
默认,每个Redis实例都会维护一个自己的连接池。可以直接建立一个连接池,
然后作为参数传给Redis实例,这样就可以实现多个Redis实例共享一个连接池。
import redis # 保持跟数据库的链接,当超过数量时,就等着
# # 解码,打印出来不再是b'xx' 最大链接数
pool = redis.ConnectionPool(host="127.0.0.1", port=6379, decode_responses=True, max_connections=10) conn = redis.Redis(connection_pool=pool) ret = conn.get("n1")
print(ret)
redis发布订阅者模型
启动监听
import redis
conn = redis.Redis(host="127.0.0.1", port=6379, decode_responses=True) # 第一步 生成一个订阅者对象
pubsub = conn.pubsub()
# 第二步 订阅一个消息
pubsub.subscribe("lewen")
# 创建一个接收
while True:
print("working~~~")
msg = pubsub.parse_response()
print(msg) # 默认值是1 # 只要订阅的内容发布改变,就会更新所有
发布内容
import redis
conn = redis.Redis(host="127.0.0.1", port=6379, decode_responses=True)
conn.publish("lewen", "cq")
Django Redis
pip install django-redis
参考django-redis 的文档 以及源码里看封装的一些方法