# 实例化Redis对象
# decode_responses True 写入的KV对中的V为string类型 不加则写入的为字节类型
self.redis_obj Redis(host 139.199.**.** , port 6379, password 123456 ,
decode_responses True,
charset UTF-8 , encoding UTF-8 )
def start(self):
# 1、操作字符串
# self.manage_str()
# 2、操作列表
# self.manage_list()
# 3、操作set集合
# self.manage_set()
# 4、操作zset集合
# self.manage_zset()
# 5、操作哈希表
# self.manage_hash()
# 6、执行事务 即一系列操作
self.manage_steps()
def manage_str(self):
操作字符串
:return:
# 单值操作
# 1、添加一个值 并设置超时时间为120s
# 单位为 秒
# set(key,value,超时时间)
self.redis_obj.set( name , airpython , ex 120)
# 2、获取一个值
# get(key)
print(self.redis_obj.get( name ))
# 3、删除一个值
# delete(key)
self.redis_obj.delete( name )
print(self.redis_obj.get( name ))
# 4、设置某一个值自增1
self.redis_obj.set( count , 2)
# 自增1
self.redis_obj.incr( count )
print(self.redis_obj.get( count ))
# 5、自减1
self.redis_obj.decr( count )
print(self.redis_obj.get( count ))
# 查看类型:string
print(self.redis_obj.type( count ))
# 多值操作
# mset() 设置多个值
self.redis_obj.mset({ foo : foo1 , zoo : zoo1 })
# mget() 获取多个值
result self.redis_obj.mget( foo , zoo )
print(result)
def manage_list(self):
操作列表
:return:
# 先清空元素
self.redis_obj.delete( company )
# 1、新增一个列表 并左边插入一个数据
# 注意 可以一次加入多个元素 也可以一个个元素的加入
self.redis_obj.lpush( company , 阿里 , 腾讯 , 百度 )
# 移除第一个元素
self.redis_obj.lpop( company )
# 2、右边插入数据
self.redis_obj.rpush( company , 字节跳动 , 小米 )
# 移除最后一个元素
self.redis_obj.rpop( company )
# 3、获取列表的长度
self.redis_obj.llen( company )
# 通过索引 获取列表中的某一个元素 第二个元素
print( 列表中第二个元素是 , self.redis_obj.lindex( company , 1))
# 2、根据范围 查看列表中所有的值
print(self.redis_obj.lrange( company , 0, -1))
def manage_set(self):
操作set集合
:return:
self.redis_obj.delete( fruit )
# 1、sadd 新增元素到集合中
# 添加一个元素 香蕉
self.redis_obj.sadd( fruit , 香蕉 )
# 再添加两个元素
self.redis_obj.sadd( fruit , 苹果 , 桔子 )
# 2、集合元素的数量
print( 集合元素数量 , self.redis_obj.scard( fruit ))
# 3、移除一个元素
self.redis_obj.srem( fruit , 桔子 )
# 再定义一个集合
self.redis_obj.sadd( fruit_other , 香蕉 , 葡萄 , 柚子 )
# 4、获取两个集合的交集
result self.redis_obj.sinter( fruit , fruit_other )
print(type(result))
print( 交集为 , result)
# 5、获取两个集合的并集
result self.redis_obj.sunion( fruit , fruit_other )
print(type(result))
print( 并集为 , result)
# 6、差集 以第一个集合为标准
result self.redis_obj.sdiff( fruit , fruit_other )
print(type(result))
print( 差集为 , result)
# 7、合并保存到新的集合中
self.redis_obj.sunionstore( fruit_new , fruit , fruit_other )
print( 新的集合为 , self.redis_obj.smembers( fruit_new ))
# 8、判断元素是否存在集合中
result self.redis_obj.sismember( fruit , 苹果 )
print( 苹果是否存在于集合中 , result)
# 9、随机从集合中删除一个元素 然后返回
result self.redis_obj.spop( fruit )
print( 删除的元素是: , result)
# 3、集合中所有元素
result self.redis_obj.smembers( fruit )
print( 最后fruit集合包含的元素是: , result)
def manage_zset(self):
操作zset集合
:return:
self.redis_obj.delete( fruit )
# 1、往集合中新增元素 zadd()
# 三个元素分别是 banana , 1/ apple , 2/ pear , 3
self.redis_obj.zadd( fruit , banana , 1, apple , 2, pear , 3)
# 2、查看集合中所有元素 不带分数
result self.redis_obj.zrange( fruit , 0, -1)
# [ banana , apple , pear ]
print( 集合中的元素 不带分数 有 , result)
# 3、查看集合中所有元素 带分数
result self.redis_obj.zrange( fruit , 0, -1, withscores True)
# [( banana , 1.0), ( apple , 2.0), ( pear , 3.0)]
print( 集合中的元素 带分数 有 , result)
# 4、获取集合中某一个元素的分数
result self.redis_obj.zscore( fruit , apple )
print( apple对应的分数为 , result)
# 5、通过最小值和最大值 判断分数在这个范围内的元素个数
result self.redis_obj.zcount( fruit , 1, 2)
print( 集合中分数大于1 小于2的元素个数有 , result)
# 6、获取集合中元素个数
count self.redis_obj.zcard( fruit )
print( 集合元素格式: , count)
# 7、获取元素的值获取索引号
index self.redis_obj.zrank( fruit , apple )
print( apple元素的索引为 , index)
# 8、删除集合中的元素 zrem
self.redis_obj.zrem( fruit , apple )
print( 删除apple元素后 剩余元素为 , self.redis_obj.zrange( fruit , 0, -1))
def manage_hash(self):
操作哈希表
哈希 一个键对应一个值 并且键不容许重复
:return:
self.redis_obj.delete( website )
# 1、新建一个key为website的哈希表
# 往里面加入数据 baidu field www.baidu.com(value)
self.redis_obj.hset( website , baidu , www.alibababaidu.com )
self.redis_obj.hset( website , google , www.google.com )
# 2、往哈希表中添加多个键值对
self.redis_obj.hmset( website , { tencent : www.qq.com , alibaba : www.taobao.com })
# 3、获取某一个键的值
result self.redis_obj.hget( website , baidu )
print( 键为baidu的值为 , result)
# 4、获取多个键的值
result self.redis_obj.hmget( website , baidu , alibaba )
print( 多个键的值为: , result)
# 5、查看hash表中的所有值
result self.redis_obj.hgetall( website )
print( 哈希表中所有的键值对为 , result)
# 6、哈希表中所有键列表
# [ baidu , google , tencent , alibaba ]
result self.redis_obj.hkeys( website )
print( 哈希表 所有的键 列表 为: , result)
# 7、哈希表中所有的值列表
# [ www.alibababaidu.com , www.google.com , www.qq.com , www.taobao.com ]
result self.redis_obj.hvals( website )
print( 哈希表 所有的值 列表 为: , result)
# 8、判断某一个键是否存在
result self.redis_obj.hexists( website , alibaba )
print( alibaba这个键是否存在: , result)
# 9、删除某一个键值对
self.redis_obj.hdel( website , baidu )
print( 删除baidu键值对后 哈希表的数据包含 , self.redis_obj.hgetall( website ))
# 10、哈希表中键值对个数
count self.redis_obj.hlen( website )
print( 哈希表键值对一共有 , count)
def manage_steps(self):
执行事务操作
:return:
# 1、定义一个事务管道
self.pip self.redis_obj.pipeline()
# 定义一系列操作
self.pip.set( age , 18)
# 增加一岁
self.pip.incr( age )
# 减少一岁
self.pip.decr( age )
# 执行上面定义3个步骤的事务操作
self.pip.execute()
# 判断
print( 通过上面一些列操作 年龄变成: , self.redis_obj.get( age ))