qhfl-5 redis 简单操做

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:6379> config get *
# 获取单个配置项
redis 127.0.0.1:6379> config get loglevel
# 编辑配置
redis 127.0.0.1:6379> config set loglevel "notice"

Redis 数据类型

-- String 字符串
    -- redis的string能够包含任何数据，包括图片以及序列化的对象，一个键最大能存储512MB。

-- Hash 哈希
　-- redis的hash是一个String类型的key和value的映射表，hash特别适合存储对象，类比python字典。

-- List 列表
    -- redis的list是简单的字符串列表，按照插入顺序排序，能够从两端进行添加，相似于双向链表，列表还能够进行阻塞。

-- Set 集合
    -- redis的set是字符串类型的无序且不重复集合。集合是经过哈希表实现的，因此添加，删除，查找的时间复杂度都是O(1)。

-- 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=0，删除列表中全部的指定值；
　　　　num=2,从前到后，删除2个； num=1,从前到后，删除左边第1个
　　　　num=-2,从后向前，删除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 的文档 以及源码里看封装的一些方法