如何在Java中实现等待文件修改后再读取数据的功能？-阿里云开发者社区

如何在Java中实现等待文件修改后再读取数据的功能？

2024-05-02 52

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 如何在Java中实现等待文件修改后再读取数据的功能？

文件是计算机系统中重要的存储媒介，常用于存储数据和程序。在Java中，文件操作是非常常见的操作之一。有时候，我们需要在文件被修改后再读取其中的数据，但是文件是一直存在的，并不能通过是否生成去判断，这就需要我们在Java中实现等待文件修改后再读取数据的功能。本文将介绍如何使用Java实现该功能。

一、问题描述

这段代码的作用是将一个Excel表格中的数据提取出来，并以字符串的形式返回。具体实现过程如下：

根据传入的exePath和tagerPath参数构造出一个命令行字符串，该命令行字符串用于调用外部程序，将Excel表格中的数据提取到一个文本文件中。
调用Java的Runtime.getRuntime().exec()方法来执行上述命令行字符串，返回一个Process实例，该实例可用来控制进程并获得相关信息。
读取刚才生成的文本文件中的数据，并将其存储到一个字符数组中。
将字符数组中的数据转换成字符串，并返回该字符串。
在finally块中关闭文件流。

E:\ftpTest\data.txt文件文件是一直存在的，并不能通过是否生成去判断，怎么样才能等data.txt文件被exec(run)修改完后再执行读取数据？

public static String tableToBin(String exePath, String tagerPath) {
        String dataPath = "E:\\ftpTest\\data.txt";
        Reader fr = null;
        int length = 0;
        char ch[] = null;
        // Excel.exe test_read.xlsx 文件路径
        String run = exePath + " " + " " + tagerPath + " " + dataPath;
        try {
            //解释：Runtime.getRuntime().exec()方法返回一个Process实例，该实例可用来控制进程并获得相关信息。
            Process proc = Runtime.getRuntime().exec(run);
            System.out.println("读取表格并提取数据完成");
            //读取数据
            fr = new FileReader(dataPath);
            //ch[]数组存放读取的数据
            ch = new char[1024];
            //length为读取的数据长度
            length = fr.read(ch);
            //返回读取的数据
            return new String(ch, 0, length);
        } catch (IOException e) {
            //抛出运行时异常
            throw new RuntimeException(e);
        } finally {
            try {
                //关闭流
                fr.close();
            } catch (IOException e) {
                //抛出运行时异常
                throw new RuntimeException(e);
            }
        }
    }

二、问题分析

如果文件是一直存在的，那么可以通过比较文件的修改时间来判断文件是否更新。可以使用Java的File类的lastModified()方法获取文件的最后修改时间，然后将其与上一次检查时的时间进行比较。如果文件的最后修改时间比上一次检查时的时间要晚，那么说明文件已经更新，可以执行发送数据的代码。你可以在一个循环中不断检查文件是否更新，如果文件更新了就执行发送数据的代码。

三、解决方案

1. 使用Java的File类的lastModified()方法

使用Java的File类的lastModified()方法获取文件的最后修改时间，然后将其与上一次检查时的时间进行比较。如果文件的最后修改时间比上一次检查时的时间要晚，那么说明文件已经更新，可以执行读取数据的代码。

示例代码：

public static String tableToBin(String exePath, String tagerPath) {
    String dataPath = "E:\\ftpTest\\data.txt";
    Reader fr = null;
    int length = 0;
    char ch[] = null;
    long lastModified = 0;
    boolean fileUpdated = false;
    // Excel.exe test_read.xlsx 文件路径
    String run = exePath + " " + " " + tagerPath + " " + dataPath;
    try {
        //解释：Runtime.getRuntime().exec()方法返回一个Process实例，该实例可用来控制进程并获得相关信息。
        Process proc = Runtime.getRuntime().exec(run);
        //等待文件生成
        while(!fileUpdated) {
            File file = new File(dataPath);
            long currentModified = file.lastModified();
            if(currentModified > lastModified) {
                lastModified = currentModified;
                Thread.sleep(1000); //等待1秒
            } else {
                fileUpdated = true;
            }
        }
        //读取数据
        fr = new FileReader(dataPath);
        //ch[]数组存放读取的数据
        ch = new char[1024];
        //length为读取的数据长度
        length = fr.read(ch);
        //返回读取的数据
        return new String(ch, 0, length);
    } catch (IOException e) {
        //抛出运行时异常
        throw new RuntimeException(e);
    } catch (InterruptedException e) {
        //抛出运行时异常
        throw new RuntimeException(e);
    } finally {
        try {
            //关闭流
            fr.close();
        } catch (IOException e) {
            //抛出运行时异常
            throw new RuntimeException(e);
        }
    }
}

在这个示例代码中，我们将文件的最后修改时间与上一次检查时的时间进行比较，如果文件的最后修改时间比上一次检查时的时间要晚，那么说明文件已经更新，可以执行读取数据的代码。如果文件还没有更新，我们使用Java的Thread.sleep()方法等待一段时间，然后再次检查文件的最后修改时间。当文件的最后修改时间不再更新时，我们退出等待循环，执行读取数据的代码。

2. 使用Java的WatchService类

Java的WatchService类可以用于监控文件的变化，并在文件发生变化后再读取数据。使用WatchService类需要创建一个WatchService实例，并将其注册到需要监控的目录上。当目录中的文件发生变化时，WatchService会接收到通知，我们可以在通知中执行读取数据的代码。

示例代码：

public static String readFileAfterUpdate(String filePath) {
    Reader fr = null;
    int length = 0;
    char ch[] = null;
    try {
        //创建WatchService实例
        WatchService watchService = FileSystems.getDefault().newWatchService();
        //将目录注册到WatchService中
        Path path = Paths.get(filePath).getParent();
        path.register(watchService, StandardWatchEventKinds.ENTRY_MODIFY);
        //等待目录中的文件发生变化
        WatchKey watchKey = watchService.take();
        while(watchKey != null) {
            for(WatchEvent<?> event : watchKey.pollEvents()) {
                //如果文件发生变化
                if(event.kind() == StandardWatchEventKinds.ENTRY_MODIFY && event.context().toString().equals(Paths.get(filePath).getFileName().toString())) {
                    //读取数据
                    fr = new FileReader(filePath);
                    ch = new char[1024];
                    length = fr.read(ch);
                    return new String(ch, 0, length);
                }
            }
            watchKey.reset();
            watchKey = watchService.take();
        }
        return null;
    } catch (IOException e) {
        throw new RuntimeException(e);
    } catch (InterruptedException e) {
        throw new RuntimeException(e);
    } finally {
        try {
            fr.close();
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }
}