日韩av黄I国产麻豆传媒I国产91av视频在线观看I日韩一区二区三区在线看I美女国产在线I麻豆视频国产在线观看I成人黄色短片

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 >

java 过滤掉相同请求_java并发访问重复请求过滤问题

發布時間:2025/3/21 50 豆豆
生活随笔 收集整理的這篇文章主要介紹了 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并发访问重复请求过滤问题的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。