Spring Boot集成Redisson实现延迟队列

在Spring Boot中，你可以使用Redisson来实现延迟队列。以下是一个简单的例子，展示如何配置Redisson并使用它的延迟队列功能。

1. 添加Redisson依赖到你的pom.xml中：

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.16.2</version>
</dependency>

2. 配置RedissonClient：

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
@Configuration
public class RedissonConfig {
 
    @Bean(destroyMethod="shutdown")
    RedissonClient redisson() {
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        return Redisson.create(config);
    }
}

3. 使用RDelayedQueue：

import org.redisson.api.RDelayedQueue;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
 
@Component
public class DelayQueueExample {
 
    @Autowired
    private RedissonClient redissonClient;
 
    public void put(Object object) {
        RDelayedQueue<Object> delayedQueue = redissonClient.getDelayedQueue();
        delayedQueue.offer(object, 5, TimeUnit.SECONDS); // 延迟5秒
    }
 
    public void consume() {
        RDelayedQueue<Object> delayedQueue = redissonClient.getDelayedQueue();
        delayedQueue.poll(10, TimeUnit.SECONDS, (msg, throwable) -> {
            // 处理消息
            System.out.println("消费了: " + msg);
        });
    }
}

在这个例子中，put方法将一个对象放入延迟队列，延迟时间是5秒。consume方法从延迟队列中取出对象并处理它，它会阻塞等待直到有消息可以消费或者超时。

确保你的Redis服务器正在运行并可以被Spring Boot应用所访问。这个例子假设Redis运行在本地主机（127.0.0.1）的默认端口（6379）上。