Advertisement

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();
    }
    
    
      
      
      
      
      
      
    

以下为具体运行所得的结果展示

![在这里插入图片描述](https://cdl.itadn.

全部评论 (0)

还没有任何评论哟~