redis06_ redis的订阅发布模式(redis做MQ中间件)、持久化(rdb,aof)、事务
Redis的订阅发布模式(pub/sub)可以用来创建消息队列系统。生产者将消息发布到某个频道,消费者订阅相应的频道以接收消息。
import redis
# 连接Redis
r = redis.Redis(host='localhost', port=6379, db=0)
# 生产者发布消息
r.publish('channel1', 'hello world')
# 消费者订阅频道并接收消息
def callback(message):
print(f"Received: {message['data']}")
# 创建一个新的订阅对象
pubsub = r.pubsub()
# 订阅频道
pubsub.subscribe(**{'channel1': callback})
# 开始监听订阅的频道,这个调用会阻塞直到程序退出
pubsub.run_in_thread(sleep_time=0.001)
Redis的持久化机制有两种方式:RDB(定时快照)和AOF(append-only file)。
RDB:定时将内存中的数据快照保存到磁盘的一个压缩二进制文件中。
# redis.conf 配置
save 900 1 # 900秒内至少1个键被修改则触发保存
save 300 10 # 300秒内至少10个键被修改则触发保存
save 60 10000 # 60秒内至少10000个键被修改则触发保存
dbfilename dump.rdb # RDB文件名
dir /path/to/redis/dir # RDB文件存储目录
AOF:每个写命令都通过append操作保存到文件中。
# redis.conf 配置
appendonly yes # 开启AOF
appendfilename "appendonly.aof" # AOF文件名
dir /path/to/redis/dir # AOF文件存储目录
Redis的事务(multi/exec/discard)可以确保一系列命令的执行不会被其他客户端打断:
# 连接Redis
r = redis.Redis(host='localhost', port=6379, db=0)
# 开启事务
pipeline = r.pipeline()
# 将命令加入到事务中
pipeline.multi()
pipeline.set('key1', 'value1')
pipeline.set('key2', 'value2')
# 执行事务
pipeline.exec()
以上代码展示了如何在Redis中使用发布/订阅模式、配置RDB和AOF持久化以及如何使用事务来确保命令的执行顺序。
评论已关闭