使用Spring缓存抽象的异步缓存更新

Question

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

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

Guava的缓存生成器允许我指定缓存中的条目应该在一定时间后刷新。然后可以用异步实现覆盖缓存加载器的reload（）方法，允许返回陈旧的缓存值，直到检索到新值。但是，Spring缓存似乎没有使用底层Guava缓存的CacheLoader

可以使用Spring的缓存抽象实现这种异步缓存刷新吗？

编辑以澄清：使用Guava的CacheBuilder，我可以使用刷新后写（）来获得我想要的行为。例如从Guava缓存解释：

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（）行为的方法。

Answer 1

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

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

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

Answer 2

也许你可以尝试以下方式：

>

配置缓存：

@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;
    }
}

假设一个字符串，读取要缓存的值（我使用服务作为示例）

@Service
public class MyService{

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

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

getStringCache（）和刷新StringCache（）都调用相同的函数以检索要缓存的值。控制器仅调用getStringCache（）。

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

@Configuration
@EnableScheduling
public class ScheduledTasks {

    @Autowired
    private MyService myService;

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

通过这种方式，计划任务强制每30秒刷新一次缓存。任何访问getStringCache（）的人都会在缓存中找到更新的数据。