如何使用spring webflux上传和读取文本文件？

Question

我需要上传一个文件并读取内容，使用spring mvc很容易，但使用spring webflux，我不知道如何处理FilePart和DataBuffer流量

我期待着这样的回报：

    @PostMapping("/upload")
    fun readFile(@RequestPart("file", required = true) file: Mono<FilePart>): Mono<ResponseEntity<String>> {
        return Mono.just("my text content")
                .map {
                    ResponseEntity.ok()
                            .body(it)
                }
    }

Answer 1

我使用以下代码使其工作：

    @PostMapping("/upload")
fun readFile(@RequestPart("file", required = true) file: Mono<FilePart>): Mono<ResponseEntity<String>> {

    return file.flatMap {
        it.content().map { dataBuffer ->
            IOUtils.inputStreamAsString(dataBuffer.asInputStream(), "UTF-8")
        }.toMono()
    }.map {
        ResponseEntity.ok()
                .body(it)
    }
}