我想在带有Kotlin的Spring WebFlux上的REST API中集中记录请求和响应。到目前为止,我已经尝试过这种方法
@Bean
fun apiRouter() = router {
(accept(MediaType.APPLICATION_JSON) and "/api").nest {
"/user".nest {
GET("/", userHandler::listUsers)
POST("/{userId}", userHandler::updateUser)
}
}
}.filter { request, next ->
logger.info { "Processing request $request with body ${request.bodyToMono<String>()}" }
next.handle(request).doOnSuccess { logger.info { "Handling with response $it" } }
}
此处请求方法和路径成功登录,但正文为Mono
,那么我应该如何记录呢?是否应该相反,我必须订阅请求正文Mono
并将其记录在回调中?另一个问题是ServerResponse
此处的接口无法访问响应主体。我怎么在这里买?
我尝试过的另一种方法是使用 WebFilter
@Bean
fun loggingFilter(): WebFilter =
WebFilter { exchange, chain ->
val request = exchange.request
logger.info { "Processing request method=${request.method} path=${request.path.pathWithinApplication()} params=[${request.queryParams}] body=[${request.body}]" }
val result = chain.filter(exchange)
logger.info { "Handling with response ${exchange.response}" }
return@WebFilter result
}
同样的问题在这里:请求正文是Flux
,没有响应正文。
是否可以通过某些过滤器访问完整的请求和响应以进行日志记录?我不明白什么
这或多或少类似于Spring MVC中的情况。
在Spring MVC中,您可以使用AbstractRequestLoggingFilter
过滤器和
ContentCachingRequestWrapper
和/或ContentCachingResponseWrapper
。这里有很多折衷:
ContentCaching*Wrapper
WebFlux中不存在类,但是您可以创建类似的类。但请记住以下几点:
DataBuffer
实例,这些实例(大约)是内存有效的字节数组。这些属于缓冲池,并被回收以用于其他交换。如果未正确保留/释放这些内存,则会造成内存泄漏(并且缓冲数据以供日后使用肯定适合这种情况)您问题的其他答案:
WebFilter
可能是最好的方法flatMap
根据要求将数据缓冲在doOn
运算符中