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<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);
    }

  }
}

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