Spring应用中FilePart转换为ByteArray触发阻塞报错如何处理？

待排查代码：

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

报错信息：

java.lang.IllegalStateException: block()/blockFirst()/blockLast() are blocking, which is not supported in thread reactor-http-kqueue-3

该问题出现在Spring WebFlux响应式开发场景下：Reactor框架为了保障非阻塞IO线程的运行效率，默认禁止在Reactor网络线程（即报错信息中前缀为reactor-http-的线程）中调用block()、blockLast()这类会阻塞线程的方法，避免网络线程被阻塞导致整体服务吞吐量大幅下降。你代码中直接调用blockLast()同步等待响应式流返回结果，触发了Reactor的线程保护机制，因此抛出该异常。

方案1：全响应式处理（推荐） #

全程使用非阻塞的响应式操作符处理，不需要调用阻塞方法，符合WebFlux的设计规范，性能最优：

val byteArrayMono: Mono<ByteArray> = file.content()
    // 把所有DataBuffer的内容合并到输出流
    .reduce(ByteArrayOutputStream()) { outputStream, dataBuffer ->
        outputStream.write(dataBuffer.asInputStream().readBytes())
        outputStream
    }
    // 输出流转ByteArray
    .map { it.toByteArray() }

后续可以直接基于返回的Mono<ByteArray>拼接业务逻辑，比如文件解析、持久化等操作，全程保持非阻塞。

方案2：阻塞获取ByteArray（仅适配特殊场景） #

如果业务场景必须拿到实际的ByteArray实例，需要将阻塞操作切换到专门的业务弹性线程池执行，避免占用Reactor网络线程：

val byteArray: ByteArray = file.content()
    .reduce(ByteArrayOutputStream()) { outputStream, dataBuffer ->
        outputStream.write(dataBuffer.asInputStream().readBytes())
        outputStream
    }
    .map { it.toByteArray() }
    // 切换到Reactor提供的弹性业务线程池执行后续操作
    .subscribeOn(Schedulers.boundedElastic())
    .block()!!

注意：方案2仅允许在脱离Reactor网络线程的场景使用，生产环境优先选择方案1的全响应式实现。

内容的提问来源于stack exchange，提问作者Manish Bansal