基于Apache FTP实现的文件上传下载工具

基于Apache FTP实现文件上传下载工具 ，上传文件时需要考虑以下问题（实例未实现续传功能）：

（1）、 FTP服务器是否存在改目录，如果不存在目录则需要创建目录。

（2）、判断上传文件是否已经存在，如果存在是需要删除后再上传还是续传。

package com.scengine.wtms.utils.ftp;  
  
import java.io.ByteArrayOutputStream;  
import java.io.File;  
import java.io.FileInputStream;  
import java.io.FileOutputStream;  
import java.io.IOException;  
import java.io.InputStream;  
import java.io.OutputStream;  
import java.io.PrintWriter;  
import java.net.SocketException;  
import java.net.URLEncoder;  
import javax.servlet.http.HttpServletResponse;  
import org.apache.commons.net.PrintCommandListener;  
import org.apache.commons.net.ftp.FTP;  
import org.apache.commons.net.ftp.FTPClient;  
import org.apache.commons.net.ftp.FTPClientConfig;  
import org.apache.commons.net.ftp.FTPFile;  
import org.apache.commons.net.ftp.FTPReply;  
  
import com.scengine.wtms.utils.Log;  
  
public class FTPUtils  
{  
  
    private FTPClient ftp;  
  
    /** 
     * 对象构造 设置将过程中使用到的命令输出到控制台 
     */  
    public FTPUtils()  
    {  
        ftp = new FTPClient();  
        this.ftp.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out)));  
    }  
  
    /** 
     * 用户FTP账号登录 
     *  
     * @param url 
     *            FTP地址 
     * @param port 
     *            FTP端口 
     * @param username 
     *            用户名 
     * @param password 
     *            密 码 
     * @return true/false 成功/失败 
     * @throws SocketException 
     * @throws IOException 
     */  
    private boolean login(String url, int port, String username, String password) throws SocketException, IOException  
    {  
        int reply;  
        // 1. 连接FTP服务器  
        // 如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器  
        ftp.connect(url, port);  
  
        // 2. 设置编码  
        // 下面三行代码必须要，而且不能改变编码格式，否则不能正确下载中文文件  
        ftp.setControlEncoding("UTF-8");  
        FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_NT);  
        conf.setServerLanguageCode("zh");  
  
        // 3. 登录ftp  
        ftp.login(username, password);  
  
        // 看返回的值是不是230，如果是，表示登陆成功  
        reply = ftp.getReplyCode();  
  
        // 以2开头的返回值就会为真  
        if (!FTPReply.isPositiveCompletion(reply))  
        {  
            ftp.disconnect();  
            Log.getLogger(this.getClass()).info(">>>>>>>>>>>>>>>>连接服务器失败!");  
            return false;  
        }  
        Log.getLogger(this.getClass()).info(">>>>>>>>>>>>>>>>>登陆服务器成功!");  
        return true;  
    }  
  
    /** 
     * 释放FTP 
     */  
    private void free()  
    {  
        if (ftp.isAvailable())  
        {  
            try  
            {  
                // 退出FTP  
                ftp.logout();  
            } catch (IOException e)  
            {  
                Log.getLogger(this.getClass()).error("FTP登录退出异常:" + e.getMessage());  
            }  
        }  
        if (ftp.isConnected())  
        {  
            try  
            {  
                // 断开连接  
                ftp.disconnect();  
            } catch (IOException e)  
            {  
                Log.getLogger(this.getClass()).error("FTP断开连接异常:" + e.getMessage());  
            }  
        }  
    }  
  
    /** 
     * FTP文件上传 
     *  
     * @param url 
     *            FTP地址 
     * @param port 
     *            FTP端口 
     * @param username 
     *            FTP用户名 
     * @param password 
     *            FTP密码 
     * @param localAdr 
     *            上传文件名 
     * @param remoteAdr 
     *            指定的FTP目录 
     * @return 
     * @throws IOException 
     */  
    public boolean uploadFile(String url, int port, String username, String password, String localAdr, String remoteAdr) throws IOException  
    {  
  
        // 初始表示上传失败  
        boolean success = false;  
        /******验证用户登录信息*****/  
        try  
        {  
            success = login(url, port, username, password);  
  
            Log.getLogger(this.getClass()).info("FTP用户登录：" + (success ? "成功!" : "失败!"));  
            if (!success)  
            {  
                return success;  
            }  
        } catch (IOException e)  
        {  
            Log.getLogger(this.getClass()).error("上传文件异常:" + e.getMessage());  
            return success;  
        }  
        // 设置PassiveMode传输  
        ftp.enterLocalPassiveMode();  
  
        // 设置FTP文件类型为二进制，如果缺省该句 传输txt正常 但图片和其他格式的文件传输出现乱码  
        ftp.setFileType(FTP.BINARY_FILE_TYPE);  
  
        /*****对远程目录的处理******/  
        String remoteFileName = remoteAdr;  
  
        if (remoteAdr.contains("/"))  
        {  
            remoteFileName = remoteAdr.substring(remoteAdr.lastIndexOf("/") + 1);  
            String directory = remoteAdr.substring(0, remoteAdr.lastIndexOf("/") + 1);  
  
            if (!directory.equalsIgnoreCase("/") && !ftp.changeWorkingDirectory(directory))  
            {  
  
                // 如果远程目录不存在，则递归创建远程服务器目录  
                int start = 0, end = 0;  
  
                if (directory.startsWith("/"))  
                {  
                    start = 1;  
                } else  
                {  
                    start = 0;  
                }  
  
                end = directory.indexOf("/", start);  
  
                while (true)  
                {  
  
                    String subDirectory = remoteAdr.substring(start, end);  
  
                    if (!ftp.changeWorkingDirectory(subDirectory))  
                    {  
  
                        if (ftp.makeDirectory(subDirectory))  
                        {  
  
                            ftp.changeWorkingDirectory(subDirectory);  
  
                        } else  
                        {  
                            Log.getLogger(this.getClass()).info("创建目录失败");  
                            return false;  
                        }  
                    }  
                    start = end + 1;  
                    end = directory.indexOf("/", start);  
                    // 检查所有目录是否创建完毕  
                    if (end <= start)  
                    {  
                        break;  
                    }  
                }  
            }  
        }  
  
        /*****执行文件上传******/  
        InputStream input = null;  
        try  
        {  
            File f = new File(localAdr);  
            // 得到目录的相应文件列表  
            FTPFile[] fs = ftp.listFiles(remoteFileName);  
  
            Log.getLogger(this.getClass()).info("上传文件个数:" + fs.length + "  ,文件名称:" + localAdr);  
  
            input = new FileInputStream(f);  
            // 保存文件remoteFileName  
            success = ftp.storeFile(remoteFileName, input);  
            input.close();  
        } catch (IOException e)  
        {  
            Log.getLogger(this.getClass()).info("上传文件失败:" + e.getMessage());  
            if (input != null)  
            {  
                input.close();  
            }  
        } finally  
        {  
            Log.getLogger(this.getClass()).info("保存标识>>>" + success + "文件名称:" + localAdr + (success ? "上传成功!" : "上传失败!"));  
            free();  
        }  
        return success;  
    }  
  
    /** 
     * 删除FTP文件 
     *  
     * @param url 
     *            FTP地址 
     * @param port 
     *            FTP端口 
     * @param username 
     *            用户名 
     * @param password 
     *            密 码 
     * @param remoteAdr 
     *            文件路径 
     * @param localAdr 
     *            文件名称 
     * @return true/false 成功/失败 
     */  
    public boolean deleteFile(String url, int port, String username, String password, String remoteAdr, String localAdr)  
    {  
  
        // localAdr:要上传的文件  
        // remoteAdr :上传的路径  
        // 初始表示上传失败  
        boolean success = false;  
  
        try  
        {  
            success = login(url, port, username, password);  
            Log.getLogger(this.getClass()).info("FTP用户登录：" + (success ? "成功!" : "失败!"));  
            if (!success)  
            {  
                return success;  
            }  
  
            //String codeclocalAdr = new String(localAdr.getBytes("UTF-8"), "ISO-8859-1");  
            //String remoteAdr_ = new String(remoteAdr.getBytes("UTF-8"), "ISO-8859-1");  
  
            // 转到指定上传目录  
            // remoteAdr_->remoteAdr  
            ftp.changeWorkingDirectory(remoteAdr);  
  
            FTPFile[] fs = ftp.listFiles(); // 得到目录的相应文件列表  
            if(fs.length>0)  
            {  
  
                // codeclocalAdr->localAdr  
                success = ftp.removeDirectory(remoteAdr);  
  
                ftp.logout();  
            }  
  
        } catch (IOException e)  
        {  
            Log.getLogger(this.getClass()).error(e.getMessage());  
        } finally  
        {  
            free();  
        }  
  
        return success;  
    }  
  
    /** 
     * 删除FTP文件和目录 
     *  
     * @param url 
     *            FTP地址 
     * @param port 
     *            FTP端口 
     * @param username 
     *            用户名 
     * @param password 
     *            密 码 
     * @param remoteAdr 
     *            文件路径 
     * @return true/false 成功/失败 
     */  
    public boolean deleteDir(String url, int port, String username, String password, String remoteAdr)  
    {  
  
        // localAdr:要上传的文件  
        // remoteAdr :上传的路径  
        // 初始表示上传失败  
        boolean success = false;  
  
        try  
        {  
            success = login(url, port, username, password);  
            Log.getLogger(this.getClass()).info("FTP用户登录：" + (success ? "成功!" : "失败!"));  
            if (!success)  
            {  
                return success;  
            }  
  
            //String codeclocalAdr = new String(localAdr.getBytes("UTF-8"), "ISO-8859-1");  
            //String remoteAdr_ = new String(remoteAdr.getBytes("UTF-8"), "ISO-8859-1");  
  
            // 转到指定上传目录  
            // remoteAdr_->remoteAdr  
            ftp.changeWorkingDirectory(remoteAdr);  
  
            FTPFile[] fs = ftp.listFiles(); // 得到目录的相应文件列表  
            if(fs.length>0)  
            {  
  
                // codeclocalAdr->localAdr  
                success = ftp.removeDirectory(remoteAdr);  
  
                ftp.logout();  
            }  
  
        } catch (IOException e)  
        {  
            Log.getLogger(this.getClass()).error(e.getMessage());  
        } finally  
        {  
            free();  
        }  
        return success;  
    }  
  
    /** 
     * 下载FTP文件 
     *  
     * @param url 
     *            FPT地址 
     * @param port 
     *            FTP端口 
     * @param username 
     *            用户名 
     * @param password 
     *            密 码 
     * @param remoteremoteAdr 
     *            远程路径 
     * @param localAdr 
     *            文件名称 
     * @param outputStream文件输出流 
     * @param response 
     *            Http响应 
     * @return true/false 成功/失败 
     */  
    public boolean downFile(String url, int port, String username, String password, String remoteremoteAdr, String localAdr, HttpServletResponse response)  
    {  
        boolean success = false;  
        try  
        {  
            success = login(url, port, username, password);  
            Log.getLogger(this.getClass()).info("FTP用户登录：" + (success ? "成功!" : "失败!"));  
            if (!success)  
            {  
                return success;  
            }  
            // 转移到FTP服务器目录  
            ftp.changeWorkingDirectory(remoteremoteAdr);  
            // 得到目录的相应文件列表  
            FTPFile[] fs = ftp.listFiles();  
              
            for (FTPFile ftpFile : fs)  
            {  
                if (ftpFile.getName().equals(localAdr))  
                {  
                    // 这个就就是弹出下载对话框的关键代码  
                    response.setHeader("Content-disposition", "attachment;localAdr=" + URLEncoder.encode(localAdr, "UTF-8"));  
                    // 将文件保存到输出流outputStream中  
                    File f=new File(localAdr);  
                    OutputStream os=new FileOutputStream(f);  
                    ftp.retrieveFile(new String(ftpFile.getName().getBytes("UTF-8"), "ISO-8859-1"), os);  
                    os.flush();  
                    os.close();  
                }  
            }  
            ftp.logout();  
            success = true;  
        } catch (IOException e)  
        {  
            e.printStackTrace();  
        } finally  
        {  
            free();  
        }  
        return success;  
    }  
  
    /** 
     * 读取FTP文件内容 
     *  
     * @param url 
     *            FPT地址 
     * @param port 
     *            FTP端口 
     * @param username 
     *            用户名 
     * @param password 
     *            密 码 
     * @param remoteremoteAdr 
     *            远程路径 
     * @param localAdr 
     *            文件名称 
     * @return String 文件内容 
     */  
    public String readFileContent(String url, int port, String username, String password, String remoteremoteAdr, String localAdr)  
    {  
        String content = null;  
        try  
        {  
            boolean success = login(url, port, username, password);  
            Log.getLogger(this.getClass()).info("FTP用户登录：" + (success ? "成功!" : "失败!"));  
            if (success)  
            {  
                // 转移到FTP服务器目录  
                ftp.changeWorkingDirectory(remoteremoteAdr);   
                  
                // 得到目录的相应文件列表  
                FTPFile[] fs = ftp.listFiles();  
                  
                for (FTPFile ftpFile : fs)  
                {  
                    if (ftpFile.getName().equals(localAdr))  
                    {  
                        // 这个就就是弹出下载对话框的关键代码  
                        // 将文件保存到输出流outputStream中  
                        File f=new File(localAdr);  
                        ftp.retrieveFile(new String(ftpFile.getName().getBytes("UTF-8"), "ISO-8859-1"), new FileOutputStream(f));  
                        ByteArrayOutputStream bos = new ByteArrayOutputStream();  
                        ftp.retrieveFile(ftpFile.getName(), bos);  
                        bos.flush();  
                        bos.close();  
  
                        content = new String(bos.toByteArray(), "UTF-8");  
                    }  
                }  
            }  
        } catch (IOException e)  
        {  
            Log.getLogger(FTPUtils.class).error(e.getMessage());  
        } finally  
        {  
            free();  
        }  
        return content;  
    }  
  
    /** 
     * 判断是否重名的方法 
     *  
     * @param localAdr 
     *            文件名称 
     * @param fs 
     *            文件列表数组 
     * @return 
     */  
    public static boolean isDirExist(String localAdr, FTPFile[] fs)  
    {  
        for (FTPFile ftpFile : fs)  
        {  
            if (ftpFile.getName().equals(localAdr))  
            {  
                return true;  
            }  
        }  
        return false;  
    }  
  
    /** 
     * 根据重名判断的结果 生成新的文件的名称 更改的重名为 原有名字+[n], n表示数字 
     *  
     * @param localAdr 
     *            文件名称 
     * @param fs 
     *            FTP文件列表 
     * @return 
     */  
    public static String changeName(String localAdr, FTPFile[] fs)  
    {  
        int n = 0;  
        // 创建一个可变的字符串对象 即StringBuffer对象，把localAdr值付给该对象  
        StringBuffer localAdr_ = new StringBuffer("");  
        localAdr_ = localAdr_.append(localAdr);  
  
        // 重名时改名，遍历存在同名的文件  
        while (isDirExist(localAdr_.toString(), fs))  
        {  
            n++;  
            String a = "[" + n + "]";  
            // 最后一出现小数点的位置  
            int b = localAdr_.lastIndexOf(".");  
            // 最后一次"["出现的位置  
            int c = localAdr_.lastIndexOf("[");  
            if (c < 0)  
            {  
                c = b;  
            }  
  
            // 文件的名字  
            StringBuffer name = new StringBuffer(localAdr_.substring(0, c));  
            // 后缀的名称  
            StringBuffer suffix = new StringBuffer(localAdr_.substring(b + 1));  
            localAdr_ = name.append(a).append(".").append(suffix);  
        }  
        return localAdr_.toString();  
    }  
  
    public static void main(String[] args)  
    {  
        FTPUtils ftp = new FTPUtils();  
        try  
        {  
            ftp.uploadFile("192.168.1.200", 21, "duser", "HTPDuserXP32", "C:\\Users\\Administrator\\Desktop\\backgroud_change.html", "/htmls/backgroud_change.html");  
        } catch (IOException e)  
        {  
            Log.getLogger(FTPUtils.class).error(e.getMessage());  
        }  
    }  
  
}