sftp 定时下载一个目录下所有文件并删除原目录下文件 java main实现

可以使用Java的JSch库来实现SFTP的文件下载和删除操作，再结合Java的定时任务框架如Quartz来实现定时任务。

以下是一个示例代码，实现每天定时在SFTP服务器上下载指定目录下的所有文件，并删除原目录下的文件。

import com.jcraft.jsch.*;

import java.io.File;
import java.io.FileOutputStream;
import java.util.Properties;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class SftpDownloadAndDeleteJob implements Job {

    private String host;
    private int port;
    private String username;
    private String password;
    private String remotePath;
    private String localPath;

    public SftpDownloadAndDeleteJob() {
        // 初始化SFTP连接参数
        this.host = "sftp.example.com";
        this.port = 22;
        this.username = "username";
        this.password = "password";
        this.remotePath = "/path/to/remote/directory";
        this.localPath = "/path/to/local/directory";
    }

    public void execute(JobExecutionContext context) throws JobExecutionException {
        try {
            // 创建JSch对象
            JSch jsch = new JSch();

            // 连接SFTP服务器
            Session session = jsch.getSession(username, host, port);
            session.setPassword(password);
            Properties config = new Properties();
            config.setProperty("StrictHostKeyChecking", "no");
            session.setConfig(config);
            session.connect();

            // 打开SFTP通道
            ChannelSftp channel = (ChannelSftp) session.openChannel("sftp");
            channel.connect();

            // 下载所有文件
            Vector<ChannelSftp.LsEntry> files = channel.ls(remotePath);
            for (ChannelSftp.LsEntry entry : files) {
                if (!entry.getAttrs().isDir()) {
                    String remoteFilePath = remotePath + "/" + entry.getFilename();
                    String localFilePath = localPath + "/" + entry.getFilename();
                    channel.get(remoteFilePath, new FileOutputStream(new File(localFilePath)));
                }
            }

            // 删除所有文件
            for (ChannelSftp.LsEntry entry : files) {
                if (!entry.getAttrs().isDir()) {
                    String remoteFilePath = remotePath + "/" + entry.getFilename();
                    channel.rm(remoteFilePath);
                }
            }

            // 关闭SFTP通道和会话
            channel.disconnect();
            session.disconnect();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

然后在主函数中添加定时任务：

import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

public class Main {

    public static void main(String[] args) {
        try {
            // 创建定时任务
            JobDetail job = JobBuilder.newJob(SftpDownloadAndDeleteJob.class)
                    .withIdentity("sftpJob", "group1")
                    .build();

            // 创建触发器
            Trigger trigger = TriggerBuilder.newTrigger()
                    .withIdentity("sftpTrigger", "group1")
                    .withSchedule(CronScheduleBuilder.cronSchedule("0 0 1 * * ?")) // 每天1点执行
                    .build();

            // 创建调度器
            Scheduler scheduler = new StdSchedulerFactory().getScheduler();
            scheduler.start();
            scheduler.scheduleJob(job, trigger);
        } catch (SchedulerException e) {
            e.printStackTrace();
        }
    }
}

这样就可以每天定时执行SFTP下载和删除操作了。需要注意的是，为了避免重复下载和删除，可以在本地目录中设置一个过期时间，只保留最近几天的文件，避免占用过多磁盘空间。