Python：redis 库高级用法举例和应用详解

import redis  # 导入redis库

# 连接到Redis服务器
client = redis.StrictRedis(host='localhost', port=6379, db=0)

# 设置一个缓存数据，key为'user:1000'，value为用户信息字典
client.set('user:1000', '{"name": "Alice", "age": 30}')  # 设置用户Alice的信息为缓存

# 获取缓存的数据
user_data = client.get('user:1000')  # 从Redis获取用户信息
if user_data:
    user_info = user_data.decode('utf-8')  # 解码bytes为字符串
    print(f"User Data: {user_info}")  # 打印用户信息
else:
    print("User not found in cache.")  # 如果未找到用户数据

import redis  # 导入redis库

# 连接到Redis服务器
client = redis.StrictRedis(host='localhost', port=6379, db=0)

# 开始一个事务
pipeline = client.pipeline()  # 创建一个事务管道

# 向事务中添加操作，设置key值
pipeline.set('counter', 0)  # 初始化计数器
pipeline.incr('counter')  # 增加计数器
pipeline.incr('counter')  # 再次增加计数器

# 执行所有操作
output = pipeline.execute()  # 执行事务中的所有命令
print(f"Transaction Output: {output}")  # 打印事务执行结果

import redis  # 同样导入redis库
import threading  # 导入线程库以处理异步消息

# 连接到Redis服务器
client = redis.StrictRedis(host='localhost', port=6379, db=0)

def message_handler(message):
    print(f"Received Message: {message['data'].decode()}")  # 处理接收到的消息

# 创建一个订阅者线程
def subscriber():
    pubsub = client.pubsub()  # 创建发布-订阅对象
    pubsub.subscribe(**{'my_channel': message_handler})  # 订阅'my_channel'频道
    pubsub.run_in_thread(sleep_time=0.001)  # 以线程方式运行

subscriber_thread = threading.Thread(target=subscriber)  # 启动订阅线程
subscriber_thread.start()  # 开始监听消息

# 发布消息到频道
client.publish('my_channel', 'Hello Redis!')  # 发送消息

# 确保订阅者可以处理消息
import time
time.sleep(2)  # 等待一定时间后结束