使用redis实现延时任务

要使用Redis实现延时任务，可以使用Sorted Set（有序集合）来存储任务及其执行时间。客户端会定期检查Sorted Set中已到期的任务并执行它们。

以下是一个简单的Python示例，使用redis-py库实现：

import time
import redis
 
# 连接到Redis
redis_host = 'localhost'
redis_port = 6379
redis_db = 0
r = redis.StrictRedis(host=redis_host, port=redis_port, db=redis_db)
 
# 将任务添加到Redis Sorted Set中
def add_delay_task(task_id, delay_seconds):
    score = time.time() + delay_seconds
    r.zadd('delay_tasks', {task_id: score})
 
# 执行到期的任务
def process_delay_tasks():
    while True:
        # 获取当前时间
        now = time.time()
        # 获取分数（时间戳）小于等于当前时间的任务
        tasks = r.zrangebyscore('delay_tasks', 0, now)
        for task_id in tasks:
            # 执行任务
            print(f"Executing task: {task_id}")
            # 从Sorted Set中移除已经执行的任务
            r.zrem('delay_tasks', task_id)
        # 休眠一段时间后继续检查
        time.sleep(5)
 
# 示例：添加一个延时任务
add_delay_task('task1', 10)
 
# 启动循环以执行任务
process_delay_tasks()

在这个例子中，add_delay_task函数将任务和延时时间添加到名为delay_tasks的Sorted Set中。process_delay_tasks函数是一个无限循环，它会定期检查是否有任务已经到期，如果有，就执行它们。这里的time.sleep(5)表示每隔5秒检查一次。

请确保Redis服务器正在运行，并且根据你的环境调整连接参数。