ftp文件上传工具类

import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;

public class FTPUploader {
    private String server;
    private int port;
    private String user;
    private String pass;
    private FTPClient ftpClient;

    public FTPUploader(String server, int port, String user, String pass) {
        this.server = server;
        this.port = port;
        this.user = user;
        this.pass = pass;
        this.ftpClient = new FTPClient();
    }

    public void connect() throws IOException {
        ftpClient.connect(server, port);
        ftpClient.login(user, pass);
        ftpClient.enterLocalPassiveMode(); // 使用被动模式
        ftpClient.setFileType(FTP.BINARY_FILE_TYPE); // 设置二进制文件传输模式
    }

    public void disconnect() throws IOException {
        if (ftpClient.isConnected()) {
            ftpClient.logout();
            ftpClient.disconnect();
        }
    }

    public boolean uploadFile(String localFilePath, String remoteFilePath) throws IOException {
        try (InputStream inputStream = new FileInputStream(localFilePath)) {
            return ftpClient.storeFile(remoteFilePath, inputStream);
        }
    }

    public static void main(String[] args) {
        FTPUploader ftpUploader = new FTPUploader("ftp.example.com", 21, "username", "password");
        try {
            ftpUploader.connect();
            boolean success = ftpUploader.uploadFile("localFile.txt", "remoteFile.txt");
            if (success) {
                System.out.println("File uploaded successfully.");
            } else {
                System.out.println("File upload failed.");
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                ftpUploader.disconnect();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}