meiyaa2008
- 浏览: 1250 次
- 性别:
- 来自: 南京
-
文章分类
最新评论
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 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;
import com.ruanko.ebook.utils.DownloadStatus;
import com.ruanko.ebook.utils.UploadStatus;
/** *//**
* 支持断点续传的FTP实用类
* @version 0.1 实现基本断点上传下载
* @version 0.2 实现上传下载进度汇报
* @version 0.3 实现中文目录创建及中文文件创建，添加对于中文的支持
*/
public class RuankoFtpClient {
public FTPClient ftpClient = new FTPClient();
public RuankoFtpClient(){
//设置将过程中使用到的命令输出到控制台
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{
try{
ftpClient.connect(hostname, port);
System.out.println(ftpClient.getReplyString());
ftpClient.setControlEncoding("GBK");
if(FTPReply.isPositiveCompletion(ftpClient.getReplyCode())){
if(ftpClient.login(username, password)){
return true;
}
}
disconnect();
}catch(Exception e){
e.printStackTrace();
}
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 本地文件名称，绝对路径
* @return 上传结果
* @throws IOException
*/
public UploadStatus upload(String local) throws IOException {
//设置PassiveMode传输
ftpClient.enterLocalPassiveMode();
UploadStatus result;
try {
//设置以二进制流的方式传输
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
ftpClient.setControlEncoding("GBK");
//对远程目录的处理
File file = new File(local);
String remoteFileName = file.getName();
if(file.isDirectory()){
//创建服务器远程目录结构，创建失败直接返回
/*if(CreateDirecroty(remoteFileName+"/", ftpClient)==UploadStatus.Create_Directory_Fail){
return UploadStatus.Create_Directory_Fail;
}*/
result = uploadFileList(file,remoteFileName,remoteFileName,1);
}else{
//本地文件名称
result = uploadToFtp(local,remoteFileName);
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
throw e;
}
return result;
}
public UploadStatus uploadFileList(File file,String fileName,String remote,int level) throws IOException{
UploadStatus result = null;
File[] fileList = file.listFiles();
ftpClient.changeWorkingDirectory("/");
ftpClient.makeDirectory(new String(fileName.getBytes("GBK"),"ISO-8859-1"));
//递归遍历文件并上传
for(int i = 0;i < fileList.length; i++){
if(fileList[i].isDirectory()){
if((level+1)>2){
remote = remote+"/"+fileList[i].getParentFile().getName();
}
String temName = "";
temName = remote+"/"+fileList[i].getName()+"/";
result = uploadFileList(fileList[i],temName,remote,level+1);
}else{
String remoteFileName = fileName+fileList[i].getName();
String local = fileList[i].getAbsolutePath();
result = uploadToFtp(local,remoteFileName);
}
}
return result;
}
public UploadStatus uploadToFtp(String local,String fileName) throws IOException{
//设置PassiveMode传输
ftpClient.enterLocalPassiveMode();
UploadStatus result;
try{
//设置以二进制流的方式传输
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
ftpClient.setControlEncoding("GBK");
String remoteFileName = fileName;
String remoteDirectory = "";
if(fileName.contains("/")){
remoteFileName = fileName.substring(fileName.lastIndexOf("/")+1);
remoteDirectory = fileName.substring(0,fileName.lastIndexOf("/"));
}
//检查远程是否存在文件
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,remoteDirectory);
//如果断点续传没有成功，则删除服务器上文件，重新上传
if(result == UploadStatus.Upload_From_Break_Failed){
if(!ftpClient.deleteFile(remoteFileName)){
return UploadStatus.Delete_Remote_Faild;
}
result = uploadFile(remoteFileName, f, ftpClient, 0,remoteDirectory);
}
}else {
result = uploadFile(remoteFileName, new File(local), ftpClient, 0,remoteDirectory);
}
}catch(IOException e){
e.printStackTrace();
throw e;
}
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,String remoteDirectory) throws IOException{
ftpClient.changeWorkingDirectory(new String(remoteDirectory.getBytes("GBK"),"ISO-8859-1"));
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();
//发送NOOP指令防止上传时间过长连接假死现象
ftpClient.sendNoOp();
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) {
RuankoFtpClient myFtp = new RuankoFtpClient();
try {
// myFtp.connect("183.62.138.57", 21, "ebook_root", "ebook_root#@!");
// myFtp.upload("d:/909053ecf197432c89727531574724d3/documentFiles/S_001.pdf");
// System.out.println("上传成功！！！");
// myFtp.disconnect();
String test = "C:\\Program Files\\Apache Software Foundation\\tomcat 6.0\\webapps\\Ebook\\Document\\701c70c3a9804b3094f7056e608d32b2\\epub\\b.epub@@@@@C:\\Program Files\\Apache Software Foundation\\Tomcat 6.0\\webapps\\Ebook\\Document\\a86b97fa0bbc47a5b3aa6943689856ac\\epub\\a.epub@@@@@C:\\Program Files\\Apache Software Foundation\\Tomcat 6.0\\webapps\\Ebook\\Document\\909053ecf197432c89727531574724d3\\epub\\c.epub";
RuankoFtpClient ruankoFtpClient = new RuankoFtpClient();
ruankoFtpClient.connect("127.0.0.1", 21, "super", "super");
System.out.println(test.toString());
ruankoFtpClient.download("/epub4.epub", "F://epub/epub4.epub");
// if(test!=null){
// String[] uploads = test.toString().split("@@@@@");
// for(int m = 0;m < uploads.length; m++ ){
//
// String tmpLoad = uploads[m];
// System.out.println(ruankoFtpClient.upload(tmpLoad));
// }
// }
//释放ftp连接
ruankoFtpClient.disconnect();
} catch (IOException e) {
System.out.println("连接FTP出错："+e.getMessage());
}
}
}
分享到：
发表评论
相关推荐
**VB API FTP上传下载源代码详解** 在信息技术领域，FTP（File Transfer Protocol）是一种用于在网络上进行文件传输的标准协议。在VB（Visual Basic）环境中，我们可以使用API（Application Programming Interface...
在这个场景中，"一个ftp上传下载类(MFC)" 是一个使用MFC构建的类，它封装了FTP协议，使得开发者能够方便地在自己的应用中实现FTP的上传和下载功能。 FTP上传下载类的核心功能包括： 1. **连接与断开**：类应包含...
总的来说，VC++ FTP上传下载涉及网络编程、文件操作和XML处理等多个方面。开发者需要熟悉WinInet API或第三方FTP库的使用，理解FTP协议的工作原理，以及如何在C++中处理XML文件。通过这些技术，可以在VC++环境中实现...
VB6 FTP 上传 下载 源代码,用的API,不是那种控件版本,拿来就能用. VB6 FTP 上传 下载 源代码,用的API,不是那种控件版本,拿来就能用. VB6 FTP 上传 下载 源代码,用的API,不是那种控件版本,拿来就能用.
**Qt4实现FTP上传下载服务器** Qt是一个跨平台的C++图形用户界面应用程序开发框架，广泛应用于桌面和移动设备的应用程序开发。FTP（File Transfer Protocol）是互联网上用于文件传输的标准协议，允许用户从远程主机...
FTP上传下载文件
C# FTP上传下载是开发过程中常见的一项任务，它涉及到网络通信和文件操作。在C#中，我们可以利用System.Net命名空间中的FtpWebRequest和FtpWebResponse类来实现FTP（File Transfer Protocol）的功能。下面将详细介绍...
在这个“FTP上传下载文件demo”项目中，开发者使用C++编程语言在Visual Studio 2010环境下创建了一个功能完备的FTP客户端应用。这个应用能够执行基本的FTP操作，包括上传文件到远程FTP服务器、从服务器下载文件以及...
四、FTP上传下载的进阶功能 1. 递归上传/下载目录：可以遍历本地目录，逐个上传或下载文件。 2. 断点续传：如果文件较大，可以记录已传输的部分，在下次连接时继续上传或下载。 3. 多线程上传/下载：通过多线程同时...
这篇博客文章“qt ftp上传下载”探讨了如何在Qt环境中实现FTP的上传和下载功能。我们将详细解析这个主题，了解相关知识点。 首先，要实现FTP功能，你需要使用Qt库中的QFtp模块。QFtp类提供了FTP客户端的功能，可以...
Java编写的FTP上传下载工具是一种基于Java语言实现的文件传输应用程序，主要功能是与FTP（File Transfer Protocol）服务器进行交互，实现文件的上传和下载。这个工具特别之处在于它支持多用户登录，这意味着不同的...
在本文中，我们将深入探讨FTP上传下载的C#源代码实现及其相关的知识点。 一、FTP基本概念 FTP允许用户在两台计算机之间交换文件，通常涉及一个服务器（提供文件）和一个客户端（请求文件）。它使用TCP作为传输层...
### VB FTP上传下载知识点解析 #### 一、概述 在提供的代码示例中，主要涉及了使用Visual Basic（简称VB）进行FTP（File Transfer Protocol，文件传输协议）上传与下载的功能实现。FTP是一种用于在网络上进行文件...
VisualC 实效编程 99 FTP上传下载VisualC 实效编程 99 FTP上传下载VisualC 实效编程 99 FTP上传下载VisualC 实效编程 99 FTP上传下载VisualC 实效编程 99 FTP上传下载VisualC 实效编程 99 FTP上传下载VisualC 实效...
ftp上传下载 linux环境下程序 网络高级程序设计课程实验
"ftp上传下载图片" FTP（File Transfer Protocol，文件传输协议）是一种常用的网络协议，用于在网络上进行文件传输。FTP 协议允许用户在远程服务器上存储和检索文件。在这里，我们将讨论如何使用 C# 语言实现 FTP ...
本篇文章将深入探讨如何利用C#实现FTP上传和下载功能，并结合给定的"FTP上传下载demo"和"demo（upload）、FTPupload"这两个文件名，我们将具体分析其可能包含的代码示例。 首先，让我们了解FTP上传和下载的基本原理...
FTP上传下载的实现，网络编程 FTP SOCKET MFC 网络
Java基于Swing的FTP上传下载程序是一个用户界面友好、功能完备的应用，主要用于通过FTP（File Transfer Protocol）协议实现文件的上传和下载。Swing是Java提供的一个轻量级的GUI库，它允许开发者创建出美观且功能...