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持久化以及如何使用事务来确保命令的执行顺序。