- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章spring应用中多次读取http post方法中的流遇到的问题由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.
1、问题简述 。
先说下为啥有这个需求,在基于spring的web应用中,一般会在controller层获取http方法body中的数据.
方式1:
比如http请求的content-type为application/json的情况下,直接用@requestbody接收.
方式2:
也有像目前我们在做的这个项目,比较原始,是直接手动读取流。(不要问我为啥这么原始,第一版也不是我写的。) 。
1
2
3
4
5
6
|
@requestmapping
(
"/xxx.do"
)
public
void
xxx(httpservletrequest request, httpservletresponse response)
throws
ioexception {
jsonobject jsonobject = webutils.getparameters(request);
//业务处理
responseutil.setresponse(response, messagefactory.createsuccessmsg());
}
|
webutils.getparameters如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
public
static
jsonobject getparameters(httpservletrequest request)
throws
ioexception {
inputstream is =
null
;
is =
new
bufferedinputstream(request.getinputstream(), buffer_size);
int
contentlength = integer.valueof(request.getheader(
"content-length"
));
byte
[] bytes =
new
byte
[contentlength];
int
readcount =
0
;
while
(readcount < contentlength) {
readcount += is.read(bytes, readcount, contentlength - readcount);
}
string requestjson =
new
string(bytes, appconstants.utf8);
if
(stringutils.isblank(requestjson)) {
return
new
jsonobject();
}
jsonobject jsonobj = jsonutils.tojsonobject(requestjson);
return
jsonobj;
}
|
当然,不管怎么说,都是对流进行读取.
问题是,假如我想在controller前面加一层aop,aop里面对进入controller层的方法进行日志记录,记录方法参数,应该怎么办呢.
如果是采用了方式1的话,简单。spring已经帮我们把参数从流里取出来,给我们提供好了,我们拿着打印一下日志即可.
如果是比较悲剧地采用了我们这种方式,参数里只有个httpservletrequest,那就只有自己去读取流了,然而,在aop中我们把流读了的话, 。
在controller层就读不到了.
毕竟,流只能读一次啊.
2、怎么一个流读多次呢 。
说一千道一万,流来自哪里,来自 。
1
|
javax.servlet.servletrequest#getinputstream
|
所以,我们的思路,是不是可以这样,定义一个filter,在filter中将request替换为我们自定义的request.
下面标红的为自定义的request.
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
/**
*
*/
package
com.ckl.filter;
import
com.ckl.utils.basewebutils;
import
com.ckl.utils.multireadhttpservletrequest;
import
org.slf4j.logger;
import
org.slf4j.loggerfactory;
import
org.springframework.core.annotation.order;
import
org.springframework.http.httpmethod;
import
org.springframework.http.mediatype;
import
javax.servlet.*;
import
javax.servlet.annotation.webfilter;
import
javax.servlet.http.httpservletrequest;
import
java.io.ioexception;
/**
* web流多次读写过滤器
*
* 拦截所有请求,主要是针对第三方提交过来的请求.
* 为什么要做成可多次读写的流,因为可以在aop层打印日志。
* 但是不影响controller层继续读取该流
*
* 该filter的原理:https://stackoverflow.com/questions/10210645/http-servlet-request-lose-params-from-post-body-after-read-it-once/17129256#17129256
* @author ckl
*/
@order
(
1
)
@webfilter
(filtername =
"cacherequestfilter"
, urlpatterns =
"*.do"
)
public
class
cacherequestfilter
implements
filter {
private
static
final
logger logger = loggerfactory.getlogger(cacherequestfilter.
class
);
@override
public
void
init(filterconfig filterconfig)
throws
servletexception {
// todo auto-generated method stub
}
@override
public
void
dofilter(servletrequest request, servletresponse response,
filterchain chain)
throws
ioexception, servletexception {
httpservletrequest httpservletrequest = (httpservletrequest) request;
logger.info(
"request uri:{}"
,httpservletrequest.getrequesturi());
if
(basewebutils.isformpost(httpservletrequest)){
httpservletrequest =
new
multireadhttpservletrequest(httpservletrequest);
string parameters = basewebutils.getparameters(httpservletrequest);
logger.info(
"cacherequestfilter receive post req. body is {}"
, parameters);
}
else
if
(ispost(httpservletrequest)){
//文件上传请求,没必要缓存请求
if
(request.getcontenttype().contains(mediatype.multipart_form_data_value)){
}
else
{
httpservletrequest =
new
multireadhttpservletrequest(httpservletrequest);
string parameters = basewebutils.getparameters(httpservletrequest);
logger.info(
"cacherequestfilter receive post req. body is {}"
, parameters);
}
}
chain.dofilter(httpservletrequest, response);
}
@override
public
void
destroy() {
// todo auto-generated method stub
}
public
static
boolean
ispost(httpservletrequest request) {
return
httpmethod.post.matches(request.getmethod());
}
}
multireadhttpservletrequest.java:
import
org.apache.commons.io.ioutils;
import
javax.servlet.servletinputstream;
import
javax.servlet.http.httpservletrequest;
import
javax.servlet.http.httpservletrequestwrapper;
import
java.io.bufferedreader;
import
java.io.bytearrayoutputstream;
import
java.io.ioexception;
import
java.io.inputstreamreader;
/**
* desc:
* https://stackoverflow.com/questions/10210645/http-servlet-request-lose-params-from-post-body-after-read-it-once/17129256#17129256
* @author : ckl
* creat_date: 2018/8/2 0002
* creat_time: 13:46
**/
public
class
multireadhttpservletrequest
extends
httpservletrequestwrapper {
private
bytearrayoutputstream cachedbytes;
public
multireadhttpservletrequest(httpservletrequest request) {
super
(request);
cachedbytes =
new
bytearrayoutputstream();
servletinputstream inputstream =
null
;
try
{
inputstream =
super
.getinputstream();
ioutils.copy(inputstream, cachedbytes);
}
catch
(ioexception e) {
e.printstacktrace();
}
}
@override
public
servletinputstream getinputstream()
throws
ioexception {
return
new
cachedservletinputstream(cachedbytes);
}
@override
public
bufferedreader getreader()
throws
ioexception {
return
new
bufferedreader(
new
inputstreamreader(getinputstream()));
}
}
|
在自定义的request中,构造函数中,先把原始流中的数据读出来,放到bytearrayoutputstream cachedbytes中.
并且需要重新定义getinputstream方法.
以后每次程序中调用getinputstream方法时,都会从我们的偷梁换柱的request中的cachedbytes字段,new一个inputstream出来.
看上图红色部分:
getinputstream我们返回了自定义的cachedservletinputstream类.
那么,接下来是cachedservletinputstream:
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
|
package
com.ceiec.webservice.utils;
import
javax.servlet.readlistener;
import
javax.servlet.servletinputstream;
import
java.io.bytearrayinputstream;
import
java.io.bytearrayoutputstream;
import
java.io.ioexception;
/**
* an inputstream which reads the cached request body
*/
public
class
cachedservletinputstream
extends
servletinputstream {
private
bytearrayinputstream input;
public
cachedservletinputstream(bytearrayoutputstream cachedbytes) {
// create a new input stream from the cached request body
byte
[] bytes = cachedbytes.tobytearray();
input =
new
bytearrayinputstream(bytes);
}
@override
public
int
read()
throws
ioexception {
return
input.read();
}
@override
public
boolean
isfinished() {
return
false
;
}
@override
public
boolean
isready() {
return
false
;
}
@override
public
void
setreadlistener(readlistener readlistener) {
}
}
|
至此。完整的偷梁换柱就结束了.
现在,请再回过头去,看文章开头的代码,标红的部分.
是不是豁然开朗了?
3、代码地址 。
https://github.com/cctvckl/work_util/tree/master/spring-mvc-multiread-post 。
直接git 下载即可.
这是个单独的工程,直接eclipse或者idea导入即可.
运行方法:
我这边讲下idea:
直接运行jetty:run这个goal即可.
然后访问testpost.do即可(下面把curl贴出来,可以自己在接口测试工具里拼装):
1
2
3
4
5
6
|
curl -i -x post \
-h
"content-type:application/json"
\
-d \
'{
"id"
:
"32"
}
' \
'http://localhost:8080/springmvc-multiread-post/testpost.do'
|
我这边演示下效果,可以发现,两次都读出来了:
总结 。
以上所述是小编给大家介绍的spring应用中多次读取http post方法中的流,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对我网站的支持! 。
原文链接:http://www.cnblogs.com/grey-wolf/p/9953661.html 。
最后此篇关于spring应用中多次读取http post方法中的流遇到的问题的文章就讲到这里了,如果你想了解更多关于spring应用中多次读取http post方法中的流遇到的问题的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我对 c# 有点陌生,我在尝试围绕这个 if-then 语句尝试实现时遇到了一些麻烦。 这是我的目标:当用户将订单输入系统时,将为每个订单创建一个唯一的 orderID。但是,一些附加功能是用户可以选
我已经搜索了这个特定的错误,发现根本问题涉及循环计数错误并导致程序超出数组的界限。 但是,当我将每个数组降低到数组开始丢失输出数据的程度后,它继续抛出相同的错误。我对 C/C++ 仍然是新手,但任何对
我不明白为什么我运行这个小程序时屏幕上没有任何显示? while 循环甚至开始了吗? #include #include int main() { char word[20]; char
我接手了一个用 Perl 编写的项目,它有一些依赖项,例如 Template::Toolkit , Image::ExifTool , 和 GD仅举几例。目前,这些依赖项使用 --prefix 构建到
我想对一个字段进行累积总和,但只要遇到 0 就重置聚合值。 这是我想要的一个例子: data.frame(campaign = letters[1:4] , date=c("jan","
不久前,该项目的 gradle 构建运行良好,但现在一直失败并显示以下错误(带有 --info 标志的输出): Starting process 'Gradle Test Executor 1'. W
我是编程新手,想用 Java 制作一个掷骰子程序来执行。代码如下: import java.math.*; public class Dices { public static int dice1=0
这个问题已经有答案了: What is a StringIndexOutOfBoundsException? How can I fix it? (1 个回答) 已关闭 5 年前。 我对 Java 完
这个方法一直抛出标题中的异常,我找不到原因,我已经通过连接创建了其他表,并且所有引用的表都已创建。我正在使用嵌入式JavaDB . private void createEvidenceTable()
我刚开始上课,这是我第三次尝试上课。我遇到了一个 NameError,我真的不知道如何解决。看看我的程序,看看你能不能帮忙。 import random import math import pyga
好吧,这是我的困境,我向 JFrame 添加了三个面板。第一个(不可见)第二个(可见)和第三个(不可见)..我使用第一个面板作为菜单,当您选择一个选项时,第一个面板被制作(可见),然后第三个面板被制作
我的部分代码遇到问题。如果我选择选项 A,它会运行并给我正确的答案,但是,如果我选择选项 S 或 M,它不会给我任何结果,只会去到它应该去的地方。已经尝试将 if 更改为 else if,但它显示“预
我这里有一些代码,但我正在努力解决它,因为我似乎无法掌握这个文件指针的东西。我对使用文件还很陌生。我见过类似的其他问题,并且尝试了对其他人有效的解决方案,但由于某种原因它们对我不起作用。这是出现问题的
我们有一个很大的应用程序,我们已经将 TODO 规则添加到质量门中,如果发现 TODO 注释,它会给出错误。如果我们只是删除 TODO 注释(这很可怕),它会起作用,但添加 TODO 注释的整个目的就
我正在尝试编写一个名为 isVowel 的函数,它接受一个字符(即长度为 1 的字符串)并在它是元音、大写或小写时返回“true”。如果该字符不是元音字母,该函数应返回“false”。 这看起来应该可
我一直在努力完成我正在做的这个小项目,但由于某种原因它无法正常工作。 问题是当我第一次访问该页面并单击出现在主要部分中的第一个链接时,它会根据需要显示弹出框。现在,当我点击另一天,例如星期天并尝试点击
我正在尝试制作一个 WPF 应用程序。我的窗口内有一个数据网格。我制作了另一个窗口,将新数据添加到我的数据网格中。虽然它按照我想要的方式工作,但我不断遇到异常。我的 MySQL 代码: using S
我试图在我似乎无法使 NSUserDefaults 正常工作的程序中保存几个首选项。如果有人可以查看我的代码并查看是否有任何错误,我们将不胜感激 NSString *kGameIsPaused = @
设置 SymmetricDS版本是3.9.1(也试过3.9.0) 设置是从 postgres 9.5.3 到 postgres 9.5.3 Windows 10 pc(客户端节点)到 Windows
经过长时间的努力,我终于(差不多)完成了我的java菜单程序。但是,我无法让我的返回更改功能在我的代码末尾工作。它给出了非常奇数的数字。有什么想法吗? 代码: import java.io.*; im
我是一名优秀的程序员,十分优秀!