10

使用 Spring 的缓存抽象，如何让缓存异步刷新条目，同时仍返回旧条目？

我正在尝试使用 Spring 的缓存抽象来创建一个缓存系统，在相对较短的“软”超时之后，缓存条目可以刷新。然后，当它们被查询时，返回缓存的值，并启动异步更新操作来刷新条目。我也会

Guava 的缓存构建器允许我指定缓存中的条目应在一定时间后刷新。然后可以用异步实现覆盖缓存加载器的 reload() 方法，允许返回陈旧的缓存值，直到检索到新的缓存值。但是，spring 缓存似乎不使用底层 Guava 缓存的 CacheLoader

是否可以使用 Spring 的缓存抽象来进行这种异步缓存刷新？

编辑澄清：使用 Guava 的 CacheBuilder，我可以使用 refreshAfterWrite() 来获得我想要的行为。例如来自Guava Caches Explained：

LoadingCache<Key, Graph> graphs = CacheBuilder.newBuilder()
   .maximumSize(1000)
   .refreshAfterWrite(1, TimeUnit.MINUTES)
   .build(
       new CacheLoader<Key, Graph>() {
         public Graph load(Key key) { // no checked exception
           return getGraphFromDatabase(key);
         }

         public ListenableFuture<Graph> reload(final Key key, Graph prevGraph) {
           if (neverNeedsRefresh(key)) {
             return Futures.immediateFuture(prevGraph);
           } else {
             // asynchronous!
             ListenableFutureTask<Graph> task = ListenableFutureTask.create(new Callable<Graph>() {
               public Graph call() {
                 return getGraphFromDatabase(key);
               }
             });
             executor.execute(task);
             return task;
           }
         }
       });

但是，我看不到使用 Spring 的 @Cacheable 抽象来获取 refreshAfterWrite() 行为的方法。

4

2 回答 2

6

也许您可以尝试以下方法：

  1. 配置缓存：

    @Configuration
@EnableCaching
public class CacheConfig {

    @Bean
    public CacheManager cacheManager() {
        SimpleCacheManager simpleCacheManager = new SimpleCacheManager();

        GuavaCache chache= new GuavaCache("cacheKey", CacheBuilder.newBuilder().build());

        simpleCacheManager.setCaches(Arrays.asList(cacheKey));

        return simpleCacheManager;
    }
}

  2. 读取要缓存的值，假设是一个字符串（我以 a@Service为例）

    @Service
public class MyService{

    @Cacheable("cacheKey")
    public String getStringCache() {
        return doSomething();
    }

    @CachePut("cacheKey")
    public String refreshStringCache() {
        return doSomething();
    }
    ...
}

    两者都getStringCache()调用refreshStringCache()相同的函数以检索要缓存的值。仅controller调用。_ getStringCache()

  3. 使用计划任务文档刷新缓存

    @Configuration
@EnableScheduling
public class ScheduledTasks {

    @Autowired
    private MyService myService;

    @Scheduled(fixedDelay = 30000)
    public void IaaSStatusRefresh(){
        myService.refreshStringCache();
    }
}

    这样，计划任务会强制每 30 秒刷新一次缓存。任何访问过的人getStringCache()都会在缓存中找到更新的数据。

于 2015-06-25T10:39:52.610 回答
0

在一个使用 Spring Cache 抽象的项目中，我做了以下事情来达到相同的目标，但仍然设法隐藏缓存的实际供应商，即它应该与 Spring 支持的任何缓存提供程序一起工作（目前是 Guava，但应用程序可以切换到如果需要，集群缓存提供程序）。

核心概念是“捕获”缓存使用模式，并可能通过调度程序在另一个后台线程中“重放”这些操作。

如果我想保持代码非侵入性，它需要对“捕获”部分使用反射和一些 AOP 编程，幸运的是，对于 Spring，Spring AOP 提供了我需要的所有工具集。

于 2016-12-19T07:44:55.800 回答