Java Caching JSR107介绍（四）

忘是亡心i 2022-08-25 08:38 74阅读 0赞

# 集成 #

javax.cache.integration包中包含集成外部资源的类。

## 缓存数据加载 ##

Cache的loadAll方法用于从外部资源中加载数据。定义如下。

void loadAll(Set<? extends K> keys,boolean replaceExistingValues,

CompletionListenercompletionListener);

对于此方法中使用的CacheLoader必须在缓存创建时已经在配置中设置。缓存使用此方法并不需要被设置为read-through缓存模式。

数据加载可能需要大量的时间，基于这个原因，可以通过CompletionListener其中在完成或异常时收到通知。它的定义如下：

public interface CompletionListener \{

/\*\*

\* 通知应用程序操作成功完成。

\*/

void onCompletion();

/\*\*

\* 通知应用程序操作失败。

\*/

void onException(Exception e);

另外提供了阻塞式的CompletionListener实现CompletionListenerFuture，它实现了CompletionListener和Future两个接口。如果CompletionListener的onException(Exceptione)方法被调用，则异常被包装成ExecutionException，然后被Future的get()和get(long timeout, TimeUnit unit)方法抛出。

例子1：使用CompletionListenerFuture。

HashSet<String> keys = new HashSet<>();

keys.add("23432lkj");

keys.add("4fsdldkj");

//创建一个CompletionListenerFuture然后等待loadAll完成

CompletionListenerFuture future = new CompletionListenerFuture();

//加载keys集合的所有值，值存在时替换旧值

cache.loadAll(keys, true, future);

//等待值加载完成

try \{

future.get();

\}catch (InterruptedException e) \{

//future interrupted

e.printStackTrace();

\}catch (ExecutionException e) \{

//抛出的是被送到onException(Exception e)方法的异常

Throwable throwable = e.getCause();

*loadAll方法的用途是从外部资源预加载数据到缓存中，这对于应用程序来说如果数据在缓存外需要加载是很有必要的。另一种用途是缓存预热，如果数据在缓存中不存在，并不会导致应用程序错误，但它会影响性能或可伸缩性。*

## 缓存的Read-Through ##

除了缓存条目不存在时，需要调用CacheLoader加载数据外，read-through的缓存和非read-through缓存的行为是完全相同的。

缓存Read-Through是在配置时通过调用setReadThrough（boolean isReadThrough）设置到MutableConfiguration上来实现的，一个CacheLoader工厂也同时必须被定义。CacheLoader用于从外部资源加载缓存条目。

当缓存处于read-through模式下时每个方法调用的效果如下表所述：

<table> 
 <tbody> 
 <tr> 
 <td> 方法 </td> 
 <td> 是否调用Read-Through </td> 
 </tr> 
 <tr> 
 <td> boolean containsKey(K key) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> V get(K key) </td> 
 <td> 是 </td> 
 </tr> 
 <tr> 
 <td> Map&lt;K,V&gt; getAll(Collection&lt;? extends K&gt; keys) </td> 
 <td> 是，调用loadAll() </td> 
 </tr> 
 <tr> 
 <td> V getAndPut(K key, V value) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> V getAndRemove(K key) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> V getAndReplace(K key, V value) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> &lt;T&gt; T invoke(K key, EntryProcessor&lt;K, V, T&gt; entryProcessor, Object... arguments)entryProcessor); </td> 
 <td> 是，如果getValue() 被调用 </td> 
 </tr> 
 <tr> 
 <td> &lt;T&gt; Map&lt;K, T&gt; invokeAll(Set&lt;? extends K&gt; keys, EntryProcessor&lt;K, V, T&gt; entryProcessor, Object... arguments); </td> 
 <td> 是，如果getValue() 被调用 </td> 
 </tr> 
 <tr> 
 <td> Iterator&lt;Cache.Entry&lt;K, V&gt;&gt; iterator() </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> void loadAll(Set&lt;? extends K&gt; keys, boolean replaceExistingValues, CompletionListener completionListener) &nbsp; </td> 
 <td> 是，使用CacheLoader.loadAll() 方法，即时缓存不是read-through模式 </td> 
 </tr> 
 <tr> 
 <td> void put(K key, V value) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> void putAll(Map&lt;? extends K,? extends V&gt; map) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> boolean putIfAbsent(K key, V value) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> boolean remove(K key) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> boolean remove(K key, V oldValue) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> void removeAll() </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> void removeAll(Set&lt;? extends K&gt; keys) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> boolean replace(K key, V value) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> boolean replace(K key, V oldValue, V newValue) </td> 
 <td> 否 </td> 
 </tr> 
 </tbody> 
</table>

*缓存Read-through是懒加载缓存数据的一个有用的术语，这对于屏蔽来自外部的资源是如何加载到缓存中的细节非常有用。*

*当想预加载一些或所有缓存数据到缓存中时，使用loadAll方法。*

## 缓存的Write-Through ##

除了一些可变的方法将调用CacheWriter外，缓存write-through的行为和非write-through完全一样。

缓存Write-Through是在配置时通过调用setWriteThrough(booleanisWriteThrough)设置到MutableConfiguration上来实现的，一个CacheWriter工厂也同时必须被定义。CacheWriter用于写入缓存条目到外部资源和从外部资源删除缓存条目。

当缓存处于write-through模式下时每个方法调用的效果如下表所述：

<table> 
 <tbody> 
 <tr> 
 <td> 方法 </td> 
 <td> 是否调用Write-Through </td> 
 </tr> 
 <tr> 
 <td> boolean containsKey(K key) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> V get(K key) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> Map&lt;K,V&gt; getAll(Collection&lt;? extends K&gt; keys) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> V getAndPut(K key, V value) </td> 
 <td> 是 </td> 
 </tr> 
 <tr> 
 <td> V getAndRemove(K key) </td> 
 <td> 是 </td> 
 </tr> 
 <tr> 
 <td> V getAndReplace(K key, V value) </td> 
 <td> 是 </td> 
 </tr> 
 <tr> 
 <td> &lt;T&gt; T invoke(K key, EntryProcessor&lt;K, V, T&gt; entryProcessor, Object... arguments) </td> 
 <td> 是，如果setValue () 被调用 </td> 
 </tr> 
 <tr> 
 <td> &lt;T&gt; Map&lt;K, T&gt; invokeAll(Set&lt;? extends K&gt; keys, EntryProcessor&lt;K, V, T&gt; entryProcessor, Object... arguments); </td> 
 <td> 是，如果setValue () 被调用 </td> 
 </tr> 
 <tr> 
 <td> Iterator&lt;Cache.Entry&lt;K, V&gt;&gt; iterator() </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> void loadAll(Set&lt;? extends K&gt; keys, boolean replaceExistingValues, CompletionListener completionListener) </td> 
 <td> 否 </td> 
 </tr> 
 <tr> 
 <td> void put(K key, V value) </td> 
 <td> 是 </td> 
 </tr> 
 <tr> 
 <td> void putAll(Map&lt;? extends K,? extends V&gt; map) </td> 
 <td> 是，writeAll将被调用 </td> 
 </tr> 
 <tr> 
 <td> boolean putIfAbsent(K key, V value) </td> 
 <td> 是，如果该方法返回true </td> 
 </tr> 
 <tr> 
 <td> boolean remove(K key) </td> 
 <td> 是 </td> 
 </tr> 
 <tr> 
 <td> boolean remove(K key, V oldValue) </td> 
 <td> 是，如果该方法返回true </td> 
 </tr> 
 <tr> 
 <td> void removeAll() </td> 
 <td> 是 </td> 
 </tr> 
 <tr> 
 <td> void removeAll(Set&lt;? extends K&gt; keys) </td> 
 <td> 是 </td> 
 </tr> 
 <tr> 
 <td> boolean replace(K key, V value) </td> 
 <td> 是 </td> 
 </tr> 
 <tr> 
 <td> boolean replace(K key, V oldValue, V newValue) </td> 
 <td> 是，如果该方法返回true </td> 
 </tr> 
 </tbody> 
</table>

*缓存Write-through是懒更新缓存数据变化到外部资源的一个有用的惯用语，这对于屏蔽缓存如何写入数据到外部资源的细节非常有用。*