Redis：构建高可靠性系统的利器

import redis

# 连接Redis数据库
redis_client = redis.Redis(host='localhost', port=6379, db=0)

def get_data_from_cache(key):
    # 尝试从缓存中获取数据
    data = redis_client.get(key)

    if not data:
        # 如果缓存中没有数据，则从数据库中查询
        data = get_data_from_database(key)

        # 将数据存入缓存，有效期设置为60秒
        redis_client.set(key, data, ex=60)

    return data

import redis
import threading

# 连接Redis数据库
redis_client = redis.Redis(host='localhost', port=6379, db=0)

def publish_message(channel, message):
    # 发布消息到指定的频道
    redis_client.publish(channel, message)

def handle_message(message):
    # 处理接收到的消息
    print("Received message:", message)

# 启动一个订阅线程
def subscribe_channel(channel):
    pubsub = redis_client.pubsub()
    pubsub.subscribe(channel)

    for message in pubsub.listen():
        # 处理接收到的消息
        handle_message(message)

# 在主线程中发布消息
def main():
    # 发布一个消息到名为"chat"的频道
    threading.Thread(target=subscribe_channel, args=("chat",)).start()
    publish_message("chat", "Hello, World!")

if __name__ == "__main__":
    main()