Redis

Posted 2020-11-24 tangshuo

简介

　　高性能 key-value数据库

　　支持数据持久化，可以将内存中的数据保存到磁盘，重启再次加载使用

　　五种数据类型

　　支持数据库备份

　　原子性

　　发布订阅这模式

　　key过期

python简单操作redis

• 本地启动redis服务

• import redis
  conn = redis.Redis(decode_responses=True) #这样拿出来的不是bytes 是字符串了
  conn.set(‘n1‘,‘v1‘)
  conn.hset(‘n2‘,‘k2‘,‘v2‘)     #{"n2":{"k2":"v2"}}
  ret1 = conn.get(‘n1‘)
  ret2 = conn.hget(‘n2‘,‘k2‘)
  
  -----------------------------------------------------------------------------------
  
  conn.hmset(‘n3‘,{"k3":"v3","k4":"v4"}) #支持直接传字典
  ret3 = conn.hget(‘n3‘,‘k3‘)    #v3
  ret4 = conn.hget(‘n3‘,‘k4‘)    #v4
  ret5 = conn.hgetall(‘n3‘)      #全拿
  

   

  　

redis连接池

import redis
pool = redis.ConnectionPool(decode_responses=True,max_connections=100) #具体参数点进去看
conn = redis.Redis(connection_pool=pool)
ret1 = conn.get(‘n1‘)
print(ret1)

以及发布者订阅者模型

　　发布者

 

import redis
conn = redis.Redis(decode_responses=True)
conn.publish(‘sss‘,‘hhhh3333333‘)

 

　　订阅者

import redis
conn = redis.Redis(decode_responses=True)
#生成订阅者对象
pubsub = conn.pubsub()
#订阅一个消息（监听一个对象)
pubsub.subscribe("sss")
#创建接受
while True:
    print("working....")
    msg = pubsub.parse_response()
    print(msg)

 

 

　　发布者改变 订阅者也改变