我正在使用Spring Boot，并且使用Ehcache进行缓存。目前为止一切正常。但是现在我需要重新加载/刷新，那么我该怎么做才能使我的应用程序没有任何停机时间。
我已经尝试了Spring Ehcache中的许多方法，但它们都没有奏效。或者我必须编写一个调度程序来重新加载数据。
@Override
@Cacheable(value="partTypeCache", key="#partKey")
public List<PartType> loadPartType(String partKey) throws CustomException {
return productIdentityDao.loadPartType();
}
显然，关于您的问题的所有评论都是正确的。您应该使用CacheEvict。我在这里找到了解决方案：https://www.baeldung.com/spring-boot-evict-cache，看起来像这样：
你所需要做的就是创建一个名为CacheService的类，并创建一个方法来清除您拥有的所有缓存对象。然后，您将该方法注释为@Scheduled，并设置您的时间间隔。
@Service
public class CacheService {
@Autowired
CacheManager cacheManager;
public void evictAllCaches() {
cacheManager.getCacheNames().stream()
.forEach(cacheName -> cacheManager.getCache(cacheName).clear());
}
@Scheduled(fixedRate = 6000)
public void evictAllcachesAtIntervals() {
evictAllCaches();
}
}
Collection也有一个forEach方法，因此可以通过删除.stream()调用来简化解决方案：cacheManager.getCacheNames().forEach。 - M. Justin很多人建议使用@CacheEvict选项是正确的。此外，为了确保你的缓存（近似）始终具有最新的数据加载，即使数据在数据库中更新超出了运行应用程序的范围，你需要周期性地重新加载整个数据集，间隔时间要与应用程序的SLAs匹配。在上面提供的解决方案中，添加重新加载所有数据的逻辑如下：
@Service
public class CacheService {
@Autowired
CacheManager cacheManager;
public void refreshAllCaches() {
cacheManager.getCacheNames().stream()
.forEach(cacheName -> cacheManager.getCache(cacheName).clear());
// reload whole dataset here, dummy example here:
dataRepository.findAll().forEach(a -> cacheManager.getCache("cache-name")).put(a.getKey(), a));
}
@Scheduled(fixedRate = 6000)
public void refreshAllcachesAtIntervals() {
refreshAllCaches();
}
}
尝试以下操作：
@Caching(evict={@CacheEvict(value="partTypeCache", key="#partKey")})
public boolean deletePartType(String partKey) {
//when this method is invoked the cache is evicted for the requested key
}
@Autowired
CacheManager cacheManager;
public void evictAllCaches() {
cacheManager.getCacheNames().stream()
.forEach(cacheName -> cacheManager.getCache(cacheName).clear());
}
@Scheduled(cron = "@weekly")
public void evictAllcachesAtIntervals() {
evictAllCaches();
}
}
需求是在X时间间隔内刷新1个缓存，Y时间间隔内刷新另一个缓存。如果我们只在一个类中编写以下代码，则缓存不会重新加载。
public class XXXSchedulers {
@Autowired
private XXXUtil util;
@Scheduled(fixedDelay = 10 * 60 * 1000) // Running after 10 minutes
public void clearSpecificABCCache() {
util.clearSpecificABCCache();
util.getABC();//Again gets value in the cache
}
@Scheduled(cron = "0 0 2 * * ?") //Running Everyday at 2 AM public void
public void clearSpecificXYZCache() {
util.clearSpecificABCCache();
util.getXYZ();
}
}
@Component
public class XXXUtil {
@Autowired
private CacheManager cacheManager;
@Autowired
private XXXService service;
@Cacheable("abc")
public ABC getABC() {
ABC abc = service.getABC();
}
public void clearSpecificABCCache() {
cacheManager.getCache("abc").clear();
}
@Cacheable("xyz")
public XYZ getXYZCache() {
XYZ xyz = service.getXYZCache();
}
public void clearSpecificXYZCache() {
cacheManager.getCache("xyz").clear();
}
}
你知道你要特别更新哪些partKeys吗？如果不知道，你必须从缓存本身找到这些keys。你可以使用@CachePut来更新缓存值而不会停机。我的建议性能可能不是很好，但它应该正好符合你的需求。
对于EhCache：
public void renewCache() {
net.sf.ehcache.EhCache cache = (net.sf.ehcache.EhCache) org.springframework.cache.CacheManager.getCache("partTypeCache").getNativeCache();
for (Object key : cache.getKeys()) {
updatePartTypeCache((String) key)
}
}
@CachePut(value="partTypeCache", key="#partKey")
public List<PartType> updatePartTypeCache(String partKey) throws CustomException {
return productIdentityDao.loadPartType();
}