最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

一次排查@CacheEvict注解失效的經歷及解決

 更新時間:2021年12月24日 16:50:48   作者:小飯大人  
這篇文章主要介紹了一次排查@CacheEvict注解失效的經歷及解決方案,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教

排查@CacheEvict注解失效

我簡單看了一下《Spring實戰(zhàn)》中的demo,然后就應用到業(yè)務代碼中了,本以為如此簡單的事情,竟然在代碼提交后的1個周,被同事發(fā)現。selectByTaskId()方法查出來的數據總是過時的。

代碼如下:

@Cacheable("taskParamsCache")
List<TaskParams> selectByTaskId(Long taskId);
// ...
// ...
@CacheEvict("taskParamsCache")
int deleteByTaskId(Long taskId);

想要的效果是當程序調用selectByTaskId()方法時,把結果緩存下來,然后在調用deleteByTaskId()方法時,將緩存清空。

經過數據庫數據對比之后,把問題排查的方向定位在@CacheEvict注解失效了。

下面是我通過源碼跟蹤排查問題的過程

在deleteByTaskId()方法的調用出打斷點,跟進代碼到spring生成的代理層。

@Override
		@Nullable
		public Object intercept(Object proxy, Method method, Object[] args, MethodProxy methodProxy) throws Throwable {
			Object oldProxy = null;
			boolean setProxyContext = false;
			Object target = null;
			TargetSource targetSource = this.advised.getTargetSource();
			try {
				if (this.advised.exposeProxy) {
					// Make invocation available if necessary.
					oldProxy = AopContext.setCurrentProxy(proxy);
					setProxyContext = true;
				}
				// Get as late as possible to minimize the time we "own" the target, in case it comes from a pool...
				target = targetSource.getTarget();
				Class<?> targetClass = (target != null ? target.getClass() : null);
				List<Object> chain = this.advised.getInterceptorsAndDynamicInterceptionAdvice(method, targetClass);
				Object retVal;
				// Check whether we only have one InvokerInterceptor: that is,
				// no real advice, but just reflective invocation of the target.
				if (chain.isEmpty() && Modifier.isPublic(method.getModifiers())) {
					// We can skip creating a MethodInvocation: just invoke the target directly.
					// Note that the final invoker must be an InvokerInterceptor, so we know
					// it does nothing but a reflective operation on the target, and no hot
					// swapping or fancy proxying.
					Object[] argsToUse = AopProxyUtils.adaptArgumentsIfNecessary(method, args);
					retVal = methodProxy.invoke(target, argsToUse);
				}
				else {
					// We need to create a method invocation...
					retVal = new CglibMethodInvocation(proxy, target, method, args, targetClass, chain, methodProxy).proceed();
				}
				retVal = processReturnType(proxy, target, method, retVal);
				return retVal;
			}
			finally {
				if (target != null && !targetSource.isStatic()) {
					targetSource.releaseTarget(target);
				}
				if (setProxyContext) {
					// Restore old proxy.
					AopContext.setCurrentProxy(oldProxy);
				}
			}
		}

通過getInterceptorsAndDynamicInterceptionAdvice獲取到當前方法的攔截器,里面包含了CacheIneterceptor,說明注解被spring檢測到了。

在這里插入圖片描述

進入CglibMethodInvocation(proxy, target, method, args, targetClass, chain, methodProxy).proceed()方法內部

org.springframework.aop.framework.ReflectiveMethodInvocation#proceed

@Override
	@Nullable
	public Object proceed() throws Throwable {
		//	We start with an index of -1 and increment early.
		if (this.currentInterceptorIndex == this.interceptorsAndDynamicMethodMatchers.size() - 1) {
			return invokeJoinpoint();
		}
		Object interceptorOrInterceptionAdvice =
				this.interceptorsAndDynamicMethodMatchers.get(++this.currentInterceptorIndex);
		if (interceptorOrInterceptionAdvice instanceof InterceptorAndDynamicMethodMatcher) {
			// Evaluate dynamic method matcher here: static part will already have
			// been evaluated and found to match.
			InterceptorAndDynamicMethodMatcher dm =
					(InterceptorAndDynamicMethodMatcher) interceptorOrInterceptionAdvice;
			if (dm.methodMatcher.matches(this.method, this.targetClass, this.arguments)) {
				return dm.interceptor.invoke(this);
			}
			else {
				// Dynamic matching failed.
				// Skip this interceptor and invoke the next in the chain.
				return proceed();
			}
		}
		else {
			// It's an interceptor, so we just invoke it: The pointcut will have
			// been evaluated statically before this object was constructed.
			return ((MethodInterceptor) interceptorOrInterceptionAdvice).invoke(this);
		}
	}

this.interceptorsAndDynamicMethodMatchers.get(++this.currentInterceptorIndex)方法取第一個攔截器,正是我們要關注的CacheIneterceptor,然后調用((MethodInterceptor) interceptorOrInterceptionAdvice).invoke(this)方法,繼續(xù)跟進

org.springframework.cache.interceptor.CacheInterceptor#invoke

@Override
	@Nullable
	public Object invoke(final MethodInvocation invocation) throws Throwable {
		Method method = invocation.getMethod();
		CacheOperationInvoker aopAllianceInvoker = () -> {
			try {
				return invocation.proceed();
			}
			catch (Throwable ex) {
				throw new CacheOperationInvoker.ThrowableWrapper(ex);
			}
		};
		try {
			return execute(aopAllianceInvoker, invocation.getThis(), method, invocation.getArguments());
		}
		catch (CacheOperationInvoker.ThrowableWrapper th) {
			throw th.getOriginal();
		}
	}

進入execute方法

protected Object execute(CacheOperationInvoker invoker, Object target, Method method, Object[] args) {
		// Check whether aspect is enabled (to cope with cases where the AJ is pulled in automatically)
		if (this.initialized) {
			Class<?> targetClass = getTargetClass(target);
			CacheOperationSource cacheOperationSource = getCacheOperationSource();
			if (cacheOperationSource != null) {
				Collection<CacheOperation> operations = cacheOperationSource.getCacheOperations(method, targetClass);
				if (!CollectionUtils.isEmpty(operations)) {
					return execute(invoker, method,
							new CacheOperationContexts(operations, method, args, target, targetClass));
				}
			}
		}
		return invoker.invoke();
	}

cacheOperationSource記錄系統(tǒng)中所有使用了緩存的方法,cacheOperationSource.getCacheOperations(method, targetClass)能獲取deleteByTaskId()方法緩存元數據,然后執(zhí)行execute()方法

@Nullable
	private Object execute(final CacheOperationInvoker invoker, Method method, CacheOperationContexts contexts) {
		// Special handling of synchronized invocation
		if (contexts.isSynchronized()) {
			CacheOperationContext context = contexts.get(CacheableOperation.class).iterator().next();
			if (isConditionPassing(context, CacheOperationExpressionEvaluator.NO_RESULT)) {
				Object key = generateKey(context, CacheOperationExpressionEvaluator.NO_RESULT);
				Cache cache = context.getCaches().iterator().next();
				try {
					return wrapCacheValue(method, cache.get(key, () -> unwrapReturnValue(invokeOperation(invoker))));
				}
				catch (Cache.ValueRetrievalException ex) {
					// The invoker wraps any Throwable in a ThrowableWrapper instance so we
					// can just make sure that one bubbles up the stack.
					throw (CacheOperationInvoker.ThrowableWrapper) ex.getCause();
				}
			}
			else {
				// No caching required, only call the underlying method
				return invokeOperation(invoker);
			}
		}
		// Process any early evictions
		processCacheEvicts(contexts.get(CacheEvictOperation.class), true,
				CacheOperationExpressionEvaluator.NO_RESULT);
		// Check if we have a cached item matching the conditions
		Cache.ValueWrapper cacheHit = findCachedItem(contexts.get(CacheableOperation.class));
		// Collect puts from any @Cacheable miss, if no cached item is found
		List<CachePutRequest> cachePutRequests = new LinkedList<>();
		if (cacheHit == null) {
			collectPutRequests(contexts.get(CacheableOperation.class),
					CacheOperationExpressionEvaluator.NO_RESULT, cachePutRequests);
		}
		Object cacheValue;
		Object returnValue;
		if (cacheHit != null && cachePutRequests.isEmpty() && !hasCachePut(contexts)) {
			// If there are no put requests, just use the cache hit
			cacheValue = cacheHit.get();
			returnValue = wrapCacheValue(method, cacheValue);
		}
		else {
			// Invoke the method if we don't have a cache hit
			returnValue = invokeOperation(invoker);
			cacheValue = unwrapReturnValue(returnValue);
		}
		// Collect any explicit @CachePuts
		collectPutRequests(contexts.get(CachePutOperation.class), cacheValue, cachePutRequests);
		// Process any collected put requests, either from @CachePut or a @Cacheable miss
		for (CachePutRequest cachePutRequest : cachePutRequests) {
			cachePutRequest.apply(cacheValue);
		}
		// Process any late evictions
		processCacheEvicts(contexts.get(CacheEvictOperation.class), false, cacheValue);
		return returnValue;
	}

這里大致過程是:

先執(zhí)行beforInvokeEvict ---- 執(zhí)行數據庫delete操作 --- 執(zhí)行CachePut操作 ---- 執(zhí)行afterInvokeEvict

我們的注解是方法調用后再使緩存失效,直接所以有效的操作應在倒數第2行

private void performCacheEvict(
			CacheOperationContext context, CacheEvictOperation operation, @Nullable Object result) {
		Object key = null;
		for (Cache cache : context.getCaches()) {
			if (operation.isCacheWide()) {
				logInvalidating(context, operation, null);
				doClear(cache);
			}
			else {
				if (key == null) {
					key = generateKey(context, result);
				}
				logInvalidating(context, operation, key);
				doEvict(cache, key);
			}
		}
	}

這里通過context.getCaches()獲取到name為taskParamsCache的緩存

在這里插入圖片描述

然后generateKey生成key,注意這里,發(fā)現生成的key是com.xxx.xxx.atomic.impl.xxxxdeleteByTaskId982,但是緩存中的key卻是com.xxx.xxx.atomic.impl.xxxxselectByTaskId982,下面調用的doEvict(cache, key)方法不再跟進了,就是從cache中移除key對應值。明顯這里key對應不上的,這也是導致@CacheEvict沒有生效的原因。

小結一下

我還是太大意了,當時看了注解@CacheEvict的對key的注釋:

在這里插入圖片描述

大意就是如果沒有指定key,那就會使用方法所有參數生成一個key,明顯com.xxx.xxx.atomic.impl.xxxxselectByTaskId982是方法名 + 參數,可是你沒說把方法名還加上了啊,說好的只用參數呢,哈哈,這個bug是我使用不當引出的,很多人不會犯這種低級錯誤。

解決辦法就是使用SpEL明確定義key

@Cacheable(value = "taskParamsCache", key = "#taskId")
List<TaskParams> selectByTaskId(Long taskId);
// ...
// ...
@CacheEvict(value = "taskParamsCache", key = "#taskId")
int deleteByTaskId(Long taskId);

說說spring全家桶中@CacheEvict無效情況

@CacheEvict(value =“test”, allEntries = true)

1、使用@CacheEvict注解的方法必須是controller層直接調用,service里間接調用不生效。

2、原因是因為key值跟你查詢方法的key值不統(tǒng)一,所以導致緩存并沒有清除

3、把@CacheEvict的方法和@Cache的方法放到一個java文件中寫,他倆在兩個java文件的話,會導致@CacheEvict失效。

4、返回值必須設置為void

@CacheEvict annotation

It is important to note that void methods can be used with @CacheEvict

5、@CacheEvict必須作用在走代理的方法上

在使用Spring @CacheEvict注解的時候,要注意,如果類A的方法f1()被標注了 @CacheEvict注解,那么當類A的其他方法,例如:f2(),去直接調用f1()的時候, @CacheEvict是不起作用的,原因是 @CacheEvict是基于Spring AOP代理類,f2()屬于內部方法,直接調用f1()時,是不走代理的。

舉個例子

不生效:

@Override
public void saveEntity(Menu menu) {
  try {
    mapper.insert(menu);
    //Cacheable 不生效
    this.test();
  }catch(Exception e){
    e.printStackTrace();
  }
}
@CacheEvict(value = "test" , allEntries = true)
public void test() {
}

正確使用:

@Override
@CacheEvict(value = "test" , allEntries = true)
public void saveEntity(Menu menu) {
  try {
    mapper.insert(menu);
  }catch(Exception e){
    e.printStackTrace();
  }
}

以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。

相關文章

  • Java報錯:找不到或無法加載主類的解決辦法

    Java報錯:找不到或無法加載主類的解決辦法

    在Java中當您嘗試運行一個類作為主類時,如果系統(tǒng)找不到該類或者無法加載該類,就會出現"找不到或無法加載主類"的錯誤,這篇文章主要給大家介紹了關于Java報錯:找不到或無法加載主類的解決辦法,需要的朋友可以參考下
    2024-12-12
  • 一文帶你搞懂java如何實現網絡NIO高并發(fā)編程

    一文帶你搞懂java如何實現網絡NIO高并發(fā)編程

    NIO是?Java?在?JDK?1.4?中引入的一套新的?I/O?API,旨在解決傳統(tǒng)?I/O高并發(fā)場景下的性能和擴展性不足的問題,下面就跟隨小編一起深入了解下NIO高并發(fā)編程吧
    2024-12-12
  • Java中的大數類簡單實現

    Java中的大數類簡單實現

    這篇文章主要介紹了Java中的大數類簡單實現的相關資料,需要的朋友可以參考下
    2017-03-03
  • SpringBoot集成itext導出PDF的過程

    SpringBoot集成itext導出PDF的過程

    本文介紹了如何在Spring Boot中集成iText庫導出PDF文件,并解決中文亂碼問題,步驟包括添加依賴、準備字體、打開系統(tǒng)字體目錄選擇字體、在控制器中新增方法、創(chuàng)建并測試UserPdfExportService類,以及添加請求頭,感興趣的朋友一起看看吧
    2024-11-11
  • Java實現的百度語音識別功能示例

    Java實現的百度語音識別功能示例

    這篇文章主要介紹了Java實現的百度語音識別功能,較為簡明扼要的分析了Java調用百度語音接口相關操作步驟,并給出了具體的語音識別用法代碼示例,需要的朋友可以參考下
    2018-08-08
  • HashMap每次擴容為什么是2倍

    HashMap每次擴容為什么是2倍

    當HashMap在初始化沒有指定容量的情況下,首次添加元素時,數組的容量為16;當超出閾值,數組容量為擴容為之前的2倍,為什么HashMap每次擴容都是之前的2倍?下面就介紹一下
    2024-11-11
  • Hadoop2.8.1完全分布式環(huán)境搭建過程

    Hadoop2.8.1完全分布式環(huán)境搭建過程

    本文搭建了一個由三節(jié)點(master、slave1、slave2)構成的Hadoop完全分布式集群(區(qū)別單節(jié)點偽分布式集群),并通過Hadoop分布式計算的一個示例測試集群的正確性。對hadoop分布式環(huán)境搭建過程感興趣的朋友跟隨小編一起看看吧
    2019-06-06
  • IDEA?Reformat?Code?格式化代碼(詳解)

    IDEA?Reformat?Code?格式化代碼(詳解)

    平時使用Ctrl+Alt+L可以格式化代碼,idea幫你整理空格,換行等,讓代碼看起來更整潔,今天通過本文給大家分享IDEA?Reformat?Code?格式化?的過程,感興趣的朋友一起看看吧
    2023-11-11
  • Java中的final關鍵字使用方式

    Java中的final關鍵字使用方式

    這篇文章主要介紹了Java中的final關鍵字使用方式,final 關鍵字用于修飾不可改變內容,更多相關梳理總結,需要的小伙伴可以參考下面文章內容
    2022-06-06
  • Java中的輸出格式化問題小結

    Java中的輸出格式化問題小結

    在Java中,System.out.printf方法用于格式化輸出,格式化字符串`%.6f`表示浮點數保留6位小數,其他格式化選項包括`%d`(整數)、`%s`(字符串)和`%e`(科學計數法),示例代碼展示了如何使用這些格式化選項,感興趣的朋友一起看看吧
    2025-02-02

最新評論

阿城市| 昭平县| 敖汉旗| 克什克腾旗| 三都| 高要市| 海盐县| 蒙自县| 唐河县| 嘉禾县| 耿马| 上犹县| 习水县| 南皮县| 乌审旗| 穆棱市| 广东省| 郯城县| 西峡县| 桐柏县| 淮阳县| 三台县| 荣成市| 枞阳县| 武安市| 句容市| 丰镇市| 达日县| 化州市| 鄂托克前旗| 禄丰县| 安阳县| 阿图什市| 绍兴市| 礼泉县| 镇平县| 湾仔区| 公安县| 荔波县| 廊坊市| 乐清市|