如何写定时任务将一个文件夹中所有文件上传到一个服务器

如何写定时任务将一个文件夹中所有文件上传到一个服务器
1、需要怎么去判断源文件夹（有文件和文件夹）中文件 是否已经上传过，

2、定时任务执行到某个时间停止，第二天继续执行，继续执行 的断点怎么获取，或者怎么设计表能快速识别哪些文件上传过

3、源文件夹不挺的有新的文件写入，怎么快速识别哪些是新增文件

可以把文件夹下的文件路径存表，然后如果传送成功，改个状态，然后通过这个状态来判断文件是上传成功还是失败，还是没上传

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.sql.*;
import java.util.Base64;
import java.util.HashMap;
import java.util.Map;
import java.util.Timer;
import java.util.TimerTask;
import java.nio.file.*;

public class FileUploader {

    private static final String SOURCE_FOLDER = "/path/to/source/folder"; // 源文件夹路径
    private static final String SERVER_URL = "http://example.com/upload"; // 服务器上传接口
    private static final int UPLOAD_INTERVAL = 60 * 1000; // 定时任务执行间隔时间（毫秒）

    private static final String DB_URL = "jdbc:mysql://localhost:3306/file_upload_db"; // 数据库连接URL
    private static final String DB_USER = "root"; // 数据库用户名
    private static final String DB_PASSWORD = "password"; // 数据库密码

    public static void main(String[] args) {
        Timer timer = new Timer();
        timer.schedule(new UploadTask(), 0, UPLOAD_INTERVAL); // 执行定时任务

        // 使用Java WatchService监控源文件夹
        try {
            WatchService watchService = FileSystems.getDefault().newWatchService();
            Path sourceFolderPath = Paths.get(SOURCE_FOLDER);
            sourceFolderPath.register(watchService, StandardWatchEventKinds.ENTRY_CREATE);
            WatchKey watchKey;
            while ((watchKey = watchService.take()) != null) {
                for (WatchEvent<?> event : watchKey.pollEvents()) {
                    if (event.kind() == StandardWatchEventKinds.ENTRY_CREATE) {
                        Path filePath = sourceFolderPath.resolve((Path) event.context());
                        System.out.println("Detected new file: " + filePath);
                        // 可在此处添加上传文件的逻辑
                    }
                }
                watchKey.reset();
            }
        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        }
    }

    static class UploadTask extends TimerTask {
        @Override
        public void run() {
            System.out.println("Start uploading...");
            File sourceFolder = new File(SOURCE_FOLDER);
            File[] files = sourceFolder.listFiles();
            if (files == null || files.length == 0) {
                System.out.println("No files to upload.");
                return;
            }

            // 连接数据库
            try (Connection conn = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD)) {
                // 检查文件是否已上传
                PreparedStatement checkStmt = conn.prepareStatement("SELECT COUNT(*) FROM uploaded_files WHERE file_md5 = ?");
                for (File file : files) {
                    String fileMD5 = getFileMD5(file);
                    checkStmt.setString(1, fileMD5);
                    ResultSet resultSet = checkStmt.executeQuery();
                    if (resultSet.next() && resultSet.getInt(1) > 0) {
                        System.out.println("File already uploaded

1、使用文件的MD5值作为唯一标识来判断文件是否已经上传过。
2、使用数据库表来记录已上传的文件信息，包括文件名、文件路径、文件的MD5值等，以便定时任务执行到某个时间停止后，可以通过查询数据库表获取断点信息。
3、使用Java WatchService来监控源文件夹，检测是否有新的文件写入。