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 类里面对象共享_Java并发编程 - 对象的共享
编写正确的并发程序,关键问题在于:在访问共享的可变状态时需要进行正确的管理.同步代码块和同步方法可以确保以原子的方式执行操作,同步还有另一个重要的方面:内存可见性. 可见性 为了确保多个线程之间对内存 ...
- java 判断请求为 ajax请求_Java过滤器处理Ajax请求,Java拦截器处理Ajax请求,java 判断请求是不是ajax请求...
Java过滤器处理Ajax请求,Java拦截器处理Ajax请求,拦截器Ajax请求 java 判断请求是不是ajax请求,Java判断是否为ajax请求 >>>>>> ...
- 两个线程同时访问一个变量_百战程序员:Java多线程对象及变量的并发访问
在开发多线程程序时,如果每个多线程处理的事情都不一样,每个线程都互不相关,这样开发的过程就非常轻松.但是很多时候,多线程程序是需要同时访问同一个对象,或者变量的.这样,一个对象同时被多个线程访问,会出 ...
- jeecgboot中,修改请求方式加入阻止重复请求的方法。
全部request.js代码 import Vue from 'vue' import axios from 'axios' import store from '@/store' import { ...
- ajax定时器重复,jquery ajax使用定时器限制请求次数及终止重复请求
场景描述: 在我们平时的开发过程中,经常会遇到这样的情况.在搜索功能中进行模糊搜索或者联想关联. 这就要我们每次对输入框中的数据进行改动时,都要发送一次请求.当在短时间内多次操作改动时,问题就出现了. ...
- futuretask java 并发请求_Java并发编程:Callable、Future和FutureTask
Java并发编程:Callable.Future和FutureTask 在前面的文章中我们讲述了创建线程的2种方式,一种是直接继承Thread,另外一种就是实现Runnable接口. 这2种方式都有一 ...
- futuretask java 并发请求_Java并发机制(9)--Callable、Future、FutureTask的使用
Java并发编程:Callable.Future.FutureTask的使用 继承关系: 1.接口Callable与Runnable 1.1.Runnable接口中只有一个void run()方法,其 ...
- java并发访问_Java并发访问
1 线程安全 线程安全就是多线程访问时,采用了加锁机制,当一个线程访问该类的某个数据时,进行保护,其他线程不能进行访问直到该线程读取完,其他线程才可使用.不会出现数据不一致或者数据污染. 线程不安全就 ...
- futuretask java 并发请求_Java并发案例04---Future和 FutureTask
4.Future和 FutureTask 4.1 Future是Callable的返回结果. 它有三个功能 1.判断任务是否完成 2.能够中断任务 3.能够获取任务返回结果 4.2 FutureTas ...
最新文章
- 属性(Properties)和字段在C#中的关系
- htaccess分布式配置文件常用写法
- SVM-SMO算法python实现
- Hsiao United Cheap Nike Air Max
- Nuget如何自动下载依赖DLL引用
- Horizon8基础环境准备08——CA证书
- Confluence 6 企业环境或者网站托管的 Java 配置策略
- 12 File and Device I/O using System Calls
- CSS 盒子模型(Box Model)
- 查看tensorflow版本以及路径:
- 【资源】PyTorch版《动手学深度学习》开源了,最美DL书遇上最赞DL框架
- 【C语言】字符串与整型数值之间的转换
- 蓝桥杯-----十六进制转八进制
- 文件读写: 二进制方式和文本方式的区别
- SketchUp LayOut 剪贴簿制作技巧
- mac charles4.0.2免费破解版安装
- postman安装使用教程---图文讲解
- 动画中的“表现手法”和“表现方式”分别是什么?今天艺点动画大家庭来给你唠嗑唠嗑
- Android动画之LayoutTransition布局动画
- 高等代数习题课(手写)