Quarkus中基于Reactive Redis添加带过期时间键值对的实现咨询

嗨，我完全懂你现在的困惑——在Quarkus的Reactive Redis场景下想添加带过期时间的键值对，结果发现ReactiveKeyCommands里根本找不到set、setex这类方法，之前看的指南也没覆盖这个场景，确实容易卡壳。

其实问题出在Quarkus的Reactive Redis是按命令分组拆分接口的：ReactiveKeyCommands只负责键的基础操作（比如删除、检查存在性），而设置键值对的操作，是放在ReactiveStringCommands这个接口里的（针对字符串类型的键值对，这也是最常用的场景）。

下面给你具体的实现步骤：

1. 注入正确的Commands接口 #

首先你需要注入ReactiveStringCommands，而不是ReactiveKeyCommands，示例代码如下：

import io.quarkus.redis.datasource.ReactiveRedisDataSource;
import io.quarkus.redis.datasource.string.ReactiveStringCommands;
import jakarta.inject.Inject;
import jakarta.enterprise.context.ApplicationScoped;
import java.time.Duration;
import io.smallrye.mutiny.Uni;

@ApplicationScoped
public class ReactiveRedisService {

    private final ReactiveStringCommands<String, String> stringCommands;

    @Inject
    public ReactiveRedisService(ReactiveRedisDataSource dataSource) {
        // 指定键和值的类型都是String，你也可以根据实际需求换其他类型
        this.stringCommands = dataSource.string(String.class, String.class);
    }
}

2. 实现带过期时间的键值对设置 #

这里有两种常见方式，推荐第一种（原子操作）：

• 方式一：原子性设置键值+过期时间
  用set方法配合SetArgs来指定过期规则，这是Redis原生的原子操作，不会出现设置键后还没来得及加过期时间就出问题的情况：

public Uni<Void> setKeyWithExpiry(String key, String value, Duration expiry) {
    // 使用ex()设置秒级过期，也可以用px()设置毫秒级过期
    return stringCommands.set(key, value, SetArgs.Builder.ex(expiry));
}

如果需要指定具体的过期时间点（比如到某个时间戳过期），可以用exAt()（秒级时间戳）或pxAt()（毫秒级时间戳）替换ex()。

• 方式二：先设置键值，再单独添加过期时间
  这种是两步操作，不具备原子性，适合对原子性要求不高的场景：

public Uni<Void> setKeyThenExpire(String key, String value, Duration expiry) {
    return stringCommands.set(key, value)
            // 链式调用添加过期时间
            .chain(() -> stringCommands.expire(key, expiry));
}

补充说明 #

你之前看的那个递增服务示例，用的是ReactiveNumberCommands，专门处理数值型的递增/递减操作，所以没涉及字符串键值的设置场景，这也是你没找到例子的原因~

另外如果你的键值对是其他数据类型（比如哈希、列表），对应的数据操作会在其他Commands接口里，但字符串类型是最通用的键值对场景，上面的方案应该能解决你的问题。

备注：内容来源于stack exchange，提问作者Арчи