首页编程java编程java为什么设置缓存,java google 的内存缓存为什么总调用cacheloader

java为什么设置缓存,java google 的内存缓存为什么总调用cacheloader

编程之家2023-10-1384次浏览

大家好,如果您还对java为什么设置缓存不太了解,没有关系,今天就由本站为大家分享java为什么设置缓存的知识,包括java google 的内存缓存为什么总调用cacheloader的问题都会给大家分析到,还望可以解决大家的问题,下面我们就开始吧!

java为什么设置缓存,java google 的内存缓存为什么总调用cacheloader

java google 的内存缓存为什么总调用cacheloader

首先,看一下使用范例:

Java代码

LoadingCache<Key,Graph> graphs=CacheBuilder.newBuilder()

java为什么设置缓存,java google 的内存缓存为什么总调用cacheloader

.maximumSize(1000)

.expireAfterWrite(10,TimeUnit.MINUTES)

.removalListener(MY_LISTENER)

java为什么设置缓存,java google 的内存缓存为什么总调用cacheloader

.build(

newCacheLoader<Key,Graph>(){

publicGraph load(Key key)throwsAnyException{

return createExpensiveGraph(key);

}

});

适用性

缓存在很多情况下都是非常有用的。比如,我们需要多次根据给定的输入获取值,而且该值计算或者获取的开销是非常昂贵的。

缓存和ConcurrentMap是非常相像的,但是它们也不完全一样。最根本的区别就是,ConcurrentMap会持有所有添加的对象,直到被显示的移除。而缓存为了限制其内存的使用,通常都会配置成可以自动的将对象移除。在某些情况下即使不自动移除对象也是非常有用的,如LoadingCache它会自动加载缓存对象。

一般,Guava缓存适用于以下几种情况:

你愿意花费一些内存来换取性能提升;

你预测到某些键会多次进行查询;

你的缓存数据不超过内存(Guava缓存是单个应用中的本地缓存。它不会将数据存储到文件中,或者外部服务器。如果不适合你,可以考虑一下 Memcached)。

如果你的需要符合上面所说的每一条,那么选择Guava缓存绝对没错。

使用CacheBuilder的构建模式可以获取一个Cache,如上面的范例所示。但是如何进行定制才是比较有趣的。

注意:如果你不需要缓存的这些特性,那么使用ConcurrentHashMap会有更好的内存效率,但是如果想基于旧有的ConcurrentMap复制实现Cache的一些特性,那么可能是非常困难或者根本不可能。

加载

对于缓存首先需要明确的是:有没有一个方法可以通过给定的键来计算/加载相应的值?如果有,那么可以使用CacheLoader。如果没有这样的方法,或者你想复写缓存的加载方式,但你仍想保留“get-if-absent-compute”语义,你可以在调用get方法时传入一个Callable实例,来达到目的。缓存的对象可以通过Cache.put直接插入,但是自动加载是首选,因为自动加载可以更加容易的判断所有缓存信息的一致性。

From a CacheLoader

LoadingCache缓存是通过一个CacheLoader来构建缓存。创建一个CacheLoader仅需要实现V load(K key) throws Exception方法即可。下面的范例就是如何创建一个LoadingCache:

Java代码

LoadingCache<Key,Graph> graphs=CacheBuilder.newBuilder()

.maximumSize(1000)

.build(

newCacheLoader<Key,Graph>(){

publicGraph load(Key key)throwsAnyException{

return createExpensiveGraph(key);

}

});

...

try{

return graphs.get(key);

}catch(ExecutionException e){

thrownewOtherException(e.getCause());

}

通过方法get(K)可以对LoadingCache进行查询。该方法要不返回已缓存的值,要不通过CacheLoader来自动加载相应的值到缓存中。这里需要注意的是:CacheLoader可能会抛出Exception,LoaderCache.get(K)则可能会抛出ExecutionException。假如你定义的CacheLoader没有声明检查型异常,那么可以通过调用getUnchecked(K)来获取缓存值;但是一旦当CacheLoader中声明了检查型异常,则不可以调用getUnchecked。

Java代码

LoadingCache<Key,Graph> graphs=CacheBuilder.newBuilder()

.expireAfterAccess(10,TimeUnit.MINUTES)

.build(

newCacheLoader<Key,Graph>(){

publicGraph load(Key key){// no checked exception

return createExpensiveGraph(key);

}

});

...

return graphs.getUnchecked(key);

批量查询可以使用getAll(Iterable<? extends K>)方法。缺省,getAll方法将循环每一个键调用CacheLoader.load方法获取缓存值。当缓存对象的批量获取比单独获取更有效时,可以通过复写CacheLoader.loadAll方法实现缓存对象的加载。此时当调用getAll(Iterable)方法时性能也会提升。

需要注意的是CacheLoader.loadAll的实现可以为没有明确要求的键加载缓存值。比如,当为某组中的一些键进行计算时,loadAll方法则可能会同时加载组中其余键的值。

From a Callable

所有Guava缓存,不论是否会自动加载,都支持get(K, Callable(V))方法。当给定键的缓存值已存在时则直接返回,否则通过指定的Callable方法进行计算并将值存放到缓存中。直到加载完成时,相应的缓存才会被更改。该方法简单实现了"if cached, return; otherwise create, cache and return"语义。

Java代码

Cache<Key,Value> cache=CacheBuilder.newBuilder()

.maximumSize(1000)

.build();// look Ma, no CacheLoader

...

try{

// If the key wasn't in the"easy to compute" group, we need to

// do things the hard way.

cache.get(key,newCallable<Value>(){

@Override

publicValue call()throwsAnyException{

return doThingsTheHardWay(key);

}

});

}catch(ExecutionException e){

thrownewOtherException(e.getCause());

}

直接插入

使用cache.put(key, value)方法可以将值直接插入到缓存中,但这将会覆盖缓存中已存在的值。通过使用Cache.asMap()所导出的ConcurrentMap对象中的方法也可以对缓存进行修改。但是,请注意asMap中的任何方法都不能自动的将数据加载到缓存中。也就是说,asMap中的各方法是在缓存自动加载范围之外来运作。所以,当你使用CacheLoader或Callable来加载缓存时,应该优先使用Cache.get(K, Callable<V>),而不是Cache.asMap().putIfAbsent。

缓存回收

残酷的现实是我们可以肯定的说我们没有足够的内存来缓存一切。你必须来决定:什么时候缓存值不再值得保留?Guava提供了三种基本的缓存回收策略:基于容量回收策略,基于时间回收策略,基于引用回收策略。

基于容量回收策略

使用CacheBuilder.maximumSize(long)可以设置缓存的最大容量。缓存将会尝试回收最近没有使用,或者没有经常使用的缓存项。警告:缓存可能会在容量达到限制之前执行回收,通常是在缓存大小逼近限制大小时。

另外,如果不同的缓存项有不同的“权重”,如,缓存项有不同的内存占用,此时你需要使用CacheBuilder.weigher(Weigher)指定一个权重计算函数,并使用CacheBuilder.maxmumWeight(long)设定总权重。和maximumSize同样需要注意的是缓存也是在逼近总权重的时候进行回收处理。此外,缓存项的权重是在创建时进行计算,此后不再改变。

Java代码

LoadingCache<Key,Graph> graphs=CacheBuilder.newBuilder()

.maximumWeight(100000)

.weigher(

newWeigher<Key,Graph>(){

publicint weigh(Key k,Graph g){

return g.vertices().size();

}

})

.build(

newCacheLoader<Key,Graph>(){

publicGraph load(Key key){// no checked exception

return createExpensiveGraph(key);

}

});

基于时间回收策略

CacheBuilder为基于时间的回收提供了两种方式:

expireAfterAccess(long, TimeUnit)当缓存项在指定的时间段内没有被读或写就会被回收。这种回收策略类似于基于容量回收策略;

expireAfterWrite(long, TimeUnit)当缓存项在指定的时间段内没有更新就会被回收。如果我们认为缓存数据在一段时间后数据不再可用,那么可以使用该种策略。

就如下面的讨论,定时过期回收会在写的过程中周期执行,偶尔也会读的过程中执行。

测试定时回收

测试定时回收其实不需要那么痛苦的,我们不必非得花费2秒来测试一个2秒的过期。在构建缓存时使用Ticker接口,并通过CacheBuilder.ticker(Ticker)方法指定时间源,这样我们就不用傻乎乎等系统时钟慢慢的走了。

基于引用回收策略

通过键或缓存值的弱引用(weak references),或者缓存值的软引用(soft references),Guava可以将缓存设置为允许垃圾回收。

CacheBuilder.weakKeys()使用弱引用存储键。当没有(强或软)引用到该键时,相应的缓存项将可以被垃圾回收。由于垃圾回收是依赖==进行判断,因此这样会导致整个缓存也会使用==来比较键的相等性,而不是使用equals();

CacheBuilder.weakValues()使用弱引用存储缓存值。当没有(强或软)引用到该缓存项时,将可以被垃圾回收。由于垃圾回收是依赖==进行判断,因此这样会导致整个缓存也会使用==来比较缓存值的相等性,而不是使用equals();

CacheBuilder.softValues()使用软引用存储缓存值。当响应需要时,软引用才会被垃圾回收通过最少使用原则回收掉。由于使用软引用造成性能上的影响,我们强烈建议使用可被预言的maximum cache size的策略来代替。同样使用softValues()缓存值的比较也是使用==,而不是equals()。

显示移除

在任何时候,你都可以可以通过下面的方法显式将无效的缓存移除,而不是被动等待被回收:

使用Cache.invalidate(key)单个移除;

使用Cache.invalidteAll(keys)批量移除;

使用Cache.invalidateAll()移除全部。

Java本地缓存有哪些

下面给你介绍几个常见的java缓存框架:

1、OSCache

OSCache是个一个广泛采用的高性能的J2EE缓存框架,OSCache能用于任何Java应用程序的普通的缓存解决方案。

OSCache有以下特点:

缓存任何对象,你可以不受限制的缓存部分jsp页面或HTTP请求,任何java对象都可以缓存。

拥有全面的API--OSCache API给你全面的程序来控制所有的OSCache特性。

永久缓存--缓存能随意的写入硬盘,因此允许昂贵的创建(expensive-to-create)数据来保持缓存,甚至能让应用重启。

支持集群--集群缓存数据能被单个的进行参数配置,不需要修改代码。

缓存记录的过期--你可以有最大限度的控制缓存对象的过期,包括可插入式的刷新策略(如果默认性能不需要时)。

2、Java Caching System

JSC(Java Caching System)是一个用分布式的缓存系统,是基于服务器的java应用程序。它是通过提供管理各种动态缓存数据来加速动态web应用。

JCS和其他缓存系统一样,也是一个用于高速读取,低速写入的应用程序。

动态内容和报表系统能够获得更好的性能。

如果一个网站,有重复的网站结构,使用间歇性更新方式的数据库(而不是连续不断的更新数据库),被重复搜索出相同结果的,就能够通过执行缓存方式改进其性能和伸缩性。

3、EHCache

EHCache是一个纯java的在进程中的缓存,它具有以下特性:快速,简单,为Hibernate2.1充当可插入的缓存,最小的依赖性,全面的文档和测试。

4、JCache

JCache是个开源程序,正在努力成为JSR-107开源规范,JSR-107规范已经很多年没改变了。这个版本仍然是构建在最初的功能定义上。

5、ShiftOne

ShiftOne Java Object Cache是一个执行一系列严格的对象缓存策略的Java lib,就像一个轻量级的配置缓存工作状态的框架。

6、SwarmCache

SwarmCache是一个简单且有效的分布式缓存,它使用IP multicast与同一个局域网的其他主机进行通讯,是特别为集群和数据驱动web应用程序而设计的。SwarmCache能够让典型的读操作大大超过写操作的这类应用提供更好的性能支持。

SwarmCache使用JavaGroups来管理从属关系和分布式缓存的通讯。

java中输入流去读取文件时为什么要创建一个缓存数组

IO流自定义字节流的缓冲区:

思路:BufferedInputStream类中read()方法的工作原理

1)先一个一个从字节流中读取字节,读取一定量(自定义)之后,存储在一个字节数组(缓冲区)(FileInputStream.read(byte[] b)),并获得存储数量(read方法的返回值)。

2)一个一个字节返回,返回一个,存储数量减1,然后指针往后移一位,准备取下一个。

3)如果存储数量为0,代表当前数组中所有数据已经全部取完,此时再来一次读取(read(byte[] b)),再获得此次存储数量。

4)如果存储数量(即read方法返回-1),代表读到文件末尾,返回-1。

因此,需要用到以下几个变量:

读取的字节数量,指向数组中准备取哪一个的指针,将要返回的字节变量。

END,本文到此结束,如果可以帮助到大家,还望关注本站哦!

java中什么是proxy(Java设计模式之Proxy模式)千言万语(千言万语道不尽,唯有感恩挂心头的意思)