本文讲解如何在 Reactive 编程中正确使用 Mutiny 实现文件行的异步流式读取，强调避免 BufferedReader::readLine 等阻塞调用，并推荐基于 Vert.x Mutiny 绑定的非阻塞方案。
本文讲解如何在 reactive 编程中正确使用 mutiny 实现文件行的异步流式读取，强调避免 `bufferedreader::readline` 等阻塞调用，并推荐基于 vert.x mutiny 绑定的非阻塞方案。
在响应式编程中，直接将 BufferedReader::readLine 传给 Multi.createFrom() 是不可行且违背设计原则的——因为 readLine() 是同步阻塞方法，会挂起线程，彻底破坏 Mutiny 的非阻塞、背压感知与资源高效调度能力。Mutiny 的核心价值在于编排真正的异步、事件驱动的数据流，而非对传统阻塞 API 做语法糖式封装。
✅ 正确做法：使用 Vert.x Mutiny 文件系统 API
Vert.x 提供了完全异步、非阻塞的文件 I/O 支持，并通过 smallrye-mutiny-vertx-bindings 提供了原生 Mutiny 封装。以下是一个完整示例（需添加依赖）：
<!-- Maven 依赖 --> <dependency><groupid>io.smallrye.reactive</groupid><artifactid>smallrye-mutiny-vertx-file-system</artifactid><version>2.8.0</version><!-- 请根据 Quarkus 或 Vert.x 版本选择兼容版本 --></dependency>
import io.vertx.mutiny.core.Vertx;
import io.vertx.mutiny.ext.file.FileSystem;
import io.smallrye.mutiny.Uni;
import io.smallrye.mutiny.Multi;
public class FileLineReader {
private final FileSystem fs;
public FileLineReader(Vertx vertx) {
this.fs = vertx.fileSystem();
}
// 方式一：读取整个文件 → 按行分割（适合中小文件）
public Multi<string> readLinesBySplit(String filePath) {
return fs.readFile(filePath)
.onItem().transform(buffer -> buffer.toString("UTF-8"))
.onItem().transformToMulti(content -> Multi.createFrom().items(content.split("\n")));
}
// 方式二：流式逐块读取 + 行缓冲解析（推荐用于大文件，支持背压）
public Multi<string> readLinesAsStream(String filePath) {
return fs.open(filePath, new io.vertx.core.file.OpenOptions())
.onItem().transformToMulti(file ->
file.readLines() // ← Vert.x 原生返回 Multi<string>，真正异步、非阻塞、支持背压
);
}
}</string></string></string>
⚠️ 注意事项：
- ❌ 切勿使用
Multi.createFrom().emitter(e -> { ... BufferedReader ... })手动包装阻塞 I/O —— 这会导致线程池饥饿、响应延迟甚至服务崩溃； - ✅
file.readLines()是 Vert.x 的专用 API，底层基于事件循环和零拷贝缓冲区，自动处理换行符边界、编码与流控； - ? 默认使用 UTF-8 编码；如需指定编码，请确保文件系统配置或在
OpenOptions中设置（部分 Vert.x 版本需配合setEncoding("GBK")）； - ? 在 Quarkus 中，可直接注入
@Inject FileSystem fs，无需手动管理Vertx实例。
? 总结：
Mutiny 本身不提供文件 I/O 能力，它依赖于底层异步运行时（如 Vert.x）。要实现“响应式读取文件行”，必须选用真正异步的基础设施——Vert.x 的 FileSystem + Mutiny 绑定是当前最成熟、最符合 Reactive Principles 的标准方案。放弃阻塞思维，拥抱事件驱动，才能充分发挥 Mutiny 的并发优势与弹性伸缩能力。
