java上传、下载、预览、删除ftp服务器上的文件

1、添加依赖

<dependency>
    <groupId>commons-net</groupId>
    <artifactId>commons-net</artifactId>
</dependency>

2、在properties文件里配置ftp信息(初学者可以放在java类里)：

ftp.url=192.168.60.48
ftp.port=21
ftp.username=FTPTest
ftp.password=FTPTest
ftp.path=E

3、代码：

package com.bosssoft.nontax.basicinfo.standard.sfml.domain;

import org.apache.commons.lang3.StringUtils;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

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

/**
 * @Description TODD
 * @Author sgw
 * @Date 2019/4/2
 * @Version 1.0
 **/
@Component
public class PdfUtilsByFtp {
   

     @Resource
     private FTPClient ftpClient;

     @Value("${ftp.url}")
     public String url;//ftpClient url

     @Value("${ftp.port}")
     public int port;//端口

     @Value("${ftp.username}")
     public String username;//登录用户名

     @Value("${ftp.password}")
     public String password;//登录密码

     @Value("${ftp.path}")
     public String path;//写入/上传文件路径

    //本地字符编码
    private static String LOCAL_CHARSET = "GBK";

    Logger logger = LoggerFactory.getLogger(PdfUtilsByFtp.class);

    /**
     * Description: 向FTP服务器上传文件
     * @param filename 文件名
     * @param path  文件路径
     * @param input  输入流
     * @param url     ftp的地址
     * @param port    ftp的端口
     * @param username  ftp用户名
     * @param password  ftp密码
     * @throws IOException
     */
    public void uploadFile(String filename, String path, InputStream input, String url, int port, String username, String password) throws IOException {
   
        /*try {*/

        int reply;

        /**
         * 连接FTP服务器
         * 如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器
         */
        ftpClient.connect(url, port);
        //登录
        ftpClient.login(username, password);
        //ftp连接的返回码：200表示连接成功，其他值表示连接失败
        reply = ftpClient.getReplyCode();
        if (!FTPReply.isPositiveCompletion(reply)) {
   
            ftpClient.disconnect();
            logger.error("FTP上传文件还没开始就断开了");
        }
        /**
         * 这里修改为被动模式
         * 主动模式：客户端开放端口给服务端用；
         * 被动模式：服务端开放端口给客户端用。
         * 由于很多客户端在防火墙内，开放端口给服务器端用比较困难。所以用被动模式的时候比较多。
         */
        ftpClient.enterLocalPassiveMode();

        // 修改工作目录为path指定的目录
        workingDirectory(ftpClient, path);
        // ftpClient.changeWorkingDirectory(path);
        logger.info("FTP判断服务器的编码格式是UTF-8还是GBK");
        //查看服务器的编码格式是UTF-8还是GBK 开启服务器对UTF-8的支持，如果服务器支持就用UTF-8编码，否则就使用本地编码（GBK）.
        if (FTPReply.isPositiveCompletion(ftpClient.sendCommand("OPTS UTF8", "ON"))) {
   
            LOCAL_CHARSET = "UTF-8";
        }
        ftpClient.setControlEncoding(LOCAL_CHARSET);
        //ftp上传文件是以文本形式传输的，所以多媒体文件会失真，需要转为二进制形式传输
        ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
        logger.info("FTP进行上传文件");
        //文件名字进行编码转换
        ftpClient.storeFile(utf8TOiso88591(filename, LOCAL_CHARSET), input);
        input.close();
        ftpClient.logout();
        if (ftpClient.isConnected()) {
   
            ftpClient.disconnect();
        }
    }
    public void workingDirectory(FTPClient ftp, String path) {
   
        try {
   
            //切换工作目录为根目录
            ftp.changeWorkingDirectory("/");

            if (StringUtils.isBlank(path) || path.equals("/")) {
   //如果输入的路径为空或者为根路径，则不转换操作目录

            } else {
   //否则创建想要上传文件的目录，并且将操作目录转为新创建的目录
                //循环创建多级目录
                String directory = path.substring(0, path.lastIndexOf("/") + 1);
                if (!directory.equalsIgnoreCase("/") && !ftpClient.changeWorkingDirectory(new String(directory.getBytes("GBK"), "iso-8859-1"))) {
   
                    // 如果远程目录不存在，则递归创建远程服务器目录
                    int start = 0;
                    int end = 0;
                    if (directory.startsWith("/")) {
   
                        start = 1;
                    } else {
   
                        start = 0;
                    }
                    end = directory.indexOf("/", start);
                    while (true) {
   
                        String subDirectory = new String(path.substring(start, end).getBytes("GBK"),
                                "iso-8859-1");
                        if (!ftpClient.changeWorkingDirectory(subDirectory)) {
   
                            if (ftpClient.makeDirectory(subDirectory)) {
   
                                ftpClient.changeWorkingDirectory(subDirectory);

                            } else {
   
                                System.out.println("创建目录失败");
                            }
                        }
                        start = end + 1;
                        end = directory.indexOf("/", start);
                        // 检查所有目录是否创建完毕
                        if (end <= start) {
   
                            break;
                        }
                    }
                }
                //这个创建目录的函数只能创建一级目录，不能创建多级目录
                //boolean b = ftp.makeDirectory(gbkTOiso88591(path));
                //切换当前的工作目录为新建的目录
                ftp.changeWorkingDirectory(gbkTOiso88591(path));
            }
        } catch (Exception e) {
   
            logger.error("FTP上传文件进行创建目录结构的时候出现了异常:" + e.getMessage());
        }
    }

    public String utf8TOiso88591(String filename, String codestyle) {
   
        try {
   
            return new String(filename.getBytes(codestyle), "iso-8859-1");
        } catch (Exception e) {
   
            logger.error("FTP上传文件进行" + codestyle + "转ISO-8859-1的时候出现了异常:" + e.getMessage() + "返回的结果就还是传进来的参数");
            logger.error("FTP上传文件进行" + codestyle + "转ISO-8859-1的时候出现了异常,返回的结果就还是传进来的参数");
            return filename;
        }
    }

    public String gbkTOiso88591(String path) {
   
        try {
   
            return new String(path.getBytes("GBK"), "iso-8859-1");
        } catch (Exception e) {
   
            logger.error("FTP上传文件进行GBK转ISO-8859-1的时候出现了异常:" + e.getMessage());
            logger.error("FTP上传文件进行GBK转ISO-8859-1的时候出现了异常,返回的结果就还是传进来的参数");
            return path;
        }
    }

    public FTPClient getFtpClient() {
   
        return ftpClient;
    }

    public void setFtpClient(FTPClient ftpClient) {
   
        this.ftpClient = ftpClient;
    }

    /**
     * Description: 删除ftp上的文件
     * @param url     ftp的地址
     * @param port    ftp的端口
     * @param username  ftp用户名
     * @param password  ftp密码
     * @param filePath  文件路径(后边跟上了文件名)
     * @throws IOException
     */
    public void deleteFile(String url, int port, String username, String password, String filePath) throws IOException {
   
        int reply;
        ftpClient.connect(url, port);
        //如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器
        ftpClient.login(username, password);
        reply = ftpClient.getReplyCode();
        if (!FTPReply.isPositiveCompletion(reply)) {
   
            ftpClient.disconnect();
            logger.error("FTP断开了");
        }
        //修改为被动模式
        ftpClient.enterLocalPassiveMode();
        //删除文件
        ftpClient.deleteFile(filePath);
    }
    /**
     * Description: 下载/浏览器预览  需要的流信息
     * @param url     ftp的地址
     * @param port    ftp的端口
     * @param username  ftp用户名
     * @param password  ftp密码
     * @param filePath  文件路径(后边跟上了文件名)
     * @throws IOException
     */
    public InputStream getStream(String url, int port, String username, String password, String filePath) throws IOException {
   
        int reply;
        ftpClient.connect(url, port);//连接FTP服务器
        //如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器
        ftpClient.login(username, password);//登录
        reply = ftpClient.getReplyCode();
        if (!FTPReply.isPositiveCompletion(reply)) {
   
            ftpClient.disconnect();
            logger.error("FTP断开了");
        }
        InputStream inputStream = ftpClient.retrieveFileStream(filePath);
        return inputStream;
    }
}

注意：由于PdfUtilsByFtp类需要加载配置文件里的信息，所以，引用PdfUtilsByFtp类的时候需要用注入的方式，不能new，即：

    @Autowired
    private PdfUtilsByFtp fdfUtilsByFtp;