java并发访问重复请求过滤问题

网友投稿 260 2023-01-31


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.aspectjzsaujaeiwT.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 duplizsaujaeiwTcate() {

}

/**

* 对方法拦截后进行参数验证

* @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);

}

}

}

以上就是本次给大家讲述的全部内容以及相关代码,如果大家还有任何问题可以在下方的留言区讨论,感谢大家对我们的支持。


版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:使用proxytable 配置解决 vue
下一篇:Java实现文件和base64流的相互转换功能示例
相关文章

 发表评论

暂时没有评论,来抢沙发吧~