为什么我在将mono映射到mono时会收到一个空字符串？

Question

我正在使用Spring WebFlux开发一个API REST,但在上传文件时遇到了问题。它们被存储了，但我没有得到预期的返回值。

我就是这么做的：

1. 接收通量
2. 将部件强制转换为文件部件。
3. 使用transferTo（）保存零件（这返回一个单声道 )
4. 使用文件名将Mono 映射到Mono 。
5. 向客户端返回通量 。

@PostMapping(value = "/muscles/{id}/image")
public Flux<String> updateImage(@PathVariable("id") String id, @RequestBody Flux<Part> file) {
    log.info("REST request to update image to Muscle");
    return storageService.saveFiles(file);
}

存储服务

public Flux<String> saveFiles(Flux<Part> parts) {
    log.info("StorageService.saveFiles({})", parts);
    return
            parts
            .filter(p -> p instanceof FilePart)
            .cast(FilePart.class)
            .flatMap(file -> saveFile(file));
}

private Mono<String> saveFile(FilePart filePart) {
    log.info("StorageService.saveFile({})", filePart);
    String filename = DigestUtils.sha256Hex(filePart.filename() + new Date());
    Path target = rootLocation.resolve(filename);
    try {
        Files.deleteIfExists(target);
        File file = Files.createFile(target).toFile();

        return filePart.transferTo(file)
                .map(r -> filename);
    } catch (IOException e) {
        throw new RuntimeException(e);
    }
}

Answer 1

filepart.transferTo()返回mono ，它在操作完成时发出信号-这意味着反应型发布服务器将只发布oncomplete/onerror信号，而在此之前永远不会发布值。

这意味着map操作从未执行过，因为它只是源发布的给定元素。

您可以返回文件的名称，仍然可以使用链式反应运算符，如下所示：

return part.transferTo(file).thenReturn(part.filename());