使用Apache上传文件

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.net.SocketException; 
import java.net.URLEncoder; 
import javax.servlet.http.HttpServletResponse;
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 uk.ltd.getahead.dwr.util.Logger;
 
public class ApacheFtp 
{
    private FTPClient ftp=null;
    private Logger log=Logger.getLogger(ApacheFtp.class);
    /**
     * 对象构造 设置将过程中使用到的命令输出到控制台
     */ 
    public ApacheFtp() 
    { 
     ftp = new FTPClient();
    }
    /**
     * 用户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("GBK"); 
        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.error(">>>>>>>>>>>>>>>>连接服务器失败!");
            return false; 
        }
        return true; 
    } 
 
    /**
     * 释放FTP
     */ 
    private void free() 
    {
        if (ftp.isConnected()) 
        { 
            try 
            { 
                // 断开连接 
                ftp.disconnect();
            } catch (IOException e) 
            { 
             log.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);
            if (!success) 
            { 
             log.error("FTP用户："+username+",登录失败!"); 
                return success; 
            }
        } catch (IOException e){
         log.error("上传文件异常:" + e.getMessage()); 
            return success; 
        } 
        // 设置PassiveMode传输 
        ftp.enterLocalPassiveMode(); 
 
        ftp.changeWorkingDirectory(new String(remoteAdr.getBytes("GBK"),"iso-8859-1"));
        // 设置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.error("创建目录失败"); 
                            return false; 
                        } 
                    } 
                    start = end + 1; 
                    end = directory.indexOf("/", start); 
                    // 检查所有目录是否创建完毕 
                    if (end <= start) 
                    { 
                        break; 
                    } 
                } 
            } 
        }
        /*****执行文件上传******/ 
        InputStream input = null;
        try 
        {
            input = new FileInputStream(localAdr);
            // 保存文件remoteFileName
            success = ftp.storeFile(new String(remoteFileName.getBytes("GBK"), "iso-8859-1") , input); 
            input.close(); 
        } catch (IOException e) 
        { 
         log.error("上传文件失败:" + e.getMessage()); 
            if (input != null) 
            { 
                input.close(); 
            } 
        } finally 
        { 
         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);
            if (!success) 
            { 
             log.error("FTP用户登录："+username+"失败!");
                return success; 
            }
 
            // 转到指定上传目录
            ftp.changeWorkingDirectory(remoteAdr); 
 
            FTPFile[] fs = ftp.listFiles(); // 得到目录的相应文件列表 
            if(fs.length>0) 
            {
                success = ftp.removeDirectory(remoteAdr);
                ftp.logout();
            } 
 
        } catch (IOException e) 
        { 
         System.out.println(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);
            if (!success) 
            { 
             log.error("FTP用户登录："+username+"失败!");
                return success; 
            } 
 
            // 转到指定上传目录
            ftp.changeWorkingDirectory(remoteAdr); 
 
            FTPFile[] fs = ftp.listFiles(); // 得到目录的相应文件列表 
            if(fs.length>0) 
            {
                success = ftp.removeDirectory(remoteAdr);
                ftp.logout(); 
            } 
 
        } catch (IOException e) 
        { 
         System.out.println(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);
            if (!success) 
            { 
             log.error("FTP用户登录："+username+"失败!");
                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);
            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"); 
                    } 
                } 
            }else log.error("FTP用户登录："+username+"失败!");
        } catch (IOException e) 
        { 
         System.out.println(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(); 
    }
}