java 过滤掉相同请求_java并发访问重复请求过滤问题
問題描述
前段時間遇到個問題,自己內部系統調用出現重復請求導致數據混亂。
發生條件:接受到一個請求,該請求沒有執行完成又接受到相同請求,導致數據錯誤(如果是前一個請求執行完成,馬上又接受相同請求不會有問題)
問題分析:是由于數據庫的臟讀導致
問題解決思路
1.加一把大大的鎖 (是最簡單的實現方式,但是性能堪憂,而且會阻塞請求)
2.實現請求攔截 (可以共用,但是怎么去實現卻是一個問題,怎么用一個優雅的方式實現,并且方便復用)
3.修改實現 (會對原有代碼做改動,存在風險,最主要的是不能共用)
最終實現方式
通過注解+spring AOP 的方式實現
使用
通過在任意方法上添加注解NotDuplicate
類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 {
}
類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 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);
}
}
}
以上就是本次給大家講述的全部內容以及相關代碼,如果大家還有任何問題可以在下方的留言區討論,感謝大家對腳本之家的支持。
總結
以上是生活随笔為你收集整理的java 过滤掉相同请求_java并发访问重复请求过滤问题的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: java的lr词法编译器_Sample语
- 下一篇: java同名过滤器_Gateway Re