org.apache.commons.net.ftp包开发FTP客户端，实现断点续传，中文支持

zhouzaibao

浏览: 291655 次
性别:
来自: 上海

最近访客更多访客>>

wanglu187287

thousandlin

myclover

lindongbin

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

java开发相关

.net Apache Web C C#

利用org.apache.commons.net.ftp包实现一个简单的ftp客户端实用类。主要实现一下功能

1.支持上传下载。支持断点续传

2.支持进度汇报

3.支持对于中文目录及中文文件创建的支持。

具体请看代码，上面有详细的注释。简化版本请参见http://zhouzaibao.iteye.com/blog/342766

枚举类UploadStatus代码

public enum UploadStatus {
	Create_Directory_Fail,		//远程服务器相应目录创建失败
	Create_Directory_Success,	//远程服务器闯将目录成功
	Upload_New_File_Success,	//上传新文件成功
	Upload_New_File_Failed,		//上传新文件失败
	File_Exits,					//文件已经存在
	Remote_Bigger_Local,		//远程文件大于本地文件
	Upload_From_Break_Success,	//断点续传成功
	Upload_From_Break_Failed,	//断点续传失败
	Delete_Remote_Faild;		//删除远程文件失败
}

枚举类DownloadStatus代码

public enum DownloadStatus {
	Remote_File_Noexist,	//远程文件不存在
	Local_Bigger_Remote,	//本地文件大于远程文件
	Download_From_Break_Success,	//断点下载文件成功
	Download_From_Break_Failed,		//断点下载文件失败
	Download_New_Success,			//全新下载文件成功
	Download_New_Failed;			//全新下载文件失败
}

核心FTP代码

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
 * @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();
			if(isDo){
				result = DownloadStatus.Download_From_Break_Success;
			}else {
				result = DownloadStatus.Download_From_Break_Failed;
			}
		}else {
			OutputStream out = new FileOutputStream(f);
			InputStream in= ftpClient.retrieveFileStream(new String(remote.getBytes("GBK"),"iso-8859-1"));
			byte[] bytes = new byte[1024];
			long step = lRemoteSize /100;
			long process=0;
			long localSize = 0L;
			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 upNewStatus = ftpClient.completePendingCommand();
			if(upNewStatus){
				result = DownloadStatus.Download_New_Success;
			}else {
				result = DownloadStatus.Download_New_Failed;
			}
		}
		return result;
	}
	
	/**
	 * 上传文件到FTP服务器，支持断点续传
	 * @param local 本地文件名称，绝对路径
	 * @param remote 远程文件路径，使用/home/directory1/subdirectory/file.ext 按照Linux上的路径指定方式，支持多级目录嵌套，支持递归创建不存在的目录结构
	 * @return 上传结果
	 * @throws IOException
	 */
	public UploadStatus upload(String local,String remote) throws IOException{
		//设置PassiveMode传输
		ftpClient.enterLocalPassiveMode();
		//设置以二进制流的方式传输
		ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
		ftpClient.setControlEncoding("GBK");
		UploadStatus result;
		//对远程目录的处理
		String remoteFileName = remote;
		if(remote.contains("/")){
			remoteFileName = remote.substring(remote.lastIndexOf("/")+1);
			//创建服务器远程目录结构，创建失败直接返回
			if(CreateDirecroty(remote, ftpClient)==UploadStatus.Create_Directory_Fail){
				return UploadStatus.Create_Directory_Fail;
			}
		}
		
		//检查远程是否存在文件
		FTPFile[] files = ftpClient.listFiles(new String(remoteFileName.getBytes("GBK"),"iso-8859-1"));
		if(files.length == 1){
			long remoteSize = files[0].getSize();
			File f = new File(local);
			long localSize = f.length();
			if(remoteSize==localSize){
				return UploadStatus.File_Exits;
			}else if(remoteSize > localSize){
				return UploadStatus.Remote_Bigger_Local;
			}
			
			//尝试移动文件内读取指针,实现断点续传
			result = uploadFile(remoteFileName, f, ftpClient, remoteSize);
			
			//如果断点续传没有成功，则删除服务器上文件，重新上传
			if(result == UploadStatus.Upload_From_Break_Failed){
				if(!ftpClient.deleteFile(remoteFileName)){
					return UploadStatus.Delete_Remote_Faild;
				}
				result = uploadFile(remoteFileName, f, ftpClient, 0);
			}
		}else {
			result = uploadFile(remoteFileName, new File(local), ftpClient, 0);
		}
		return result;
	}
	/**
	 * 断开与远程服务器的连接
	 * @throws IOException
	 */
	public void disconnect() throws IOException{
		if(ftpClient.isConnected()){
			ftpClient.disconnect();
		}
	}
	
	/**
	 * 递归创建远程服务器目录
	 * @param remote 远程服务器文件绝对路径
	 * @param ftpClient FTPClient对象
	 * @return 目录创建是否成功
	 * @throws IOException
	 */
	public UploadStatus CreateDirecroty(String remote,FTPClient ftpClient) throws IOException{
		UploadStatus status = UploadStatus.Create_Directory_Success;
		String directory = remote.substring(0,remote.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(remote.substring(start,end).getBytes("GBK"),"iso-8859-1");
				if(!ftpClient.changeWorkingDirectory(subDirectory)){
					if(ftpClient.makeDirectory(subDirectory)){
						ftpClient.changeWorkingDirectory(subDirectory);
					}else {
						System.out.println("创建目录失败");
						return UploadStatus.Create_Directory_Fail;
					}
				}
				
				start = end + 1;
				end = directory.indexOf("/",start);
				
				//检查所有目录是否创建完毕
				if(end <= start){
					break;
				}
			}
		}
		return status;
	}
	
	/**
	 * 上传文件到服务器,新上传和断点续传
	 * @param remoteFile 远程文件名，在上传之前已经将服务器工作目录做了改变
	 * @param localFile 本地文件File句柄，绝对路径
	 * @param processStep 需要显示的处理进度步进值
	 * @param ftpClient FTPClient引用
	 * @return
	 * @throws IOException
	 */
	public UploadStatus uploadFile(String remoteFile,File localFile,FTPClient ftpClient,long remoteSize) throws IOException{
		UploadStatus status;
		//显示进度的上传
		long step = localFile.length() / 100;
		long process = 0;
		long localreadbytes = 0L;
		RandomAccessFile raf = new RandomAccessFile(localFile,"r");
		OutputStream out = ftpClient.appendFileStream(new String(remoteFile.getBytes("GBK"),"iso-8859-1"));
		//断点续传
		if(remoteSize>0){
			ftpClient.setRestartOffset(remoteSize);
			process = remoteSize /step;
			raf.seek(remoteSize);
			localreadbytes = remoteSize;
		}
		byte[] bytes = new byte[1024];
		int c;
		while((c = raf.read(bytes))!= -1){
			out.write(bytes,0,c);
			localreadbytes+=c;
			if(localreadbytes / step != process){
				process = localreadbytes / step;
				System.out.println("上传进度:" + process);
				//TODO 汇报上传状态
			}
		}
		out.flush();
		raf.close();
		out.close();
		boolean result =ftpClient.completePendingCommand();
		if(remoteSize > 0){
			status = result?UploadStatus.Upload_From_Break_Success:UploadStatus.Upload_From_Break_Failed;
		}else {
			status = result?UploadStatus.Upload_New_File_Success:UploadStatus.Upload_New_File_Failed;
		}
		return status;
	}
	
	public static void main(String[] args) {
		ContinueFTP myFtp = new ContinueFTP();
		try {
			myFtp.connect("192.168.21.181", 21, "nid", "123");
//			myFtp.ftpClient.makeDirectory(new String("电视剧".getBytes("GBK"),"iso-8859-1"));
//			myFtp.ftpClient.changeWorkingDirectory(new String("电视剧".getBytes("GBK"),"iso-8859-1"));
//			myFtp.ftpClient.makeDirectory(new String("走西口".getBytes("GBK"),"iso-8859-1"));
//			System.out.println(myFtp.upload("E:\\yw.flv", "/yw.flv",5));
//			System.out.println(myFtp.upload("E:\\走西口24.mp4","/央视走西口/新浪网/走西口24.mp4"));
			System.out.println(myFtp.download("/央视走西口/新浪网/走西口24.mp4", "E:\\走西口242.mp4"));
			myFtp.disconnect();
		} catch (IOException e) {
			System.out.println("连接FTP出错："+e.getMessage());
		}
	}
}

16
顶

0
踩

分享到：

java中File.listFiles(FileFilter) FileFil ... | jdom结合xpath读取xml数据内容

2009-03-09 17:58
浏览 15822
评论(23)
分类:企业架构
查看更多

23 楼 zlb824 2012-07-12

问楼主一个问题，先定位于264行，如下：
OutputStream out = ftpClient.appendFileStream(new String(remoteFile.getBytes("GBK"),"iso-8859-1"));
这一句在执行的时候返回的是null，找了一下API文档，发现是因为远程文件不存在。所以，这里我有一个疑问，难道还得先手动在服务器上创建此文件才能再进行上传吗？

22 楼 6214832 2012-03-26

楼主，在Linux下搭建的服务器上上传下载没有问题，但是用xlight搭了个ftp服务器，用这个代码出了很多问题，是为什么呢？

21 楼 xiongshulan 2011-10-26

好文章多谢楼主

20 楼 ruijin5566 2011-09-23

很好，学习了。就是上传文件为中文名时控制台会输出乱码。
请问楼主：
我从本地上传文件时会重命名文件名为：本机IP地址+现在的时间，如127.0.0.1.2011-9-23-17-33。这时如果连接中断，继续上传的时候所上传的文件名已经改变了，那么怎么实现断点续传呢？
还有我先上传文件到FTP临时目录temp下，上传完成后再将临时目录下的文件转移到正式目录下，有什么方法可以实现？
望楼主解答，感激不尽！

19 楼 nolongerc 2010-11-22

我想请问FTP 上传或下载操作的间隔时间稍有几分钟 FTP response 421 received. Server closed connection.

18 楼 zhouzaibao 2010-03-06

hanmo110 写道

楼主你好，当我上传断网后，网再连接时，再次上传不法续传，出现Cannot create file错误，请指教。谢谢！

在此上传不是重新创建文件上传，而是打开文件继续写入，你检查该文件是否被占用，然后看看逻辑结构。

17 楼 hanmo110 2010-03-05

楼主你好，当我上传断网后，网再连接时，再次上传不法续传，出现Cannot create file错误，请指教。谢谢！

16 楼 lt0604 2010-02-08

chai_spring1129 写道

我在本地上传时没错，可代码放到服务器上，上传找不到客户端的文件，出现“系统找不到指定文件”

在web项目里面不能这样调用，你的web客户端根本就没有class文件，你调用的是服务器的class文件（相对于FTP服务器来说，你的wen服务器才是真正的FtpClient），做WEB的FTP上传需要web客户端调用java applet。

15 楼 zhouzaibao 2010-01-21

331008019 写道

我试了一下，不知道为什么在我机器上不能创建中文目录

你慢慢调试一下，把错误信息打印出来吧，我这里是没有任何问题的。

14 楼 331008019 2010-01-12

我试了一下，不知道为什么在我机器上不能创建中文目录

13 楼 zhouzaibao 2009-12-23

mzyp 写道

zhouzaibao 写道

chai_spring1129 写道

我在本地上传时没错，可代码放到服务器上，上传找不到客户端的文件，出现“系统找不到指定文件”

这个就是你部署的问题了，建议你仔细分析一下错误信息。

我也遇到同样问题,本机做web服务器,一切正常,但部署到服务器后,再从客户端IE上传时,就提示“系统找不到指定文件”,给我的感觉是,好象未能通过WEB页面访问本地文件,楼主说是部署问题,能否详加描述,不胜感激,再次鸣谢

web我没有部署过，具体的你就看看异常吧，我觉得

12 楼 mzyp 2009-12-15

zhouzaibao 写道

chai_spring1129 写道

我在本地上传时没错，可代码放到服务器上，上传找不到客户端的文件，出现“系统找不到指定文件”

这个就是你部署的问题了，建议你仔细分析一下错误信息。

11 楼 zhouzaibao 2009-12-01

chai_spring1129 写道

我在本地上传时没错，可代码放到服务器上，上传找不到客户端的文件，出现“系统找不到指定文件”

这个就是你部署的问题了，建议你仔细分析一下错误信息。

10 楼 chai_spring1129 2009-11-30

我在本地上传时没错，可代码放到服务器上，上传找不到客户端的文件，出现“系统找不到指定文件”

9 楼 zhouzaibao 2009-07-02

caiway 写道

楼主，除了需要Commons net2.0的jar包，能够把其他需要的相关的jar包列出来吗？方便大家学习使用。
谢谢！

因为项目过大，不方便，我也不想清理了

8 楼 caiway 2009-06-25

楼主，除了需要Commons net2.0的jar包，能够把其他需要的相关的jar包列出来吗？方便大家学习使用。
谢谢！

7 楼 zhouzaibao 2009-06-10

因为是目录切换问题，第一次的时候你的工作目录已经切换了
第二次你需要切换到根目录才可以，不然他就找不到文件了

6 楼 gousheng12345 2009-06-10

楼主你好，请问为什么我的main函数写成这个样
    public static void main(String[] args) {
        JContinueFTPUtil myFtp = new JContinueFTPUtil();
        System.out.println("第一次");
        try
        {
        myFtp.connect("127.0.0.1", 21, "gou", "gou");
        System.out.println(myFtp.download("("/央视走西口/新浪网/走西口24.mp4", "D:\\走西口24.mp4"));
        myFtp.disconnect();
        }
        catch (IOException e)
        {
            System.out.println("连接FTP出错："+e.getMessage());
        }
        System.out.println("第二次");
        try {
       myFtp.connect("127.0.0.1", 21, "gou", "gou");
        System.out.println(myFtp.download("/图片/地质图.jpg", "D:\\地质图.jpg"));
       myFtp.disconnect();
       }
        catch (IOException e)
        {
           System.out.println("连接FTP出错："+e.getMessage());
       }
    }

连续调用的时候，第一次可以正确的传输文件，二第二次的时候就会报远程文件不存在
Remote_File_Noexist 这样的错误呢，我的服务器端已经有了这样的文件了，请赐教，谢谢

5 楼 h819 2009-03-16

谢谢，楼主很热情，更新很快

4 楼 zhouzaibao 2009-03-16

h819 写道

open.mis.data.DownloadStatus
open.mis.data.UploadStatus

两个包类在哪里？

另外，是否根据最新的 commons net 2.0 改写过了?

目前已经更新文档，两个包也在上面

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论