spring-webflux中Flux<DataBuffer> 转String

灰太狼 2022-05-13 14:12 178阅读 0赞

Spring WebFlux既支持像Tomcat，Jetty这样的的传统容器（前提是支持Servlet 3.1 Non-Blocking IO API），又支持像Netty，Undertow那样的异步容器。不管是何种容器，Spring WebFlux都会将其输入输出流适配成Flux<DataBuffer>格式，以便进行统一处理。  
在使用SpringCloud-gateway时，在各个filter里，都有ServerWebExchange对象，exchange里面携带着用户的request，request里带着用户请求的数据。

![70][]

如果是Get请求传的参数，我们可以直接通过下图红框这样的方式获取参数的值，但是post请求的值就取不到了。

![70 1][]

post的值都封装在了 Flux<DataBuffer> 对象中，那么我们怎么将它转为可读的String呢？

Flux<DataBuffer> body = exchange.getRequest().getBody();
    
            body.subscribe(buffer -> {
                byte[] bytes = new byte[buffer.readableByteCount()];
                buffer.read(bytes);
                DataBufferUtils.release(buffer);
                try {
                    String bodyString = new String(bytes, "utf-8");
                    System.out.println(bodyString);
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
            });

这里面就是一种方式，post传的参数如下

![70 2][]

上面代码处理后的bodyString如下：

![70 3][]

还有一些其他的方式，如

AtomicReference<String> bodyRef = new AtomicReference<>();
            body.subscribe(buffer -> {
                CharBuffer charBuffer = StandardCharsets.UTF_8.decode(buffer.asByteBuffer());
                DataBufferUtils.release(buffer);
                bodyRef.set(charBuffer.toString());
            });
            //获取request body
            String bodyStr = bodyRef.get();
            System.out.println(bodyStr);

![70 4][]

大家可以去看一下DataBuffer的方法，里面有多个方法可以读取里面的值。

![70 5][]

[70]: /images/20220504/2167e4320d094951b3ac347bdb0e3b03.png
[70 1]: /images/20220504/f53e01180e3b4c1c8bf4d6a8362f1bf9.png
[70 2]: /images/20220504/ca0af2b7f8a24ff2a6c1006e3da6e9c2.png
[70 3]: /images/20220504/e6b75f5bf890499b881217a25b4f36fa.png
[70 4]: /images/20220504/7c17fd74482343cd9f0474af33d40316.png
[70 5]: /images/20220504/b75bfe55532a4b2b880e80f875e0ff3c.png