`
deepinmind
  • 浏览: 450787 次
  • 性别: Icon_minigender_1
  • 来自: 北京
博客专栏
1dc14e59-7bdf-33ab-841a-02d087aed982
Java函数式编程
浏览量:41551
社区版块
存档分类
最新评论

Java函数式编程(十四)监控文件修改

阅读更多

本系列文章译自Venkat Subramaniam的Functional Programming in Java

未完待续,后续文章请继续关注[url={{ site.url }}]Java译站[/url]。

使用flatMap列出子目录

前面已经看到如何列出指定目录下的文件了。我们再来看下如何遍历指定目录的直接子目录(深度为1),先实现一个简单的版本,然后再用更方便的flatMap()方法来实现。

我们先用传统的for循环来遍历一个指定的目录。如果子目录中有文件,就添加到列表里;否则就把子目录添加到列表里。最后,打印出所有文件的总数。代码在下面——这个是困难模式的。


public static void listTheHardWay() {

     List<File> files = new ArrayList<>();

     File[] filesInCurrentDir = new File(".").listFiles();

     for(File file : filesInCurrentDir) {

          File[] filesInSubDir = file.listFiles();

               if(filesInSubDir != null) {

                     files.addAll(Arrays.asList(filesInSubDir));

               } else {

                    files.add(file);

               }

      }

     System.out.println("Count: " + files.size())

}



我们先获取当前目录下的文件列表,然后进行遍历。对于每个文件,如果它有子文件,就把它们添加到列表中。这样做是没问题的,不过它有一些常见的问题:可变性,基本类型偏执,命令式,代码冗长,等等。一个叫flatMap()的小方法就可以解决掉这些问题。

正如这个名字所说的,这个方法在映射后会进行扁平化。它会像map()一样对集合中的元素进行映射。但是和map()方法不同的是,map()方法里面的lambda表达式只是返回一个元素,而这里返回的是一个Stream对象。于是这个方法将多个流压平,将里面的每个元素映射到一个扁平化的流中。

我们可以用flatMap()来执行各种操作,不过现在手头的这个问题就正好诠释了它的价值。每个子目录都有一个文件的列表或者说流,而我们希望获取当前目录下的所有子目录中的文件列表。

有一些目录可能是空的,或者说没有子元素。这种情况下,我们将这个空目录或者文件包装成一个流对象。如果我们想忽略某个文件,JDK中的flatMap()方法也可以很好的处理空文件;它会把一个空引用作为一个空集合合并到流里。来看下flatMap()方法的使用。


public static void betterWay() {

     List<File> files =

          Stream.of(new File(".").listFiles())

               .flatMap(file -> file.listFiles() == null ?

                    Stream.of(file) : Stream.of(file.listFiles()))

               .collect(toList());

     System.out.println("Count: " + files.size());

}



我们先是获取了当前目录的子文件流,然后调用了它的flatMap()方法。然后将一个lambda表达式传给这个方法,这个表达式会返回指定文件的子文件的流。flatMap()方法返回的的是当前目录所有子目录下的文件的集合。我们使用collect()方法以及Collectors里面的toList()(方法把它们收集到一个列表中。

我们传给flatMap()的这个lambda表达式,它返回的是一个文件的子文件。 如果没有的话,则返回这个文件的流。flatMap()方法优雅地将这个流映射到一个流的集合中,然后将这个集合扁平化,最终合并到一个流中。

flatMap()方法减少了许多开发的工作——它将两个连续的操作很好的结合到了一起,这通常称为元组 ——用一个优雅的操作就完成了。

我们已经知道如何使用flatMap()方法来将直接子目录中的所有文件列出来。下面我们来监控一下文件的修改操作。

监控文件修改

我们已经知道如何查找文件及目录,不过如果我们希望在文件创建,修改或删除的时候,能够接收到提示消息的话,这个也非常简单。这样的机制对于监视一些特殊文件比如配置文件,系统资源的改动非常有用。下面我们来探索下Java 7中引入的这个工具,WatchService,它可以用来监控文件的修改。下面我们看到的许多特性都来自JDK 7,而这里最大的改进就是内部迭代器带来的便利性。

我们先来写个监控当前目录中的文件修改的例子。JDK中的Path类会对应文件系统中的一个实例,它是一个观察者服务的工厂。我们可以给这个服务注册通知事件,就像这样:


inal Path path = Paths.get(".");

final WatchService watchService =

       path.getFileSystem()

           .newWatchService();

       path.register(watchService, StandardWatchEventKinds.ENTRY_MODIFY);

System.out.println("Report any file changed within next 1 minute...");



我们注册了一个WatchService来观察当前目录的修改。你可以轮询这个WatchService来获取目录下文件的修改操作,它会通过一个WatchKey将这些改动返回给我们。一旦我们拿到了这个key,可以遍历它的所有事件来获取文件更新的详细信息。因为可能会有多个文件被同时修改,poll操作可能会返回多个事件。来看下轮询以及遍历的代码。


final WatchKey watchKey = watchService.poll(1, TimeUnit.MINUTES);

if(watchKey != null) {

     watchKey.pollEvents()

          .stream()

          .forEach(event ->

               System.out.println(event.context()));

}



这里可以看到,Java 7和Java 8的特性同时出场了。我们把pollEvents()返回的集合转化成了一个Java 8的Stream,然后使用它的内部迭代器来打印出每个文件的详细的更新信息。

我们来运行下这段代码,然后将当前目录下的sample.txt文件修改一下,看下这个程序是否能察觉这个更新。


Report any file changed within next 1 minute...

sample.txt



当我们修改了这个文件的时候,程序会提示说文件被修改了。我们可以用这个功能来监视不同文件的更新,然后执行相应的任务。当然我们也可以只注册文件新建或者删除的操作。

总结

有了lambda表达式和方法引用后,像字符串及文件的操作,创建自定义比较器这些常见的任务都变得更简单也更简洁了。匿名内部类也变得优雅起来了,而可变性就像日出后的晨雾一样,也消失得无影无踪了。使用这种新风格进行编码还有一个福利,就是你可以使用JDK的新设施来高效地遍历庞大的目录。

现在你已经知道如何创建lambda表达式并把它传递给方法了。下一章我们会介绍如何使用函数式接口及lambda表达式进行软件的设计。


未完待续,后续文章请继续关注[url={{ site.url }}]Java译站[/url]。

原创文章转载请注明出处:http://it.deepinmind.com
5
2
分享到:
评论

相关推荐

    Java函数式编程(十二):监控文件修改

    总的来说,Java函数式编程提供了更简洁、可读性更强的代码,而文件监控功能则让我们能够在文件系统发生变化时采取相应的行动。通过结合这两者,我们可以编写出优雅且功能强大的文件系统监控程序。

    java编程技巧典型案例解析

    7. Lambda表达式与函数式编程 - Lambda表达式的语法:理解其简洁的语法,以及如何替代匿名内部类。 - 函数式接口:Supplier、Consumer、Function等接口的应用。 - Stream API:流式编程,如何使用map、filter、...

    java编程常用单词

    18. **Lambda表达式(Lambda Expression)**:Java 8引入的新特性,简化了函数式编程,使代码更加简洁。 19. **Stream API(Stream API)**:Java 8提供的新API,用于处理集合和数组,支持高效的并行操作。 20. **...

    core java 1第十版英文版 java核心技术第十版英文版

    11. **Lambda表达式**:介绍Java 8引入的函数式编程特性,如何使用Lambda简化代码,以及Stream API的运用。 12. **模块系统**:讲解Java 9引入的模块系统,如何组织和管理代码模块。 13. **JVM内存模型**:探讨...

    Java JDK 8.202 window 64位

    1. **Java 8核心特性**:此版本基于Java 8,引入了多项重要特性,如Lambda表达式、函数式编程接口、Stream API、新的日期与时间API(java.time包)以及Optional类等。Lambda表达式使得代码更简洁,提高了代码的...

    java jdk1.8 Linux版本

    Java 1.8是Java的重大更新,引入了Lambda表达式、函数式编程支持、新日期时间API(java.time包)以及Stream API等重要特性。Lambda表达式使得编写简洁的匿名函数成为可能,提高了代码的可读性和效率。新的日期时间...

    Java SE 8u251 Linux安装包

    Java SE 8引入了一些重要的新特性,比如Lambda表达式,它简化了处理函数式编程任务的方式;新的日期和时间API(java.time包)提供了更强大和灵活的日期处理功能;方法引用和默认方法增强了接口的使用。此外,还增强...

    JAVA上百实例源码以及开源项目源代码

    Java圆形电子时钟源代码 1个目标文件 内容索引:JAVA源码,系统相关,电子钟 用JAVA编写的指针式圆形电子钟,效果图如下所示,其实代码很简单,希望对你有帮助。 Message-Driven Bean EJB实例源代码 2个目标文件 摘要:...

    java开源包6

    BoneCP很小,只有四十几K(运行时需要slf4j和guava的支持,这二者加起来就不小了),而相比之下 C3P0 要六百多K。 异步输出框架 AsynWriter 一个Java的类库,用于异步输出记录的简单小框架用于高并发下数据输出使用...

    java开源包4

    BoneCP很小,只有四十几K(运行时需要slf4j和guava的支持,这二者加起来就不小了),而相比之下 C3P0 要六百多K。 异步输出框架 AsynWriter 一个Java的类库,用于异步输出记录的简单小框架用于高并发下数据输出使用...

    java开源包9

    BoneCP很小,只有四十几K(运行时需要slf4j和guava的支持,这二者加起来就不小了),而相比之下 C3P0 要六百多K。 异步输出框架 AsynWriter 一个Java的类库,用于异步输出记录的简单小框架用于高并发下数据输出使用...

    java开源包101

    BoneCP很小,只有四十几K(运行时需要slf4j和guava的支持,这二者加起来就不小了),而相比之下 C3P0 要六百多K。 异步输出框架 AsynWriter 一个Java的类库,用于异步输出记录的简单小框架用于高并发下数据输出使用...

    Java U盘检测小程序

    Java U盘检测小程序是一种利用Java编程语言开发的小型应用程序,主要功能是监控并检测接入到计算机的U盘设备。这个程序的设计理念是为了提供一个简单易用的工具,帮助用户了解和管理他们的U盘设备。通过使用线程技术...

    java开源包5

    BoneCP很小,只有四十几K(运行时需要slf4j和guava的支持,这二者加起来就不小了),而相比之下 C3P0 要六百多K。 异步输出框架 AsynWriter 一个Java的类库,用于异步输出记录的简单小框架用于高并发下数据输出使用...

    java开源包8

    BoneCP很小,只有四十几K(运行时需要slf4j和guava的支持,这二者加起来就不小了),而相比之下 C3P0 要六百多K。 异步输出框架 AsynWriter 一个Java的类库,用于异步输出记录的简单小框架用于高并发下数据输出使用...

    java-1.8.0-openjdk.linux.x86_64

    此外,它还提供了Lambda表达式、函数式接口、Stream API、Optional类等Java 8的新特性,这些特性极大地提升了代码的简洁性和可读性,使得编程更加高效。 对于Linux x86_64架构,这个版本的OpenJDK优化了64位系统上...

    java开发工具,jdk1.8

    在JDK1.8中,Java语法已经发展到支持Lambda表达式,增强了函数式编程的能力。 3. **Java虚拟机JVM**: JVM是Java程序运行的核心,它负责解释并执行字节码,实现了“一次编写,到处运行”的跨平台特性。JDK1.8的JVM...

    java开源包10

    BoneCP很小,只有四十几K(运行时需要slf4j和guava的支持,这二者加起来就不小了),而相比之下 C3P0 要六百多K。 异步输出框架 AsynWriter 一个Java的类库,用于异步输出记录的简单小框架用于高并发下数据输出使用...

    java开源包1

    BoneCP很小,只有四十几K(运行时需要slf4j和guava的支持,这二者加起来就不小了),而相比之下 C3P0 要六百多K。 异步输出框架 AsynWriter 一个Java的类库,用于异步输出记录的简单小框架用于高并发下数据输出使用...

    java开源包3

    BoneCP很小,只有四十几K(运行时需要slf4j和guava的支持,这二者加起来就不小了),而相比之下 C3P0 要六百多K。 异步输出框架 AsynWriter 一个Java的类库,用于异步输出记录的简单小框架用于高并发下数据输出使用...

Global site tag (gtag.js) - Google Analytics