欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2023-12-19 14:35:58
问题描述 前段时间遇到个问题,自己内部系统调用出现重复请求导致数据混乱。 发生条件:接受到一个请求,该请求没有执行完成又接受到相同请求,导致数据错误(如果是...

问题描述

前段时间遇到个问题,自己内部系统调用出现重复请求导致数据混乱。

发生条件:接受到一个请求,该请求没有执行完成又接受到相同请求,导致数据错误(如果是前一个请求执行完成,马上又接受相同请求不会有问题)

问题分析:是由于数据库的脏读导致

问题解决思路

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

  }
}

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

上一篇:

下一篇: