Apache Ignite中AtomicLong及原子对象是否支持TTL配置？

Apache Ignite的AtomicLong这类原子对象本身不支持直接设置TTL或内置驱逐策略——因为原子对象属于分布式原子性原语，并非缓存条目，没有内置的过期机制。不过可以通过以下两种方案实现类似效果：

方案1：改用缓存存储计数器（推荐） #

把限流密钥和对应计数值存入Ignite缓存，给缓存条目配置TTL，同时利用缓存的原子操作实现计数逻辑：

• 配置缓存全局TTL（以1分钟为例）：

  CacheConfiguration<String, Long> rlCacheCfg = new CacheConfiguration<>("rate-limit-cache");
  // 设置创建后1分钟过期
  rlCacheCfg.setExpiryPolicyFactory(CreatedExpiryPolicy.factoryOf(new Duration(TimeUnit.MINUTES, 1)));
  IgniteCache<String, Long> rlCache = ignite.getOrCreateCache(rlCacheCfg);
  

• 或者在存入时指定单个条目TTL：

  // 单个条目设置1分钟过期
  rlCache.put("user-123", 0L, new Duration(TimeUnit.MINUTES, 1));
  

• 用缓存的原子方法完成计数：

  // 递增计数
  long count = rlCache.incrementAndGet("user-123");
  

这种方案完全契合Ignite的缓存设计，到期条目会自动被驱逐，无需额外维护逻辑。

方案2：手动维护原子对象的过期清理 #

如果必须使用AtomicLong，可以额外维护一个记录过期时间的缓存，配合定时任务清理过期原子对象：

1. 创建缓存存储密钥与过期时间：

   CacheConfiguration<String, Long> expiryCacheCfg = new CacheConfiguration<>("rl-expiry-cache");
   IgniteCache<String, Long> expiryCache = ignite.getOrCreateCache(expiryCacheCfg);
   

2. 创建AtomicLong时记录过期时间：

   String rlKey = "user-123";
   IgniteAtomicLong counter = ignite.atomicLong(rlKey, 0L, true);
   // 设置1分钟后过期
   expiryCache.put(rlKey, System.currentTimeMillis() + 60000);
   

3. 用Ignite定时任务定期清理：

   ignite.scheduler().schedule(() -> {
       long now = System.currentTimeMillis();
       // 遍历过期条目并清理原子对象
       for (Map.Entry<String, Long> entry : expiryCache.entrySet()) {
           if (entry.getValue() < now) {
               ignite.destroyAtomicLong(entry.getKey());
               expiryCache.remove(entry.getKey());
           }
       }
   }, new Date(), 60000); // 每分钟执行一次清理
   

注意：这种方案需要处理分布式环境下的并发清理问题，避免重复操作或遗漏。

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