Spring Boot整合Redis通过Zset数据类型+定时任务实现延迟队列

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
 
import java.util.Set;
 
@Component
public class DelayQueueConsumer {
 
    private final RedisTemplate<String, Object> redisTemplate;
 
    public DelayQueueConsumer(RedisTemplate<String, Object> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }
 
    @Scheduled(fixedRate = 1000) // 设置定时任务的执行频率，单位毫秒
    public void processDelayQueue() {
        // 获取当前时间戳
        long currentTimestamp = System.currentTimeMillis();
        // 使用ZRANGEBYSCORE命令获取所有score小于等于当前时间戳的数据
        Set<Object> items = redisTemplate.opsForZSet().rangeByScore("delay_queue", 0, currentTimestamp);
        for (Object item : items) {
            // 处理业务逻辑
            // ...
 
            // 移除已经处理的数据
            redisTemplate.opsForZSet().remove("delay_queue", item);
        }
    }
}

这段代码展示了如何使用Spring Boot整合Redis的Zset数据结构来实现一个简单的延时队列。它定义了一个DelayQueueConsumer组件，该组件使用@Scheduled注解设置了一个定时任务，定时检查并处理那些已经到期的任务。这里的关键点是使用Redis的Zset数据结构来存储带有延迟时间的任务，并且通过定时任务来轮询这些任务并进行处理。