如何用Java代码实现FTP链接服务器？Java连接FTP服务器代码示例

在 Java 中连接 FTP 服务器，最常用且推荐的方式是使用 Apache Commons Net 库，它提供了稳定、易于使用的 API 来处理 FTP、FTPS 和 SFTP 协议。

下面我将提供两种常见场景的代码示例：

加载中

Java小案例 - 网络编程 - 实现简单的客户端与服务器端连接传输

鬼鬼骑士

6373936

原视频地址

1. 标准 FTP 连接（明文传输，端口 21）
2. FTPS 连接（加密传输,推荐用于生产环境）

✅ 前置依赖

如果你使用 Maven，请在 pom.xml 中添加以下依赖：

<dependency>
    <groupId>commons-net</groupId>
    <artifactId>commons-net</artifactId>
    <version>3.9.0</version> <!-- 请使用最新版本 -->
</dependency>

⚠️ 注意：Apache Commons Net 不直接支持 SFTP（SSH File Transfer Protocol），SFTP 需要使用 JSch 或 Apache Commons VFS 等库，本文聚焦于 FTP/FTPS。

📌 示例 1：标准 FTP 连接（非加密）

import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import java.io.IOException;
public class FtpExample {
    public static void main(String[] args) {
        String host = "ftp.example.com";
        int port = 21;
        String username = "your_username";
        String password = "your_password";
        FTPClient ftpClient = new FTPClient();
        try {
            // 连接服务器
            ftpClient.connect(host, port);
            System.out.println("Connected to " + host);
            // 登录
            boolean loginSuccess = ftpClient.login(username, password);
            if (!loginSuccess) {
                System.out.println("Login failed!");
                return;
            }
            System.out.println("Logged in successfully.");
            // 检查响应码
            int reply = ftpClient.getReplyCode();
            if (!FTPReply.isPositiveCompletion(reply)) {
                ftpClient.disconnect();
                System.err.println("Server refused connection.");
                return;
            }
            // 设置被动模式（推荐，尤其通过防火墙/NAT 时）
            ftpClient.enterLocalPassiveMode();
            // 设置文件类型为二进
制（避免文件损坏）
            ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
            // 示例：列出根目录文件
            String[] files = ftpClient.listNames();
            if (files != null) {
                for (String file : files) {
                    System.out.println("File: " + file);
                }
            }
            // 断开连接
            ftpClient.logout();
            System.out.println("Disconnected.");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (ftpClient.isConnected()) {
                try {
                    ftpClient.disconnect();
                } catch (IOException ex) {
                    ex.printStackTrace();
                }
            }
        }
    }
}

🔒 示例 2：FTPS 连接（显式 SSL/TLS 加密）

FTPS 是 FTP over SSL，更安全，使用 FTPClient 并启用 SSL 即可。

import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManagerFactory;
import java.io.FileInputStream;
import java.io.IOException;
import java.security.KeyStore;
import java.security.Security;
public class FtpsExample {
    public static void main(String[] args) {
        String host = "ftps.example.com";
        int port = 990; // 或 21（显式模式）
        String username = "your_username";
        String password = "your_password";
        FTPClient ftpClient = new FTPClient();
        try {
            // 可选：配置 SSL 上下文（如需要自定义信任库）
            // SSLContext sslContext = createSSLContext();
            // ftpClient.execPBSZ(0);
            // ftpClient.execPROT("P");
            // ftpClient.setAuthSSL(sslContext);
            // 连接（显式 FTPS，端口通常为 21）
            ftpClient.connect(host, port);
            System.out.println("Connected to " + host);
            // 登录
            boolean loginSuccess = ftpClient.login(username, password);
            if (!loginSuccess) {
                System.out.println("Login failed!");
                return;
            }
            System.out.println("Logged in successfully.");
            int reply = ftpClient.getReplyCode();
            if (!FTPReply
.isPositiveCompletion(reply)) {
                ftpClient.disconnect();
                System.err.println("Server refused connection.");
                return;
            }
            // 启用显式 FTPS（自动处理 SSL 握手）
            ftpClient.execPBSZ(0);
            ftpClient.execPROT("P"); // 数据通道也加密
            // 被动模式
            ftpClient.enterLocalPassiveMode();
            // 二进制模式
            ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
            // 示例：列出文件
            String[] files = ftpClient.listNames();
            if (files != null) {
                for (String file : files) {
                    System.out.println("File: " + file);
                }
            }
            ftpClient.logout();
            System.out.println("Disconnected.");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (ftpClient.isConnected()) {
                try {
                    ftpClient.disconnect();
                } catch (IOException ex) {
                    ex.printStackTrace();
                }
            }
        }
    }
    // 如需自定义信任库，可取消注释并实现此方法
    /
    private static SSLContext createSSLContext() throws Exception {
        KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType());
        try (FileInputStream fis = new FileInputStream("truststore.jks")) {
            trustStore.load(fis, "changeit".toCharArray());
        }
        TrustManagerFactory tmf = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
        tmf.init(trustStore);
        SSLContext sslContext = SSLContext.getInstance("TLS");
        sslContext.init(null, tmf.getTrustManagers(), null);
        return sslContext;
    }
    /
}

📤 上传/下载文件示例

上传文件

import java.io.FileInputStream;
import java.io.IOException;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
public boolean uploadFile(FTPClient ftpClient, String remotePath, String localFilePath) throws IOException {
    try (FileInputStream inputStream = new FileInputStream(localFilePath)) {
        boolean success = ftpClient.storeFile(remotePath, inputStream);
        if (success) {
            System.out.println("File uploaded successfully: " + remotePath);
        } else {
            System.out.println("Upload failed for: " + remotePath);
        }
        return success;
    }
}

下载文件

import java.io.FileOutputStream;
import java.io.IOException;
import org.apache.commons.net.ftp.FTPClient;
public boolean downloadFile(FTPClient ftpClient, String remoteFilePath, String localFilePath) throws IOException {
    try (FileOutputStream outputStream = new FileOutputStream(localFilePath)) {
        boolean success = ftpClient.retrieveFile(remoteFilePath, outputStream);
        if (success) {
            System.out.println("File downloaded successfully: " + remoteFilePath);
        } else {
            System.out.println("Download failed for: " + remoteFilePath);
        }
        return success;
    }
}

⚠️ 注意事项

1. 被动模式（Passive Mode）：始终调用 ftpClient.enterLocalPassiveMode()，否则在 NAT/防火墙后可能无法传输数据。
2. 字符编码：如果文件名包含中文，需设置编码：

   ftpClient.setControlEncoding("UTF-8");

3. 资源关闭：务必在 finally 块中关闭 FTPClient 和输入/输出流,避免资源泄漏。
4. FTPS vs SFTP：
   • FTPS：使用 commons-net 的 FTPClient + SSL。
   • SFTP：使用 JSch 或 Apache Commons VFS。
5. 超时设置：可设置连接和数据超时：

   ftpClient.setConnectTimeout(5000); // 5秒
   ftpClient.setDataTimeout(30000);   // 30秒

如需 SFTP 示例，请告诉我，我可以提供 JSch 的实现代码。