插菊花网,国产精品对白交换视频,欧美成人免费网站

問題描述

前段時間遇到個問題，自己內部系統調用出現重復請求導致數據混亂。

發生條件：接受到一個請求，該請求沒有執行完成又接受到相同請求，導致數據錯誤（如果是前一個請求執行完成，馬上又接受相同請求不會有問題）

問題分析：是由于數據庫的臟讀導致

問題解決思路

1.加一把大大的鎖（是最簡單的實現方式，但是性能堪憂，而且會阻塞請求）

2.實現請求攔截（可以共用，但是怎么去實現卻是一個問題，怎么用一個優雅的方式實現，并且方便復用）

3.修改實現（會對原有代碼做改動，存在風險，最主要的是不能共用）

最終實現方式

通過注解+spring AOP 的方式實現

使用

通過在任意方法上添加注解NotDuplicate

類1：

java" id="highlighter_459420">

									import static java.lang.annotation.ElementType.METHOD;

									import java.lang.annotation.Documented;

									import java.lang.annotation.Retention;

									import java.lang.annotation.RetentionPolicy;

									import java.lang.annotation.Target;

									@Target({METHOD})

									@Retention(RetentionPolicy.RUNTIME)

									@Documented

									public @interface NotDuplicate {

									}

類2：

									import java.lang.reflect.Method;

									import java.util.Set;

									import java.util.concurrent.ConcurrentSkipListSet;

									import org.aspectj.lang.ProceedingJoinPoint;

									import org.aspectj.lang.annotation.Around;

									import org.aspectj.lang.annotation.Aspect;

									import org.aspectj.lang.annotation.Pointcut;

									import org.aspectj.lang.reflect.MethodSignature;

									import org.springframework.stereotype.Component;

									@Aspect

									@Component

									public class NotDuplicateAop {

									  private static final Set<String> KEY = new ConcurrentSkipListSet<>();

									  @Pointcut("@annotation(com.hhly.skeleton.base.filter.NotDuplicate)")

									  public void duplicate() {

									  }

									  /**

									   * 對方法攔截后進行參數驗證

									   * @param pjp

									   * @return

									   * @throws Throwable

									   */

									  @Around("duplicate()")

									  public Object duplicate(ProceedingJoinPoint pjp) throws Throwable {

									    MethodSignature msig = (MethodSignature) pjp.getSignature();

									    Method currentMethod = pjp.getTarget().getClass().getMethod(msig.getName(), msig.getParameterTypes());

									    //拼接簽名

									    StringBuilder sb = new StringBuilder(currentMethod.toString());

									    Object[] args = pjp.getArgs();

									    for (Object object : args) {

									      if(object != null){

									        sb.append(object.getClass().toString());

									        sb.append(object.toString());

									      }

									    }

									    String sign = sb.toString();

									    boolean success = KEY.add(sign);

									    if(!success){

									      throw new ServiceRuntimeException("該方法正在執行,不能重復請求");

									    }

									    try {

									      return pjp.proceed();

									    } finally {

									      KEY.remove(sign);

									    }

									  }

									}