无法将 Part 的内容 (Flux<DataBuffer>) 读入单个字符串

Question

在下面的 sn-p 中，我尝试使用 Spring 的 Part 对象提取文件的内容（发送到给定的服务）并将其转换为字符串。

问题是它跳过了映射器函数，并且映射器函数内的代码不会像 filePartMono 的内容为空一样执行，但是当我在运行时检查对象时，它的存储字段具有文件的数据。

public void parseFilePart(Part filePartMono) {
    filePartMono.content().map(dataBuffer -> {
            byte[] bytes = new byte[dataBuffer.readableByteCount()];
            dataBuffer.read(bytes);
            DataBufferUtils.release(dataBuffer);
            String fileContent = new String(bytes, StandardCharsets.UTF_8);
        });
}

Answer 1

org.springframework.http.codec.multipart.Part.content() 返回Flux<DataBuffer>，这意味着在您订阅此Publisher 之前不会发生任何事情。

如果您的代码可以以阻塞方式执行而不会导致错误，您可以这样重构它以获得 String 结果：

public void parseFilePart(Part filePartMono) {
  List<String> parts = 
    filePartMono.content()
    .map(dataBuffer -> {
          byte[] bytes = new byte[dataBuffer.readableByteCount()];
          dataBuffer.read(bytes);
          DataBufferUtils.release(dataBuffer);
          return new String(bytes, StandardCharsets.UTF_8);
    })
    .collectList()
    .block();
  //do what you want here with the Strings you retrieved
}

如果您确定Flux<DataBuffer> 将始终发出1 个DataBuffer，您可以将.collectList().block() 替换为.blockFirst() 并获得String 结果而不是List<String>。

如果你的代码不能以阻塞方式执行，那么你可以这样重构它：

public void parseFilePart(Part filePartMono) {
    filePartMono.content()
    .map(dataBuffer -> {
          byte[] bytes = new byte[dataBuffer.readableByteCount()];
          dataBuffer.read(bytes);
          DataBufferUtils.release(dataBuffer);
          return new String(bytes, StandardCharsets.UTF_8);
    })
    .subscribe(resultString -> {
      //do what you want with the result String here
    });
}

附注我没有测试您的实现以将DataBuffer 转换为String，因此您现在可能需要仔细检查它是否已被实际调用