spring-boot 整合 redisson 实现延时队列（文末有彩蛋）

import org.redisson.Redisson;
import org.redisson.api.RDelayedQueue;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
 
import java.util.concurrent.TimeUnit;
 
public class RedissonDelayQueueExample {
 
    public static void main(String[] args) {
        // 配置Redisson客户端
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        RedissonClient redisson = Redisson.create(config);
 
        // 创建延时队列
        RDelayedQueue<String> delayedQueue = redisson.getDelayedQueue();
 
        // 添加延时任务
        delayedQueue.offer("myTask", 5, TimeUnit.SECONDS);
 
        // 延时获取任务，并处理
        delayedQueue.poll(5, TimeUnit.SECONDS, (task) -> {
            // 处理任务的逻辑
            System.out.println("任务被处理：" + task);
            return null;
        });
 
        // 关闭Redisson客户端
        redisson.shutdown();
    }
}

这段代码展示了如何使用Redisson来实现一个简单的延时队列。首先，我们配置了Redisson客户端以连接到本地运行的Redis服务器。然后，我们创建了一个RDelayedQueue对象，并使用offer方法向队列中添加了一个延时任务。最后，我们使用poll方法从队列中延时获取任务并处理它。这个例子简单明了地展示了如何使用Redisson来实现和管理延时队列。