使用 Java 和 JSch 在 SFTP 服务器上解压文件

import com.jcraft.jsch.*;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Vector;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;

public class SftpUnzip {

    public static void main(String[] args) {
        String host = "your_sftp_host";
        int port = 22; // 默认 SFTP 端口
        String username = "your_username";
        String password = "your_password";
        String zipFilePath = "ML_E_DAM_D_op_files_*.zip"; //SFTP服务器上zip文件路径

        try {
            JSch jsch = new JSch();
            Session session = jsch.getSession(username, host, port);
            session.setPassword(password);

            // 禁用 StrictHostKeyChecking，仅用于测试环境
            java.util.Properties config = new java.util.Properties();
            config.put("StrictHostKeyChecking", "no");
            session.setConfig(config);

            session.connect();

            ChannelSftp getChannel = (ChannelSftp) session.openChannel("sftp");
            getChannel.connect();
            ChannelSftp putChannel = (ChannelSftp) session.openChannel("sftp");
            putChannel.connect();

            Vector filelist = getChannel.ls(zipFilePath);

            for (int i = 0; i < filelist.size(); i++) {
                ChannelSftp.LsEntry entry = (ChannelSftp.LsEntry) filelist.get(i);
                System.out.println("Processing file: " + entry.getFilename());

                try (ZipInputStream stream1 = new ZipInputStream(getChannel.get(entry.getFilename()))) {
                    ZipEntry zEntry;
                    while ((zEntry = stream1.getNextEntry()) != null) {
                        System.out.println("Extracting: " + zEntry.getName());
                        try (OutputStream out = putChannel.put(zEntry.getName())) {
                            byte[] buffer = new byte[2048];
                            int len;
                            while ((len = stream1.read(buffer)) != -1) {
                                out.write(buffer, 0, len);
                            }
                        }
                        stream1.closeEntry();
                    }
                } catch (IOException e) {
                    System.err.println("Error processing zip entry: " + e.getMessage());
                    e.printStackTrace();
                }
            }

            getChannel.disconnect();
            putChannel.disconnect();
            session.disconnect();

        } catch (JSchException e) {
            System.err.println("JSchException: " + e.getMessage());
            e.printStackTrace();
        } catch (SftpException e) {
            System.err.println("SftpException: " + e.getMessage());
            e.printStackTrace();
        }
    }
}

<dependency>
    <groupId>com.jcraft</groupId>
    <artifactId>jsch</artifactId>
    <version>0.1.55</version>
</dependency>