springboot redis延迟消息队列实现代码怎么写

实现延迟消息队列可以使用 Redis 的 sorted set 数据结构，其中 score 表示消息的执行时间戳，member 表示消息内容。每隔一段时间轮询一次 sorted set，将 score 小于当前时间的消息取出来执行即可。

下面是一个基于 Spring Boot 和 Redis 的简单实现代码：

首先引入 Redis 相关依赖，在 pom.xml 文件中添加以下内容：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

然后创建一个消息实体类 DelayMessage，用于存储消息内容和执行时间戳：

public class DelayMessage {
    private String message;
    private long executeTime;

    // getter 和 setter 方法省略
}

接着创建一个 Redis 延迟消息队列的服务 DelayQueueService，其中包含添加消息和轮询消息的方法：

@Service
public class DelayQueueService {
    private static final String DELAY_QUEUE_KEY = "delay_queue";

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    // 添加延迟消息
    public void addDelayMessage(DelayMessage message) {
        redisTemplate.opsForZSet().add(DELAY_QUEUE_KEY, message, message.getExecuteTime());
    }

    // 轮询延迟消息
    public List<DelayMessage> pollDelayMessage() {
        long currentTime = System.currentTimeMillis();
        Set<Object> messages = redisTemplate.opsForZSet().rangeByScore(DELAY_QUEUE_KEY, 0, currentTime);
        if (messages != null && !messages.isEmpty()) {
            List<DelayMessage> result = new ArrayList<>();
            for (Object message : messages) {
                redisTemplate.opsForZSet().remove(DELAY_QUEUE_KEY, message);
                result.add((DelayMessage) message);
            }
            return result;
        }
        return null;
    }
}

最后在需要使用延迟消息队列的地方调用 addDelayMessage 方法添加消息，轮询消息可以单独开一个线程或者使用定时任务实现。

注意：以上代码只是一个简单的示例，实际使用中需要考虑分布式环境下的并发问题。