- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章SpringBoot记录Http请求日志的方法由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.
在使用spring boot开发 web api 的时候希望把 request,request header ,response reponse header , uri, method 等等的信息记录到我们的日志中,方便我们排查问题,也能对系统的数据做一些统计.
spring 使用了 dispatcherservlet 来拦截并分发请求,我们只要自己实现一个 dispatcherservlet 并在其中对请求和响应做处理打印到日志中即可.
我们实现一个自己的分发 servlet ,它继承于 dispatcherservlet,我们实现自己的 dodispatch(httpservletrequest request, httpservletresponse response) 方法.
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
|
public
class
loggabledispatcherservlet
extends
dispatcherservlet {
private
static
final
logger logger = loggerfactory.getlogger(
"httplogger"
);
private
static
final
objectmapper mapper =
new
objectmapper();
@override
protected
void
dodispatch(httpservletrequest request, httpservletresponse response)
throws
exception {
contentcachingrequestwrapper requestwrapper =
new
contentcachingrequestwrapper(request);
contentcachingresponsewrapper responsewrapper =
new
contentcachingresponsewrapper(response);
//创建一个 json 对象,用来存放 http 日志信息
objectnode rootnode = mapper.createobjectnode();
rootnode.put(
"uri"
, requestwrapper.getrequesturi());
rootnode.put(
"clientip"
, requestwrapper.getremoteaddr());
rootnode.set(
"requestheaders"
, mapper.valuetotree(getrequestheaders(requestwrapper)));
string method = requestwrapper.getmethod();
rootnode.put(
"method"
, method);
try
{
super
.dodispatch(requestwrapper, responsewrapper);
}
finally
{
if
(method.equals(
"get"
)) {
rootnode.set(
"request"
, mapper.valuetotree(requestwrapper.getparametermap()));
}
else
{
jsonnode newnode = mapper.readtree(requestwrapper.getcontentasbytearray());
rootnode.set(
"request"
, newnode);
}
rootnode.put(
"status"
, responsewrapper.getstatus());
jsonnode newnode = mapper.readtree(responsewrapper.getcontentasbytearray());
rootnode.set(
"response"
, newnode);
responsewrapper.copybodytoresponse();
rootnode.set(
"responseheaders"
, mapper.valuetotree(getresponsetheaders(responsewrapper)));
logger.info(rootnode.tostring());
}
}
private
map<string, object> getrequestheaders(httpservletrequest request) {
map<string, object> headers =
new
hashmap<>();
enumeration<string> headernames = request.getheadernames();
while
(headernames.hasmoreelements()) {
string headername = headernames.nextelement();
headers.put(headername, request.getheader(headername));
}
return
headers;
}
private
map<string, object> getresponsetheaders(contentcachingresponsewrapper response) {
map<string, object> headers =
new
hashmap<>();
collection<string> headernames = response.getheadernames();
for
(string headername : headernames) {
headers.put(headername, response.getheader(headername));
}
return
headers;
}
|
在 loggabledispatcherservlet 中,我们可以通过 httpservletrequest 中的 inputstream 或 reader 来获取请求的数据,但如果我们直接在这里读取了流或内容,到后面的逻辑将无法进行下去,所以需要实现一个可以缓存的 httpservletrequest。好在 spring 提供这样的类,就是 contentcachingrequestwrapper 和 contentcachingresponsewrapper, 根据官方的文档这两个类正好是来干这个事情的,我们只要将 httpservletrequest 和 httpservletresponse 转化即可.
httpservletrequest wrapper that caches all content read from the input stream and reader, and allows this content to be retrieved via a byte array. used e.g. by abstractrequestloggingfilter. note: as of spring framework 5.0, this wrapper is built on the servlet 3.1 api. 。
httpservletresponse wrapper that caches all content written to the output stream and writer, and allows this content to be retrieved via a byte array. used e.g. by shallowetagheaderfilter. note: as of spring framework 5.0, this wrapper is built on the servlet 3.1 api. 。
实现好我们的 loggabledispatcherservlet后,接下来就是要指定使用 loggabledispatcherservlet 来分发请求.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
@springbootapplication
public
class
sbdemoapplication
implements
applicationrunner {
public
static
void
main(string[] args) {
springapplication.run(sbdemoapplication.
class
, args);
}
@bean
public
servletregistrationbean dispatcherregistration() {
return
new
servletregistrationbean(dispatcherservlet());
}
@bean
(name = dispatcherservletautoconfiguration.default_dispatcher_servlet_bean_name)
public
dispatcherservlet dispatcherservlet() {
return
new
loggabledispatcherservlet();
}
}
|
增加一个简单的 controller 来测试一下 。
1
2
3
4
5
6
7
8
9
|
@restcontroller
@requestmapping
(
"/hello"
)
public
class
hellocontroller {
@requestmapping
(value =
"/word"
, method = requestmethod.post)
public
object hello(
@requestbody
object object) {
return
object;
}
}
|
使用 curl 发送一个 post 请求:
1
2
3
4
5
|
$ curl --header
"content-type: application/json"
\
--request post \
--data
'{"username":"xyz","password":"xyz"}'
\
http:
//localhost:8080/hello/word
{
"username"
:
"xyz"
,
"password"
:
"xyz"
}
|
查看打印的日志:
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
|
{
"uri"
:
"/hello/word"
,
"clientip"
:
"0:0:0:0:0:0:0:1"
,
"requestheaders"
:{
"content-length"
:
"35"
,
"host"
:
"localhost:8080"
,
"content-type"
:
"application/json"
,
"user-agent"
:
"curl/7.54.0"
,
"accept"
:
"*/*"
},
"method"
:
"post"
,
"request"
:{
"username"
:
"xyz"
,
"password"
:
"xyz"
},
"status"
:
200
,
"response"
:{
"username"
:
"xyz"
,
"password"
:
"xyz"
},
"responseheaders"
:{
"content-length"
:
"35"
,
"date"
:
"sun, 17 mar 2019 08:56:50 gmt"
,
"content-type"
:
"application/json;charset=utf-8"
}
}
|
当然打印出来是在一行中的,我进行了一下格式化。我们还可以在日志中增加请求的时间,耗费的时间以及异常信息等.
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我.
原文链接:https://segmentfault.com/a/1190000018535456 。
最后此篇关于SpringBoot记录Http请求日志的方法的文章就讲到这里了,如果你想了解更多关于SpringBoot记录Http请求日志的方法的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
据我了解,HTTP POST 请求的正文大小没有限制。因此,客户端可能会在一个 HTTP 请求中发送 千兆字节 的数据。现在我想知道 HTTP 服务器应该如何处理此类请求。 Tomcat 和 Jett
在了解Web Deploy我遇到了一些讨论 http://+:80 和 http://*:80 的 netsh.exe 命令。这些是什么意思? 最佳答案 引自URLPrefix Strings (Wi
假设我有一个负载均衡器,然后是 2 个 Web 服务器,然后是一个负载均衡器,然后是 4 个应用程序服务器。 HTTP 响应是否遵循与 HTTP 请求服务相同的路径? 最佳答案 按路径,我假设您是网络
我有一个带有 uri /api/books/122 的资源,如果在客户端为此资源发送 HTTP Delete 时该资源不存在,那么相应的响应代码是什么这个 Action ?是不是404 Not Fou
是否有特定的(或约定的)HTTP 响应消息(或除断开连接之外的其他操作)来阐明服务器不接受 pipelined HTTP requests ? 我正在寻找能让客户端停止流水线化它的请求并分别发送每个请
在了解Web Deploy我遇到了一些讨论 http://+:80 和 http://*:80 的 netsh.exe 命令。这些是什么意思? 最佳答案 引自URLPrefix Strings (Wi
我有一个带有 uri /api/books/122 的资源,如果在客户端为此资源发送 HTTP Delete 时该资源不存在,那么相应的响应代码是什么这个 Action ?是不是404 Not Fou
关闭。这个问题需要更多focused .它目前不接受答案。 想改进这个问题吗? 更新问题,使其只关注一个问题 editing this post . 关闭 8 年前。 Improve this qu
我使用 Mule 作为 REST API AMQP。我必须发送自定义请求方法:“PRINT”,但我收到: Status Code: 400 Bad Request The request could
我需要针对具有不同 HTTP 响应代码的 URL 测试我的脚本。我如何获取响应代码 300、303 或 307 等的示例/示例现有 URL? 谢谢! 最佳答案 您可以使用 httpbin为此目的。 例
我正在尝试编写一个程序来匹配 HTTP 请求及其相应的响应。似乎在大多数情况下一切都运行良好(当传输完全有序时,即使不是,通过使用 TCP 序列号)。 我发现的唯一问题是当我有流水线请求时。在那之后,
RESTful Web Services鼓励使用 HTTP 303将客户端重定向到资源的规范表示。它仅在 HTTP GET 的上下文中讨论主题。 这是否也适用于其他 HTTP 方法?如果客户端尝试对非
当使用chunked HTTP传输编码时,为什么服务器需要同时写出chunk的字节大小并且后续的chunk数据以CRLF结尾? 这不会使发送二进制数据“CRLF-unclean”和方法有点多余吗? 如
这个问题在这里已经有了答案: Is it acceptable for a server to send a HTTP response before the entire request has
如果我向同一台服务器发出多个 HTTP Get 请求并收到每个请求的 HTTP 200 OK 响应,我如何使用 Wireshark 判断哪个请求映射到哪个响应? 目前看起来像是发出了一个 http 请
func main() { http.HandleFunc("/", handler) } func handler(w http.ResponseWriter, r http.Request
我找不到有值(value)的 NodeJS with Typescript 教程,所以我在无指导下潜入水中,果然我有一个问题。 我不明白这两行之间的区别: import * as http from
问一个关于Are HTTP headers case-sensitive?的问题,如果 HTTP 方法区分大小写,大多数服务器如何处理“get”或“post”与“GET”或“POST”? 例如,看起来
我正在使用ASP.NET,在其中我通过动词GET接收查询,该应用程序专用于该URL。 该代码有效,但是如果用户发送的密码使http 200无效,请回答我,并在消息的正文中显示“Fail user or
Closed. This question needs details or clarity。它当前不接受答案。 想改善这个问题吗?添加详细信息,并通过editing this post阐明问题。 9
我是一名优秀的程序员,十分优秀!