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

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

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

一、问题描述

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

  1. 根据传入的exePath和tagerPath参数构造出一个命令行字符串,该命令行字符串用于调用外部程序,将Excel表格中的数据提取到一个文本文件中。
  2. 调用Java的Runtime.getRuntime().exec()方法来执行上述命令行字符串,返回一个Process实例,该实例可用来控制进程并获得相关信息。
  3. 读取刚才生成的文本文件中的数据,并将其存储到一个字符数组中。
  4. 将字符数组中的数据转换成字符串,并返回该字符串。
  5. 在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);
        }
    }
}

在这个示例代码中,我们创建了一个WatchService实例,并将需要监控的目录注册到WatchService中。当目录中的文件发生变化时,WatchService会接收到通知,我们可以在通知中执行读取数据的代码。注意,我们需要在通知中判断文件是否为需要读取的文件。


目录
相关文章
|
3天前
|
Java
【Java开发指南 | 第二十一篇】Java流之文件
【Java开发指南 | 第二十一篇】Java流之文件
12 0
|
22小时前
|
数据采集 前端开发 Java
基于Java爬取微博数据(一)
【5月更文挑战第9天】讲述如何通过 Java 爬取微博数据,以及相应的注意点
|
1天前
|
消息中间件 Java Kafka
Java大文件排序(有手就能学会),kafka面试题2024
Java大文件排序(有手就能学会),kafka面试题2024
|
3天前
|
安全 Java 开发者
Java一分钟之-文件与目录操作:Path与Files类
【5月更文挑战第13天】Java 7 引入`java.nio.file`包,`Path`和`Files`类提供文件和目录操作。`Path`表示路径,不可变。`Files`包含静态方法,支持创建、删除、读写文件和目录。常见问题包括:忽略异常处理、路径解析错误和权限问题。在使用时,注意异常处理、正确格式化路径和考虑权限,以保证代码稳定和安全。结合具体需求,这些方法将使文件操作更高效。
11 2
|
3天前
|
SQL Java
java处理数据查看范围
java处理数据查看范围
|
3天前
|
Java 开发者
Java一分钟之-Java IO流:文件读写基础
【5月更文挑战第10天】本文介绍了Java IO流在文件读写中的应用,包括`FileInputStream`和`FileOutputStream`用于字节流操作,`BufferedReader`和`PrintWriter`用于字符流。通过代码示例展示了如何读取和写入文件,强调了常见问题如未关闭流、文件路径、编码、权限和异常处理,并提供了追加写入与读取的示例。理解这些基础知识和注意事项能帮助开发者编写更可靠的程序。
17 0
|
3天前
|
Java
JDK环境下利用记事本对java文件进行运行编译
JDK环境下利用记事本对java文件进行运行编译
16 0
|
3天前
|
数据采集 机器学习/深度学习 Java
数据猎手:使用Java和Apache HttpComponents库下载Facebook图像
本文介绍了如何使用Java和Apache HttpComponents库从Facebook获取图像数据。通过设置爬虫代理IP以避免限制,利用HttpClient发送请求,解析HTML找到图像链接,然后下载并保存图片。提供的Java代码示例展示了实现过程,包括创建代理配置、线程池,以及下载图片的逻辑。注意,实际应用需根据Facebook页面结构进行调整。
数据猎手:使用Java和Apache HttpComponents库下载Facebook图像
|
Java 大数据 Apache