如何在Spring Data Aerospike中为Map特定条目设置TTL自动过期

首先得明确：Aerospike本身支持Map元素级别的TTL（过期时间），但Spring Data Aerospike的Repository默认封装没直接提供这个能力，所以咱们得借助Aerospike原生客户端的API来实现需求——毕竟Spring Data Aerospike底层就是基于原生客户端的。

一、先优化你的依赖配置 #

你当前的依赖里有重复的aerospike-client，还有system scope的spring-data-aerospike，建议调整成更规范的版本：

<dependencies>
    <!-- 统一指定Aerospike客户端版本，避免依赖冲突 -->
    <dependency>
        <groupId>com.aerospike</groupId>
        <artifactId>aerospike-client</artifactId>
        <version>4.1.3</version>
    </dependency>
    <!-- 优先用Maven仓库的依赖，实在需要本地jar再保留system和systemPath -->
    <dependency>
        <groupId>com.aerospike</groupId>
        <artifactId>spring-data-aerospike</artifactId>
        <version>2.0.0.RELEASE</version>
        <!-- <scope>system</scope>
        <systemPath>${basedir}/lib/spring-data-aerospike-2.0.0.RELEASE.jar</systemPath> -->
    </dependency>
    <dependency>
        <groupId>com.aerospike</groupId>
        <artifactId>aerospike-helper-java</artifactId>
        <version>1.2.2</version>
    </dependency>
</dependencies>

二、实现特定Map条目的过期逻辑 #

我们可以通过AerospikeTemplate获取原生客户端实例，然后用MapPolicy和MapOperation来给指定的Map条目设置TTL。

编写业务服务类 #

import com.aerospike.client.AerospikeClient;
import com.aerospike.client.Bin;
import com.aerospike.client.Key;
import com.aerospike.client.cdt.MapOperation;
import com.aerospike.client.cdt.MapPolicy;
import com.aerospike.client.cdt.MapWriteFlags;
import org.springframework.data.aerospike.core.AerospikeTemplate;
import org.springframework.stereotype.Service;

import java.util.concurrent.TimeUnit;

@Service
public class CustomerService {

    private final AerospikeClient aerospikeClient;

    // 注入Spring Data的AerospikeTemplate，从中获取原生客户端
    public CustomerService(AerospikeTemplate aerospikeTemplate) {
        this.aerospikeClient = aerospikeTemplate.getAerospikeClient();
    }

    /**
     * 给指定客户的corrDetails中特定Key设置过期时间
     * @param custId 客户ID（对应Customer的custId）
     * @param targetMapKey 要设置过期的Map键
     * @param daysToExpire 过期天数
     */
    public void setCorrDetailExpiry(String custId, String targetMapKey, int daysToExpire) {
        // 构建Aerospike对应的Key（替换成你的实际命名空间）
        Key key = new Key("你的命名空间", "cust", custId);
        // 把天数转换成Aerospike要求的秒级TTL（-1表示永不过期）
        int ttlSeconds = (int) TimeUnit.DAYS.toSeconds(daysToExpire);
        
        // 创建Map策略，设置该条目的过期时间
        MapPolicy mapPolicy = new MapPolicy();
        mapPolicy.expiration = ttlSeconds;
        // 可选：如果只想创建新条目不覆盖现有值，用CREATE_ONLY；要更新则用UPDATE_ONLY或DEFAULT
        mapPolicy.writeFlags = MapWriteFlags.DEFAULT;
        
        // 执行带TTL的Map put操作，值替换成你的实际业务值
        aerospikeClient.put(null, key, 
            new Bin("corrDetails", MapOperation.put(mapPolicy, targetMapKey, "你的业务值")));
    }
}

关键细节说明 #

• MapPolicy.expiration：专门针对单个Map条目设置TTL，到期后Aerospike会自动删除这个KV对，完全不会影响Map里的其他条目。
• 如果你的corrDetails值是复杂对象，要确保Aerospike能正确序列化/反序列化——可以用Aerospike自带的序列化，或者结合Jackson自定义序列化逻辑。
• 当条目过期后，从corrDetails中获取这个Key会返回null，业务代码里要做好空值处理。

三、注意事项 #

• Spring Data Aerospike的Repository接口目前不支持Map元素级TTL的操作，所以必须用原生客户端API来实现这个高级特性。
• 确保你的Aerospike集群版本支持Map元素TTL（Aerospike 3.10及以上版本都支持）。

内容的提问来源于stack exchange，提问作者Aditya Goel