JDK动态代理之WeakCache缓存的实现机制

上一篇我们分析了proxy类的内部是怎样产生代理类的，我们看到了proxy内部用到了缓存机制，如果根据提供的类加载器和接口数组能在缓存中找到代理类就直接返回该代理类，否则会调用proxyclassfactory工厂去生成代理类。这里用到的缓存是二级缓存，它的一级缓存key是根据类加载器生成的，二级缓存key是根据接口数组生成的。具体的内部机制我们直接贴上代码详细解释。

//reference引用队列
private final referencequeue<k> refqueue = new referencequeue<>();
//缓存的底层实现, key为一级缓存, value为二级缓存。 为了支持null, map的key类型设置为object
private final concurrentmap<object, concurrentmap<object, supplier<v>>> 
                            map = new concurrenthashmap<>();
//reversemap记录了所有代理类生成器是否可用, 这是为了实现缓存的过期机制
private final concurrentmap<supplier<v>, boolean> reversemap = new concurrenthashmap<>();
//生成二级缓存key的工厂, 这里传入的是keyfactory
private final bifunction<k, p, ?> subkeyfactory;
//生成二级缓存value的工厂, 这里传入的是proxyclassfactory
private final bifunction<k, p, v> valuefactory;

//构造器, 传入生成二级缓存key的工厂和生成二级缓存value的工厂
public weakcache(bifunction<k, p, ?> subkeyfactory, bifunction<k, p, v> valuefactory) {
  this.subkeyfactory = objects.requirenonnull(subkeyfactory);
  this.valuefactory = objects.requirenonnull(valuefactory);
}

首先我们看一下weakcache的成员变量和构造器，weakcache缓存的内部实现是通过concurrentmap来完成的，成员变量map就是二级缓存的底层实现，reversemap是为了实现缓存的过期机制，subkeyfactory是二级缓存key的生成工厂，通过构造器传入，这里传入的值是proxy类的keyfactory，valuefactory是二级缓存value的生成工厂，通过构造器传入，这里传入的是proxy类的proxyclassfactory。接下来我们看一下weakcache的get方法。

public v get(k key, p parameter) {
  //这里要求实现的接口不能为空
  objects.requirenonnull(parameter);
  //清除过期的缓存
  expungestaleentries();
  //将classloader包装成cachekey, 作为一级缓存的key
  object cachekey = cachekey.valueof(key, refqueue);
  //获取得到二级缓存
  concurrentmap<object, supplier<v>> valuesmap = map.get(cachekey);
  //如果根据classloader没有获取到对应的值
  if (valuesmap == null) {
    //以cas方式放入, 如果不存在则放入，否则返回原先的值
    concurrentmap<object, supplier<v>> oldvaluesmap = map.putifabsent(cachekey, 
        valuesmap = new concurrenthashmap<>());
    //如果oldvaluesmap有值, 说明放入失败
    if (oldvaluesmap != null) {
      valuesmap = oldvaluesmap;
    }
  }
  //根据代理类实现的接口数组来生成二级缓存key, 分为key0, key1, key2, keyx
  object subkey = objects.requirenonnull(subkeyfactory.apply(key, parameter));
  //这里通过subkey获取到二级缓存的值
  supplier<v> supplier = valuesmap.get(subkey);
  factory factory = null;
  //这个循环提供了轮询机制, 如果条件为假就继续重试直到条件为真为止
  while (true) {
    //如果通过subkey取出来的值不为空
    if (supplier != null) {
      //在这里supplier可能是一个factory也可能会是一个cachevalue
      //在这里不作判断, 而是在supplier实现类的get方法里面进行验证
      v value = supplier.get();
      if (value != null) {
        return value;
      }
    }
    if (factory == null) {
      //新建一个factory实例作为subkey对应的值
      factory = new factory(key, parameter, subkey, valuesmap);
    }
    if (supplier == null) {
      //到这里表明subkey没有对应的值, 就将factory作为subkey的值放入
      supplier = valuesmap.putifabsent(subkey, factory);
      if (supplier == null) {
        //到这里表明成功将factory放入缓存
        supplier = factory;
      }
      //否则, 可能期间有其他线程修改了值, 那么就不再继续给subkey赋值, 而是取出来直接用
    } else {
      //期间可能其他线程修改了值, 那么就将原先的值替换
      if (valuesmap.replace(subkey, supplier, factory)) {
        //成功将factory替换成新的值
        supplier = factory;
      } else {
        //替换失败, 继续使用原先的值
        supplier = valuesmap.get(subkey);
      }
    }
  }
}

weakcache的get方法并没有用锁进行同步，那它是怎样实现线程安全的呢？因为它的所有会进行修改的成员变量都使用了concurrentmap，这个类是线程安全的。因此它将自身的线程安全委托给了concurrentmap， get方法尽可能的将同步代码块缩小，这样可以有效提高weakcache的性能。我们看到classloader作为了一级缓存的key，这样可以首先根据classloader筛选一遍，因为不同classloader加载的类是不同的。然后它用接口数组来生成二级缓存的key，这里它进行了一些优化，因为大部分类都是实现了一个或两个接口，所以二级缓存key分为key0，key1，key2，keyx。key0到key2分别表示实现了0到2个接口，keyx表示实现了3个或以上的接口，事实上大部分都只会用到key1和key2。这些key的生成工厂是在proxy类中，通过weakcache的构造器将key工厂传入。这里的二级缓存的值是一个factory实例，最终代理类的值是通过factory这个工厂来获得的。

private final class factory implements supplier<v> {
  //一级缓存key, 根据classloader生成
  private final k key;
  //代理类实现的接口数组
  private final p parameter;
  //二级缓存key, 根据接口数组生成
  private final object subkey;
  //二级缓存
  private final concurrentmap<object, supplier<v>> valuesmap;

  factory(k key, p parameter, object subkey,
      concurrentmap<object, supplier<v>> valuesmap) {
    this.key = key;
    this.parameter = parameter;
    this.subkey = subkey;
    this.valuesmap = valuesmap;
  }

  @override
  public synchronized v get() {
    //这里再一次去二级缓存里面获取supplier, 用来验证是否是factory本身
    supplier<v> supplier = valuesmap.get(subkey);
    if (supplier != this) {
      //在这里验证supplier是否是factory实例本身, 如果不则返回null让调用者继续轮询重试
      //期间supplier可能替换成了cachevalue, 或者由于生成代理类失败被从二级缓存中移除了
      return null;
    }
    v value = null;
    try {
      //委托valuefactory去生成代理类, 这里会通过传入的proxyclassfactory去生成代理类
      value = objects.requirenonnull(valuefactory.apply(key, parameter));
    } finally {
      //如果生成代理类失败, 就将这个二级缓存删除
      if (value == null) {
        valuesmap.remove(subkey, this);
      }
    }
    //只有value的值不为空才能到达这里
    assert value != null;
    //使用弱引用包装生成的代理类
    cachevalue<v> cachevalue = new cachevalue<>(value);
    //将包装后的cachevalue放入二级缓存中, 这个操作必须成功, 否则就报错
    if (valuesmap.replace(subkey, this, cachevalue)) {
      //将cachevalue成功放入二级缓存后, 再对它进行标记
      reversemap.put(cachevalue, boolean.true);
    } else {
      throw new assertionerror("should not reach here");
    }
    //最后返回没有被弱引用包装的代理类
    return value;
  }
}

我们再看看factory这个内部工厂类，可以看到它的get方法是使用synchronized关键字进行了同步。进行get方法后首先会去验证subkey对应的suppiler是否是工厂本身，如果不是就返回null，而weakcache的get方法会继续进行重试。如果确实是工厂本身，那么就会委托proxyclassfactory生成代理类，proxyclassfactory是在构造weakcache的时候传入的。所以这里解释了为什么最后会调用到proxy的proxyclassfactory这个内部工厂来生成代理类。生成代理类后使用弱引用进行包装并放入reversemap中，最后会返回原装的代理类。

至此已经为大家详细揭示了weakcache缓存的实现包括它的一级缓存和二级缓存实现的原理，以及二级缓存key生成的原理，还有最后它是怎样调用proxyclassfactory来生成代理类的。在下一篇中将会深入proxygenerator这个类，来看看具体的代理类的字节码生成过程。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。