转自 http://zhangnet1.iteye.com/blog/907109

?

org.apache.commons.net.ftp.FTPClient

使用org.apache.commons.net.ftp包开发FTP客户端，实现进度汇报，实现断点续传，中文支持
利用org.apache.commons.net.ftp包实现一个简单的ftp客户端实用类。主要实现一下功能
1.支持上传下载。支持断点续传
2.支持进度汇报
3.支持对于中文目录及中文文件创建的支持。

import java.io.File; 
import java.io.FileOutputStream; 
import java.io.IOException; 
import java.io.InputStream; 
import java.io.OutputStream; 
import java.io.PrintWriter; 
import java.io.RandomAccessFile; 
 
import open.mis.data.DownloadStatus; 
import open.mis.data.UploadStatus; 
 
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.FTPFile; 
import org.apache.commons.net.ftp.FTPReply; 
 
/** *//**
* 支持断点续传的FTP实用类
* @author BenZhou  http://www.bt285.cn
* @version 0.1 实现基本断点上传下载
* @version 0.2 实现上传下载进度汇报
* @version 0.3 实现中文目录创建及中文文件创建，添加对于中文的支持
*/
public class ContinueFTP { 
    public FTPClient ftpClient = new FTPClient(); 
     
    public ContinueFTP(){ 
        //设置将过程中使用到的命令输出到控制台 
        this.ftpClient.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out))); 
    } 
     
    /** *//**
     * 连接到FTP服务器
     * @param hostname 主机名
     * @param port 端口
     * @param username 用户名
     * @param password 密码
     * @return 是否连接成功
     * @throws IOException
     */
    public boolean connect(String hostname,int port,String username,String password) throws IOException{ 
        ftpClient.connect(hostname, port); 
        ftpClient.setControlEncoding("GBK"); 
        if(FTPReply.isPositiveCompletion(ftpClient.getReplyCode())){ 
            if(ftpClient.login(username, password)){ 
                return true; 
            } 
        } 
        disconnect(); 
        return false; 
    } 
     
    /** *//**
     * 从FTP服务器上下载文件,支持断点续传，上传百分比汇报
     * @param remote 远程文件路径
     * @param local 本地文件路径
     * @return 上传的状态
     * @throws IOException
     */
    public DownloadStatus download(String remote,String local) throws IOException{ 
        //设置被动模式 
        ftpClient.enterLocalPassiveMode(); 
        //设置以二进制方式传输 
        ftpClient.setFileType(FTP.BINARY_FILE_TYPE); 
        DownloadStatus result; 
         
        //检查远程文件是否存在 
        FTPFile[] files = ftpClient.listFiles(new String(remote.getBytes("GBK"),"iso-8859-1")); 
        if(files.length != 1){ 
            System.out.println("远程文件不存在"); 
            return DownloadStatus.Remote_File_Noexist; 
        } 
         
        long lRemoteSize = files[0].getSize(); 
        File f = new File(local); 
        //本地存在文件，进行断点下载 
        if(f.exists()){ 
            long localSize = f.length(); 
            //判断本地文件大小是否大于远程文件大小 
            if(localSize >= lRemoteSize){ 
                System.out.println("本地文件大于远程文件，下载中止"); 
                return DownloadStatus.Local_Bigger_Remote; 
            } 
             
            //进行断点续传，并记录状态 
            FileOutputStream out = new FileOutputStream(f,true); 
            ftpClient.setRestartOffset(localSize); 
            InputStream in = ftpClient.retrieveFileStream(new String(remote.getBytes("GBK"),"iso-8859-1")); 
            byte[] bytes = new byte[1024]; 
            long step = lRemoteSize /100; 
            long process=localSize /step; 
            int c; 
            while((c = in.read(bytes))!= -1){ 
                out.write(bytes,0,c); 
                localSize+=c; 
                long nowProcess = localSize /step; 
                if(nowProcess > process){ 
                    process = nowProcess; 
                    if(process % 10 == 0) 
                        System.out.println("下载进度："+process); 
                    //TODO 更新文件下载进度,值存放在process变量中 
                } 
            } 
            in.close(); 
            out.close(); 
            boolean isDo = ftpClient.completePendingCommand();