机制基于Redis实现Java的过期机制（redisjava过期）

  现代系统越来越依赖对数据的可用性和一致性，这通常需要能够在固定的时间点产生元素——过时机制。为了实现这个功能，多数系统采用Redis来实现Java的过时机制，这样可以减少开发周期，实现特定服务的自动操作。本文将介绍使用Redis实现Java的过期机制的整体实现思路和源码实现。

  为了实现Java的过时机制，首先需要使用Redis库来存储键与过期时间的映射，以便能够定位过期元素。然后，可以创建monitors线程，它将维护一个可以判断哪些Redis键过期的池子，并在发现过期键时调用相应的过期动作。

  下面，我们来看下源码实现，需要注意的是，需要调用Redis的JedisAPI（可以在Maven中引入此依赖）。

//初始化Jedis
Jedis jedis = new Jedis("localhost",6379);

//定义过期的key的类，key的过期时间
public class ExpireKey implements Comparable {
  private String key;
  private long expireTime;
  public ExpireKey(String key, long expireTime) {
    this.key = key;
    this.expireTime = expireTime;
  }
 
  @Override
  public int compareTo(ExpireKey o) {
     return Long.compare(expireTime, o.expireTime);
  }

  然后，定义过期池初始化的函数：

// monitor线程池
private PriorityBlockingQueue expiryQueue;
// 初识化函数
public void init(){
 // 初始化过期池
 expiryQueue = new PriorityBlockingQueue();
 // 启动monitor线程
 Executors.newSingleThreadExecutor().execute(new ExpiredMonitor());
}

  接下来实现监控过期键的ExpiredMonitor类，这个类实现了对Redis中的键过期的监控，当某个键过期时就会调用相应的过期处理程序将键从Redis中删除：

public class ExpiredMonitor implements Runnable {
 
  /**
   * 该线程每次先从过期池中取出到期但是尚未删除的Key
   * 如果存在未到期过期Key，就从过期池中移除
   */
  @Override
  public void run() {
    
     while (true) {
        ExpireKey expireKey = null;
        try {
            expireKey = expiryQueue.peek();
            if (expireKey != null && System.currentTimeMillis() > expireKey.getExpireTime()) {
             // 继续从池子中取出Key
                expireKey = expiryQueue.take();
            } else {
                // 先等待指定的ms，看是否有Key到期
                expireKey = expiryQueue.poll(100, TimeUnit.MILLISECONDS);
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
            break;
        }
 
        // 当经过检查后，如果Key过期，就把它从Redis中删掉
        if (expireKey != null) {
            jedis.del(expireKey.getKey());
        }
     }
   }
 }

  最后，通过引入两个函数setExpiryKey()、removeExpiryKey()来实现对key的饮加和删除，两个函数的实现：

public void setExpiryKey(String key, long expireTime) {
   ExpireKey expireKey = new ExpireKey(key, expireTime);
   expiryQueue.put(expireKey);
}

public void removeExpiryKey(String key) {
  Iterator iterator = expiryQueue.iterator();
  while (iterator.hasNext()) {
      ExpireKey expireKey = iterator.next();
      if (key.equals(expireKey.getKey())) {
          expiryQueue.remove(expireKey);
      }
  }
}

  本文介绍了使用Redis实现Java的过期机制，讨论了整体的实现思路和源码实现，这种机制可以节省开发周期，实现特定服务的自动操作。