srping注解方式防止重复提交原理分析，供大家参考，具体内容如下
方法一： springmvc使用token
使用token的逻辑是，给所有的url加一个拦截器，在拦截器里面用java的uuid生成一个随机的uuid并把这个uuid放到session里面，然后在浏览器做数据提交的时候将此uuid提交到服务器。服务器在接收到此uuid后，检查一下该uuid是否已经被提交，如果已经被提交，则不让逻辑继续执行下去…**
1 首先要定义一个annotation： 用@retention 和 @target 标注接口
|
1
2
3
4
5
6
|
@target(elementtype.method)
@retention(retentionpolicy.runtime)
public @interface token {
boolean save() default false;
boolean remove() default false;
}
|
2 定义拦截器tokeninterceptor：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
public class tokeninterceptor extends handlerinterceptoradapter {
@override
public boolean prehandle(httpservletrequest request, httpservletresponse response, object handler) throws exception {
if (handler instanceof handlermethod) {
handlermethod handlermethod = (handlermethod) handler;
method method = handlermethod.getmethod();
token annotation = method.getannotation(token.class);
if (annotation != null) {
boolean needsavesession = annotation.save();
if (needsavesession) {
request.getsession(false).setattribute("token", uuid.randomuuid().tostring());
}
boolean needremovesession = annotation.remove();
if (needremovesession) {
if (isrepeatsubmit(request)) {
return false;
}
request.getsession(false).removeattribute("token");
}
}
return true;
} else {
return super.prehandle(request, response, handler);
}
}
private boolean isrepeatsubmit(httpservletrequest request) {
string servertoken = (string) request.getsession(false).getattribute("token");
if (servertoken == null) {
return true;
}
string clinettoken = request.getparameter("token");
if (clinettoken == null) {
return true;
}
if (!servertoken.equals(clinettoken)) {
return true;
}
return false;
}
}
|
spring mvc的配置文件里加入：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
<mvc:interceptors>
<!-- 使用bean定义一个interceptor，直接定义在mvc:interceptors根下面的interceptor将拦截所有的请求 -->
<mvc:interceptor>
<mvc:mapping path="/**"/>
<!-- 定义在mvc:interceptor下面的表示是对特定的请求才进行拦截的 -->
<bean class="****包名****.tokeninterceptor"/>
</mvc:interceptor>
</mvc:interceptors>
@requestmapping("/add.jspf")
@token(save=true)
public string add() {
//省略
return tpl_base + "index";
}
@requestmapping("/save.jspf")
@token(remove=true)
public void save() {
//省略
}
|
用法：
在controller类的用于定向到添加/修改操作的方法上增加自定义的注解类 @token(save=true)
在controller类的用于表单提交保存的的方法上增加@token(remove=true)
在表单中增加 用于存储token，每次需要报token值传入到后台类，用于从缓存对比是否是重复提交操作
方法二：springboot中用注解方式
每次操作，生成的key存放于缓存中，比如用google的gruava或者redis做缓存
定义annotation类
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
@target(elementtype.method)
@retention(retentionpolicy.runtime)
@documented
@inherited
public @interface locallock {
/**
* @author fly
*/
string key() default "";
/**
* 过期时间 todo 由于用的 guava 暂时就忽略这属性吧 集成 redis 需要用到
*
* @author fly
*/
int expire() default 5;
}
|
设置拦截类
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
@aspect
@configuration
public class lockmethodinterceptor {
private static final cache<string, object> caches = cachebuilder.newbuilder()
// 最大缓存 100 个
.maximumsize(1000)
// 设置写缓存后 5 秒钟过期
.expireafterwrite(5, timeunit.seconds)
.build();
@around("execution(public * *(..)) && @annotation(com.demo.testduplicate.test1.locallock)")
public object interceptor(proceedingjoinpoint pjp) {
methodsignature signature = (methodsignature) pjp.getsignature();
method method = signature.getmethod();
locallock locallock = method.getannotation(locallock.class);
string key = getkey(locallock.key(), pjp.getargs());
if (!stringutils.isempty(key)) {
if (caches.getifpresent(key) != null) {
throw new runtimeexception("请勿重复请求");
}
// 如果是第一次请求,就将 key 当前对象压入缓存中
caches.put(key, key);
}
try {
return pjp.proceed();
} catch (throwable throwable) {
throw new runtimeexception("服务器异常");
} finally {
// todo 为了演示效果,这里就不调用 caches.invalidate(key); 代码了
}
}
/**
* key 的生成策略,如果想灵活可以写成接口与实现类的方式（todo 后续讲解）
*
* @param keyexpress 表达式
* @param args 参数
* @return 生成的key
*/
private string getkey(string keyexpress, object[] args) {
for (int i = 0; i < args.length; i++) {
keyexpress = keyexpress.replace("arg[" + i + "]", args[i].tostring());
}
return keyexpress;
}
}
|
controller类引用
|
1
2
3
4
5
6
7
8
9
10
|
@restcontroller
@requestmapping("/books")
public class bookcontroller {
@locallock(key = "book:arg[0]")
@getmapping
public string save(@requestparam string token) {
return "success - " + token;
}
}
|
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：https://blog.csdn.net/xdy3008/article/details/84452587