java - 使用 java 在特定时间找不到文件时发送警报邮件

Question

如果文件在指定时间后不存在或在某个位置未修改，我会尝试向用户发送警报邮件。对于前。我正在 C:\Users\Desktop 位置寻找文件 MASTER.csv。如果自昨晚以来该文件在巴黎时间凌晨 4:00 之后没有更改或不存在于上述位置，那么它将向用户发送一封警报邮件，通知他们我们尚未按照商定的 SLA 收到该文件。

对于邮件发送，我编写了该类，但无法弄清楚如果文件不存在或未更改，如何在指定时间触发该类。

我编写了一个观察程序类，它检查文件何时出现在上述位置，然后它将调用其他类，但反之则不然。

public class FileWatchDemo {
        public static void main(String[] args) {
            try {
                // Creates a instance of WatchService.
                WatchService watcher = FileSystems.getDefault().newWatchService();

                // Registers the logDir below with a watch service.
                Path logDir = Paths.get("C:\\\\Users\\\\Desktop\\\\");
                logDir.register(watcher, ENTRY_CREATE, ENTRY_MODIFY, ENTRY_DELETE);

                // Monitor the logDir at listen for change notification.
                WatchKey watchKey = null;
                while (true) {
                    long t1 = System.currentTimeMillis();                           

                    WatchKey key = watcher.take();
                    for (WatchEvent<?> event : key.pollEvents()) {                          

                        WatchEvent.Kind<?> kind = event.kind();

                        if (ENTRY_CREATE.equals(kind)) {
                            System.out.println("Entry was created on log dir.");
                        } else if (ENTRY_MODIFY.equals(kind)) {
                            System.out.println("Entry was modified on log dir.");
                        } else if (ENTRY_DELETE.equals(kind)) {
                            System.out.println("Entry was deleted from log dir.");
                        }
                    }
                    key.reset();
                }
            } catch (IOException | InterruptedException e) {
                e.printStackTrace();
            }
        }


}

这段代码后面的代码不会向前移动

WatchKey key = watcher.take(); 

如果它在我卡住的位置没有检测到任何文件更改，如何在凌晨 4:00 检查文件是否存在。

Answer 1

如果您的主要问题是安排流程，可以通过一些方法来实现

• 根据您的操作系统(Windows = 任务计划程序/Linux = Crontab)，每天下午 4 点创建一个任务来执行您的程序。

• 使用 java.util.TimerTask 或 ScheduledExecutorService 或 java.util.Timer 创建一个代码，每 X 小时调用方法

• 使用 Quartz、Guava AbstractScheduledService 或 Spring Scheduling 等框架

有了这个，您不需要服务来“监视”文件，您只需检查它是否存在 (new File("C:\\a\\b\\c"))。 ists() 或上次修改时间 (new Date((new File("C:\\a\\b\\c")).lastModified()))

示例(请注意，下面的代码只是简单的测试/学习示例，需要改进，或者应该使用 API):

简单线程

public static void main(String[] args) {
        new Thread(new Runnable() {
            public void run() {
                try {
                    while (true) {
                        // do something every 10 seconds
                        doSomething();
                        Thread.sleep(10000); 
                    } 
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
        }).start();
    }

    private static void doSomething() {
        System.out.println("working");
    }

使用 TimerTask 和 Timer

public class Main extends TimerTask {

    @Override
    public void run() {
        doSomething();
    }

    private static void doSomething() {
        System.out.println("working");
    }

    public static void main(String[] args) {
        TimerTask timerTask = new Main();
        Timer timer = new Timer();
        timer.schedule(timerTask, 0, 1000);
    }

}

使用 ScheduledExecutorService

private static void doSomething() {
        System.out.println("working");
    }

    public static void main(String[] args) {
        ScheduledExecutorService ses = Executors.newScheduledThreadPool(1);

        Runnable task = new Runnable() {
            public void run() {
                doSomething();
            }
        };

        ses.scheduleAtFixedRate(task, 5, 10, TimeUnit.SECONDS);
    }