java - 如何缓存特定时间的数据 Spring Boot Rest Template

Question

我正在尝试找到一种方法来在特定时间段内缓存某些数据。

我知道 @Cachable 注释，但是我没有找到任何方法可以在特定时间段后清除缓存。

@GetMapping("/{lang}.{format}")
@Timed
public ResponseEntity<Object> getLocalizedMessages(@PathVariable String lang,
                                                   @PathVariable String format,
                                                   @RequestParam("buildTimestamp") long buildTimestamp) throws InvalidArgumentException {

    Map<String, Object> messages = this.localeMessageService.getMessagesForLocale(lang);
    if (FORMAT_JSON.equals(format)) {
        String jsonMessages = new PropertiesToJsonConverter().convertFromValuesAsObjectMap(messages);
        return new ResponseEntity<>(jsonMessages, HttpStatus.OK);
    }
    return new ResponseEntity<>(messages, HttpStatus.OK);
}

这是我的休息方法，我需要根据unix时间缓存数据，时间戳作为参数传递，所以例如如果一个小时过去了，缓存应该失效。

Answer 1

Spring 缓存抽象不提供缓存存储。设置实际存储需要 CacheManager 配置。

这是一个使用 Guava 的实现示例，支持基于时间的驱逐:

添加 Guava 依赖

Maven:

<dependency>
    <groupId>com.google.guava</groupId>
    <artifactId>guava</artifactId>
    <version>27.0-jre</version>
</dependency>

Gradle :

 compile 'com.google.guava:guava:27.0-jre'

添加一个类来配置缓存

import com.google.common.cache.CacheBuilder;
import org.springframework.cache.Cache;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.cache.concurrent.ConcurrentMapCache;
import org.springframework.cache.concurrent.ConcurrentMapCacheManager;
import org.springframework.cache.interceptor.KeyGenerator;
import org.springframework.cache.interceptor.SimpleKeyGenerator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.concurrent.TimeUnit;

@Configuration
@EnableCaching
public class CacheConfig extends CachingConfigurerSupport {
    @Bean
    public CacheManager cacheManager() {
        return new ConcurrentMapCacheManager() {
            @Override
            protected Cache createConcurrentMapCache(final String name) {
                return new ConcurrentMapCache(name, CacheBuilder.newBuilder()
                        // You can customize here the eviction time
                        .expireAfterWrite(1, TimeUnit.HOURS)
                        .build()
                        .asMap(),
                        false);
            }
        };
    }

    @Bean
    public KeyGenerator keyGenerator() {
        return new SimpleKeyGenerator();
    }
}

最后，将@Cacheable("CacheName")注释添加到您想要缓存结果的方法