Reactor 3 (7): 处理 I/O
发布时间
阅读量:
阅读量
无论采用webflux框架还是reactor框架,在实际应用过程中均存在需要访问文件以获取数据的情形。以下将简要说明reactor框架中实现文件读写操作的方式:
在项目目录中创建一个名为info.txt的文件,并在其中随意输入一些内容:

Mono文件读取机制
- mono支持通过可调用对象实现文件读取功能
- 由于mono元素的数量限制为0或1个,此处采用Files类中的readAllLines方法来获取列表数据
@Test
public void monoRead() {
Mono.fromCallable(()-> Files.readAllLines(Paths.get("info.txt")))
.log()
.subscribe();
}
以下为具体运行所得的结果展示

还没有任何评论哟~
