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

碧海醫心

发布时间：2025-10-02 21:32:01

244人浏览过

来源于php中文网

原创

使用 java 和 jsch 在 sftp 服务器上解压文件

本文旨在指导开发者如何使用 Java 编程语言和 JSch 库在 SFTP 服务器上解压 ZIP 文件。我们将详细介绍如何通过建立独立的 SFTP 通道来解决 JSch 在处理并发文件操作时可能出现的问题，并提供代码示例，帮助读者理解和实现这一过程。同时，我们将强调代码的实际操作方式：先下载 ZIP 文件到本地，解压后再将解压后的文件上传回 SFTP 服务器。

通常，在使用 JSch 库进行 SFTP 文件操作时，如果需要同时进行读取（get）和写入（put）操作，可能会遇到 java.io.IOException: error: 4: RequestQueue: unknown request id 这样的错误。这通常是因为 JSch 在同一个 SFTP 通道上处理多个并发文件操作时存在限制。

为了解决这个问题，一种有效的策略是为读取和写入操作分别建立独立的 SFTP 通道。这样可以避免通道冲突，确保文件能够正确传输。

建立独立的 SFTP 通道

以下代码演示了如何为读取和写入操作创建独立的 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();
        }
    }
}

代码解释：

立即学习“Java免费学习笔记（深入）”；

良精商城网店购物系统

良精商城网店购物系统是一套能够适合不同类型商品、超强灵活的多功能在线商店系统，三级分销 PC+移动端+微网站，为您提供了一个完整的在线开店解决方案。良精网店购物系统除了拥有一般网上商店系统所具有的所有功能，还拥有着其它网店系统没有的许多超强功能。多种独创的技术使得系统能满足各行业广大用户的各种各样的需求，是一个经过完善设计并适用于各种服务器环境的高效、全新、快速和优秀的网上购物软件解决方案。

下载

建立 Session 和 Channel: 首先，我们创建了一个 JSch Session 对象，并使用用户名、主机名和密码进行身份验证。然后，我们打开两个独立的 SFTP 通道：getChannel 用于从 SFTP 服务器读取 ZIP 文件，putChannel 用于将解压后的文件上传到 SFTP 服务器。
列出文件: 使用getChannel.ls(zipFilePath)获取符合条件的文件列表。
读取和写入数据: 使用 getChannel.get(entry.getFilename()) 获取 ZIP 文件的输入流，然后使用 putChannel.put(zEntry.getName()) 创建输出流，用于写入解压后的文件。
关闭连接: 在完成所有操作后，确保关闭所有通道和会话，释放资源。

注意事项：