-1

我有一项将图片上传到服务器的服务。我在这个服务上使用了 Java Spring Reactive，我用 dateformat 重命名了文件，并且需要返回这个新名称。这就是我在服务中所做的：

@Override
public Mono<String> createImage(Flux<FilePart> files) {
    Date date = new Date();
    SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH-mm-ss");
    final String[] fileName = {""};

    return files.flatMap(file -> {
        Mono<Void> copyFile = Mono.just(Paths.get(UPLOAD_ROOT, dateFormat.format(date) + "." + FilenameUtils.getExtension(file.filename())).toFile())
                .log("createImage-picktarget").map(destFile -> {
                    try {
                        fileName[0] = dateFormat.format(date) + "." + FilenameUtils.getExtension(file.filename());
                        destFile.createNewFile();
                        return destFile;
                    } catch (IOException ioe) {
                        throw new RuntimeException(ioe);
                    }
                }).log("createImage-newFile").flatMap(file::transferTo).log("createImage-copy");

        return Mono.when(copyFile).log("createImage-when");
    }).log("createImage-flatMap").then(Mono.just(fileName[0])).log("createImage-done");
}

此代码将 Mono 返回给我的控制器。在此控制器中，我需要将 Mono 中的字符串返回给客户端，因为此字符串包含前端所需的新上传文件名。这是我的控制器：

@PostMapping(value = "/upload")
public Mono<String> createFile(@RequestPart(name = "file")Flux<FilePart> files){
    Mono<String> saveImage = nasabahService.createImage(files);

    return saveImage.flatMap(value -> Mono.just(value));

}

我的问题是，如何从 Mono 中获取 createImage 函数返回的字符串，以便将其发送给客户端？

谢谢你的帮助。

4

1 回答 1

0

首先，如果你想构建一个响应式服务，你应该返回一个 Mono 对象并让 spring 使用 SSE（服务器发送事件）以非阻塞方式将字符串传递到前面。无论如何，我不明白你为什么要做最后一个平面图，你可以直接从控制器返回 saveImage 。

如果您确实需要返回字符串而不是单声道对象，则必须阻止它并使用 Mono API 中的 .block() 方法获取结果

于 2019-11-12T08:11:01.640 回答