如何在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会接收到通知,我们可以在通知中执行读取数据的代码。注意,我们需要在通知中判断文件是否为需要读取的文件。


目录
相关文章
|
6月前
|
Java API 开发工具
【Azure Developer】Java代码实现获取Azure 资源的指标数据却报错 "invalid time interval input"
在使用 Java 调用虚拟机 API 获取指标数据时,因本地时区设置非 UTC,导致时间格式解析错误。解决方法是在代码中手动指定时区为 UTC,使用 `ZoneOffset.ofHours(0)` 并结合 `withOffsetSameInstant` 方法进行时区转换,从而避免因时区差异引发的时间格式问题。
321 4
|
7月前
|
数据采集 JSON Java
Java爬虫获取1688店铺所有商品接口数据实战指南
本文介绍如何使用Java爬虫技术高效获取1688店铺商品信息,涵盖环境搭建、API调用、签名生成及数据抓取全流程,并附完整代码示例,助力市场分析与选品决策。
|
7月前
|
安全 Java API
Java中的Lambda表达式:简洁与功能的结合
Java中的Lambda表达式:简洁与功能的结合
514 211
|
7月前
|
数据采集 存储 前端开发
Java爬虫性能优化:多线程抓取JSP动态数据实践
Java爬虫性能优化:多线程抓取JSP动态数据实践
|
7月前
|
JavaScript Java 微服务
现代化 Java Web 在线商城项目技术方案与实战开发流程及核心功能实现详解
本项目基于Spring Boot 3与Vue 3构建现代化在线商城系统,采用微服务架构,整合Spring Cloud、Redis、MySQL等技术,涵盖用户认证、商品管理、购物车功能,并支持Docker容器化部署与Kubernetes编排。提供完整CI/CD流程,助力高效开发与扩展。
803 64
|
5月前
|
Java Unix Go
【Java】(8)Stream流、文件File相关操作,IO的含义与运用
Java 为 I/O 提供了强大的而灵活的支持,使其更广泛地应用到文件传输和网络编程中。!但本节讲述最基本的和流与 I/O 相关的功能。我们将通过一个个例子来学习这些功能。
251 1
|
6月前
|
算法 Java
Java多线程编程:实现线程间数据共享机制
以上就是Java中几种主要处理多线程序列化资源以及协调各自独立运行但需相互配合以完成任务threads 的技术手段与策略。正确应用上述技术将大大增强你程序稳定性与效率同时也降低bug出现率因此深刻理解每项技术背后理论至关重要.
449 16
|
6月前
|
存储 数据可视化 Java
Java Stream API 的强大功能
Java Stream API 是 Java 8 引入的重要特性,它改变了集合数据的处理方式。通过声明式语法,开发者可以更简洁地进行过滤、映射、聚合等操作。Stream API 支持惰性求值和并行处理,提升了代码效率和可读性,是现代 Java 开发不可或缺的工具。
134 0
Java Stream API 的强大功能
|
7月前
|
前端开发 JavaScript Java
Java 项目实战城市公园信息管理系统开发流程与实用功能实现指南
本系统基于Java开发,采用Spring Boot后端框架与Vue.js前端框架,结合MySQL数据库,构建了一个高效的城市公园信息管理系统。系统包含管理员、用户和保洁人员三大模块,涵盖用户管理、园区信息查询、订票预约、服务管理等功能,提升公园管理效率与服务质量。
221 6
|
7月前
|
安全 Java 数据库
Java 项目实战病人挂号系统网站设计开发步骤及核心功能实现指南
本文介绍了基于Java的病人挂号系统网站的技术方案与应用实例,涵盖SSM与Spring Boot框架选型、数据库设计、功能模块划分及安全机制实现。系统支持患者在线注册、登录、挂号与预约,管理员可进行医院信息与排班管理。通过实际案例展示系统开发流程与核心代码实现,为Java Web医疗项目开发提供参考。
367 2