關(guān)于guava cache的
如果運(yùn)營人員吧優(yōu)惠券模版一個(gè)在數(shù)據(jù)庫中設(shè)置為失效了,那么他在緩存中也是設(shè)置一下失效,這時(shí)候緩存只是去除了一個(gè)jvm上的緩存吧,如果是多臺(tái)部署的情況,其他的機(jī)器jvm依然沒有失效啊,這就數(shù)據(jù)不一致了
代碼如下: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)
這個(gè)意思是不是無論多少太機(jī)器部署,到了600秒后都會(huì)去數(shù)據(jù)庫里面重新查詢啊?所有的機(jī)器的jvm必須在600秒后才能保持和數(shù)據(jù)庫一致?。?/p>