配置应用程序启动前发生的日志

Question

@SpringBootApplication
@ConfigurationPropertiesScan
class DemoApplication {

    companion object {
        @JvmStatic
        fun main(args: Array<String>) {

            val webClient = WebClient.builder().build()

            val data = webClient.get()
                .uri("http://localhost:8080/home")
                .retrieve()
                .bodyToMono(Response::class.java)
                .block()?.data

            SpringApplicationBuilder(DemoApplication::class.java).run(*args)
        }
    }
}

data class Response(val data: String)

14:10:16.944[reactor-http-nio-1]调试org.springframework.http.codec.json.jackson2jsondecoder-[4EF27D66]解码[响应(data=hello）]
14:10:16.944[reactor-http-nio-1]调试reactor.netty.resources.pooledconnectionprovider-[ID:0x9a13da08,L:/127.0.0.1:62737-R:localhost/127.0.0.1:8080]onStateChange（GET{uri=/home,62737-R:localhost/127.0.0.1:8080]}}，[response_completed])

我已经尝试通过在应用程序yaml中将它们的日志级别更改为info来禁用这些日志，如下所示，但这并不起作用，因为这种情况甚至发生在应用程序启动之前。

logging:
  level:
    org:
      springframework:
        web: info
        http:
          codec:
            json: info

是否有人有其他方法来禁用这些应用程序启动或webClient编解码器日志？

Answer 1

向web客户端添加自定义编解码器对我来说很有效。在这个自定义编解码器中，我正在反序列化响应。

这是自定义编解码器

class MyMessageReader: HttpMessageReader<Response> {
    override fun getReadableMediaTypes(): MutableList<MediaType> {
        return mutableListOf()
    }

    override fun canRead(elementType: ResolvableType, mediaType: MediaType?): Boolean {
        return true
    }

    override fun read(elementType: ResolvableType, message: ReactiveHttpInputMessage, hints: MutableMap<String, Any>): Flux<Response> {
        return Flux.just(Jackson2JsonDecoder().objectMapper.readValue(message.toString(), Response::class.java))
    }

    override fun readMono(elementType: ResolvableType, message: ReactiveHttpInputMessage, hints: MutableMap<String, Any>): Mono<Response> {
        return message.body.map {
            val count = it.readableByteCount()
            val str = ByteArray(count)
            var count1 = 0
            while (count1 < count) {
                str[count1] = it.read()
                count1++
            }

            Jackson2JsonDecoder().objectMapper.readValue(str, Response::class.java)
        }.toMono()
    }
}

将编解码器注册到web客户端：

WebClient.builder().codecs {
                it.customCodecs().register(MyMessageReader())
            }.build()

@SpringBootApplication
@ConfigurationPropertiesScan
class DemoApplication {

    companion object {
        @JvmStatic
        fun main(args: Array<String>) {

            val webClient = WebClient.builder().codecs {
                it.customCodecs().register(MyMessageReader())
            }.build()

            val data = webClient.get()
                .uri("http://localhost:8080/home")
                .retrieve()
                .bodyToMono(Response::class.java)
                .block()

            SpringApplicationBuilder(DemoApplication::class.java).run(*args)
        }
    }
}