将filepart转换为byteArray

Question

在我的spring应用程序中，我正在获取FilePart对象，并需要将其转换为byteArray。

以下是我的代码。

val byteArray: ByteArray = file.content().map { it -> it.asInputStream().readBytes() }.blockLast()!!

但它给了我错误

非法状态异常： 块 （）/块第一（）/块最后 （） 正在阻塞，这在线程反应器中不受支持

Answer 1

看看DataBufferUtils，连接（…）方法提供了一种安全有效的方法来将数据缓冲流聚合到单个数据缓冲区中

Mono<byte[]> getByteArray(FilePart filePart) {
    return DataBufferUtils.join(filePart.content())
                          .map(dataBuffer -> dataBuffer.asByteBuffer().array());
}