在Spring Boot中，你可以使用Redisson来实现延迟队列。以下是一个简单的例子，展示如何配置Redisson并使用它的延迟队列功能。
- 添加
Redisson依赖到你的pom.xml中：
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson-spring-boot-starter</artifactId>
<version>3.16.2</version>
</dependency>- 配置
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);
}
}- 使用
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）上。