FTP实用工具类

╰半夏微凉° 2023-10-07 12:01 51阅读 0赞

import org.apache.commons.net.ftp.FTP;
    import org.apache.commons.net.ftp.FTPClient;
    import org.apache.commons.net.ftp.FTPFile;
    import java.io.*;
    
    
    public class FTPUtil implements AutoCloseable {
    
        private FTPClient ftpClient;
    
        public FTPUtil(String serverIP, int port, String userName, String password) throws IOException {
            ftpClient = new FTPClient();
            ftpClient.connect(serverIP, port);
            ftpClient.login(userName, password);
            ftpClient.setBufferSize(1024);//设置上传缓存大小
            ftpClient.setControlEncoding("UTF-8");//设置编码
            ftpClient.setFileType(FTP.BINARY_FILE_TYPE);//设置文件类型
            ftpClient.setConnectTimeout(15000);//连接超时时间
            ftpClient.setSoTimeout(60000);//读取操作时间
        }
    
        /**
         * 下载ftp文件到本地
         *
         * @param remoteFileName 远程文件名称
         * @param localFile      本地文件[包含路径]
         * @return true/false
         * @throws IOException 异常
         */
        public boolean downloadFile(String remoteFileName, String localFile) throws IOException {
            boolean isSucc;
            File outFileName = new File(localFile);
            if (ftpClient == null)
                throw new IOException("ftp server not login");
            try (OutputStream outputStream = new FileOutputStream(outFileName)) {
                isSucc = ftpClient.retrieveFile(remoteFileName, outputStream);
            }
            return isSucc;
        }
    
        /**
         * 上传文件制定目录
         *
         * @param remoteFileName 远程文件名
         * @param localFile      本地文件[必须带路径]
         * @return true/false
         * @throws IOException 异常
         */
        public boolean uploadFile(String remoteFileName, String localFile) throws IOException {
            boolean isSucc;
            try (InputStream inputStream = new FileInputStream(localFile)) {
                if (ftpClient == null)
                    throw new IOException("ftp server not login");
                isSucc = ftpClient.storeFile(remoteFileName, inputStream);
            }
            return isSucc;
        }
    
        /**
         	* 切换目录
         *
         * @param path 创建目录
         * @return 创建标志
         * @throws IOException 异常
         */
        public boolean changeDirectory(String path) throws IOException {
            return ftpClient.changeWorkingDirectory(path);
        }
    
        /**
         * 创建目录
         *
         * @param path 创建目录
         * @return 创建标志
         * @throws IOException 异常
         */
        public boolean createDirectory(String path) throws IOException {
            return ftpClient.makeDirectory(path);
        }
    
        /***
      	    * 判断文件是否存在
         * @param ftpPath
         * @return
         */
        public boolean isExsits(String ftpPath, String fileName) throws IOException {
            if (changeDirectory(ftpPath)) {
                FTPFile[] files = ftpClient.listFiles(fileName);
                if (files != null && files.length > 0) {
                    return true;
                }
            }
            return false;
        }
    
        /**
             * 自动关闭资源
         */
        @Override
        public void close() throws Exception {
            if (ftpClient != null && ftpClient.isConnected()) {
                ftpClient.logout();
                ftpClient.disconnect();
            }
        }
    }