問(wèn)題描述

在自建Filter中如何獲取完整的request.body信息？

問(wèn)題出現(xiàn)的環(huán)境背景及自己嘗試過(guò)哪些方法

在學(xué)習(xí)Spring Cloud Gateway自己寫filter時(shí)，嘗試通過(guò)exchange.getRequest().getBody獲得請(qǐng)求消息體，但是出現(xiàn)無(wú)法獲得完整消息體內(nèi)容的問(wèn)題，想請(qǐng)各位大神幫忙看看問(wèn)題出在哪？應(yīng)該如何調(diào)整？非常感謝。

相關(guān)代碼

// 請(qǐng)把代碼文本粘貼到下方（請(qǐng)勿用圖片代替代碼）

@Component
public class PreGatewayFilterFactory extends AbstractGatewayFilterFactory<Object> {


    @Override
    public GatewayFilter apply(Object config) {
        // grab configuration from Config object
        return (exchange, chain) -> {
            //If you want to build a "pre" filter you need to manipulate the
            //request before calling change.filter

            //嘗試1，直接通過(guò)操作Flux打印body內(nèi)容，但是打印結(jié)果不完整，只有部分消息報(bào)文
            ServerHttpRequest request = exchange.getRequest();
            Flux<DataBuffer> dataFlux = request.getBody();

            StringBuffer buffer = new StringBuffer();

            dataFlux.log().flatMap(dataBuffer -> {
                System.out.println("Thread - " + Thread.currentThread().getName() + ": readable count is  " +  dataBuffer.readableByteCount());
                byte[] bytes = new byte[dataBuffer.readableByteCount()];
                dataBuffer.read(bytes);
                DataBufferUtils.release(dataBuffer);
                return Mono.just(bytes);
            }).subscribe(s -> System.out.println(new String(s)));

             //嘗試2，使用DefaultServerRequest封裝后，通過(guò)BodyExtractors轉(zhuǎn)換Mono<String>后打印，但是依然打印結(jié)果只有部分消息報(bào)文
            /*DefaultServerRequest request = new DefaultServerRequest(exchange);
            request.body(BodyExtractors.toMono(String.class)).log().subscribe(System.out::print);*/

            //use builder to manipulate the request
            ServerHttpResponse response = exchange.getResponse();
            return response.writeWith(Mono.empty());
        };
    }
}

你期待的結(jié)果是什么？實(shí)際看到的錯(cuò)誤信息又是什么？

請(qǐng)大家?guī)兔纯次姨幚磉^(guò)程中問(wèn)題出在了哪？應(yīng)該如何修正？非常感謝！