關于guava cache的
如果運營人員吧優惠券模版一個在數據庫中設置為失效了,那么他在緩存中也是設置一下失效,這時候緩存只是去除了一個jvm上的緩存吧,如果是多臺部署的情況,其他的機器jvm依然沒有失效啊,這就數據不一致了
代碼如下:CouponTemplateCacheHelper.java
com.imooc.engineering.project.coupon.cachecom.google.common.cache.LoadingCachecom.google.common.cache.CacheBuildercom.google.common.cache.CacheLoadercom.imooc.engineering.project.coupon.entity.CouponTemplatelombok.RequiredArgsConstructorlombok.extern.slf4j.Slf4jorg.springframework.stereotype.Servicejava.util.Listjava.util.Mapjava.util.Optionaljava.util.concurrent.ExecutionExceptionjava.util.concurrent.TimeUnit@Slf4j
@Service
@RequiredArgsConstructor
CouponTemplateCacheHelper?{
????LoadingCache<LongOptional<CouponTemplate>>?couponTemplateLoadingCache
????????????=?CacheBuilder.newBuilder()
????????????.initialCapacity()
????????????.maximumSize()
????????????.concurrencyLevel(Runtime.getRuntime().availableProcessors())
????????????.expireAfterWrite(TimeUnit.SECONDS)
????????????.build(CacheLoader<>()?{
????????????????@Override
????????????????Optional<CouponTemplate>?load(Long?templateId)?Exception?{
????????????????????Optional.of(CouponTemplate())}
????????????})CouponTemplate?getCouponTemplateByTemplateId(Long?templateId)?{
????????{
????????????couponTemplateLoadingCache.get(templateId).orElse()}?(ExecutionException?ex)?{
????????????log.error()}
????????}
????Map<LongOptional<CouponTemplate>>?getCouponTemplateByTemplateIds(
????????????List<Long>?templateIds)?{
????????{
????????????couponTemplateLoadingCache.getAll(templateIds)}?(ExecutionException?ex)?{
????????????log.error()}
????????}
????putCouponTemplateToCache(CouponTemplate?template)?{
????????couponTemplateLoadingCache.put(template.getTemplateId()Optional.of(template))}
????putCouponTemplateToCache(Map<LongOptional<CouponTemplate>>?templateMap)?{
????????couponTemplateLoadingCache.putAll(templateMap)}
????cleanCouponTemplateCouponByTemplateId(Long?templateId)?{
????????couponTemplateLoadingCache.invalidate(templateId)}
}
2024-07-10
張老師:.expireAfterWrite(600,?TimeUnit.SECONDS)
這個意思是不是無論多少太機器部署,到了600秒后都會去數據庫里面重新查詢啊?所有的機器的jvm必須在600秒后才能保持和數據庫一致???