快捷導(dǎo)航

java并發(fā)訪問(wèn)重復(fù)請(qǐng)求過(guò)濾問(wèn)題

更新時(shí)間：2018年05月26日 15:03:21 作者：u010704600

本篇文章給大家分享了關(guān)于java并發(fā)訪問(wèn)重復(fù)請(qǐng)求過(guò)濾的相關(guān)問(wèn)題以及解決方法，對(duì)此有需要的朋友參考學(xué)習(xí)下。

問(wèn)題描述

前段時(shí)間遇到個(gè)問(wèn)題，自己內(nèi)部系統(tǒng)調(diào)用出現(xiàn)重復(fù)請(qǐng)求導(dǎo)致數(shù)據(jù)混亂。

發(fā)生條件：接受到一個(gè)請(qǐng)求，該請(qǐng)求沒(méi)有執(zhí)行完成又接受到相同請(qǐng)求，導(dǎo)致數(shù)據(jù)錯(cuò)誤（如果是前一個(gè)請(qǐng)求執(zhí)行完成，馬上又接受相同請(qǐng)求不會(huì)有問(wèn)題）

問(wèn)題分析：是由于數(shù)據(jù)庫(kù)的臟讀導(dǎo)致

問(wèn)題解決思路

1.加一把大大的鎖（是最簡(jiǎn)單的實(shí)現(xiàn)方式，但是性能堪憂，而且會(huì)阻塞請(qǐng)求）

2.實(shí)現(xiàn)請(qǐng)求攔截（可以共用，但是怎么去實(shí)現(xiàn)卻是一個(gè)問(wèn)題，怎么用一個(gè)優(yōu)雅的方式實(shí)現(xiàn)，并且方便復(fù)用）

3.修改實(shí)現(xiàn) （會(huì)對(duì)原有代碼做改動(dòng)，存在風(fēng)險(xiǎn)，最主要的是不能共用）

最終實(shí)現(xiàn)方式

通過(guò)注解+spring AOP 的方式實(shí)現(xiàn)

使用

通過(guò)在任意方法上添加注解NotDuplicate

類(lèi)1：

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 {
}

類(lèi)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() {
  }

  /**
   * 對(duì)方法攔截后進(jìn)行參數(shù)驗(yàn)證
   * @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("該方法正在執(zhí)行,不能重復(fù)請(qǐng)求");
    }
    try {
      return pjp.proceed();
    } finally {
      KEY.remove(sign);
    }

  }
}

以上就是本次給大家講述的全部?jī)?nèi)容以及相關(guān)代碼，如果大家還有任何問(wèn)題可以在下方的留言區(qū)討論，感謝大家對(duì)腳本之家的支持。

您可能感興趣的文章: