SpringBoot实现redis延迟队列的示例代码-编程学习网

这篇文章将为大家详细讲解有关SpringBoot实现redis延迟队列的示例代码，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。

SpringBoot实现Redis延迟队列示例代码

简介

Redis延迟队列利用了Redis的zset有序集合和list类型，实现了延迟执行任务的功能。该队列将任务存入zset集合，并设置一个特定时间戳作为score。当时间戳到达时，任务将从zset集合中弹出并执行。

实现

1. 创建zset集合和list

// zset集合，存储任务和时间戳
ZSetOperations<String, String> zset = redisTemplate.opsForZSet();

// list，存储延迟任务
ListOperations<String, String> list = redisTemplate.opsForList();

2. 入队任务

// 任务ID
String taskId = "task1";

// 执行时间戳
long timestamp = System.currentTimeMillis() + 10000; // 10秒后执行

// 入队，score为时间戳
zset.add("delay-queue", taskId, timestamp);

// 将任务放入list中
list.rightPush("delay-queue-list", taskId);

3. 定时执行任务

// 定时任务，每秒执行一次
@Scheduled(fixedRate = 1000)
public void executeTasks() {
    // 获取当前时间戳
    long now = System.currentTimeMillis();

    // 获取并移除score小于当前时间戳的任务
    Set<String> tasks = zset.rangeByScore("delay-queue", Double.MIN_VALUE, now);
    zset.remove("delay-queue", tasks);

    // 执行任务
    for (String task : tasks) {
        // 处理任务逻辑
        System.out.println("Executing task: " + task);

        // 从list中移除任务
        list.leftPop("delay-queue-list");
    }
}

4. 移除过期任务

// 定时任务，每24小时执行一次
@Scheduled(fixedRate = 86400000) // 24小时
public void cleanExpiredTasks() {
    // 获取当前时间戳
    long now = System.currentTimeMillis();

    // 移除score小于now的任务
    zset.removeRangeByScore("delay-queue", Double.MIN_VALUE, now);

}

注意事项