Spring Boot 整合：Redis 延时队列的实现方案（基于有赞的设计）

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ZSetOperations;
import java.util.Set;
import java.util.concurrent.TimeUnit;
 
public class DelayQueue {
 
    private RedisTemplate<String, Object> redisTemplate;
    private String key;
 
    public DelayQueue(RedisTemplate<String, Object> redisTemplate, String key) {
        this.redisTemplate = redisTemplate;
        this.key = key;
    }
 
    public void push(Object value, long delaySeconds) {
        long score = System.currentTimeMillis() + TimeUnit.SECONDS.toMillis(delaySeconds);
        redisTemplate.opsForZSet().add(key, value, score);
    }
 
    public Object pop() {
        while (true) {
            long now = System.currentTimeMillis();
            Set<Object> values = redisTemplate.opsForZSet().rangeByScore(key, 0, now);
            if (values == null || values.isEmpty()) {
                try {
                    Thread.sleep(50);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                    break;
                }
            } else {
                ZSetOperations<String, Object> zSetOps = redisTemplate.opsForZSet();
                for (Object value : values) {
                    zSetOps.remove(key, value);
                    return value;
                }
            }
        }
    }
}

这个代码实例展示了如何使用Redis的ZSet数据结构来实现一个基本的延时队列。push方法将元素加入到延时队列中，其中score是消息需要被处理的时间。pop方法循环检查并移除那些到期的元素。这个简单的实现没有考虑优先级问题，也没有使用锁来避免并发问题，它只是展示了基本的逻辑。在实际应用中，你需要根据具体需求来扩展和优化这个实现。