`

java操作ftp

 
阅读更多

FTP文件操作

 

1.环境

a) 先在另外机器上面安装一个FTP服务器,我选择的是SERV-U。这个比较好。先安装,然后设置FTPIP,目录,用户名,密码,权限等,通过管理界面能很快速的进行配置OK 

2.所需要的jar

a) commons-net-3.2.jar 

 

三.介绍

a) ftpClient类囊括了Java对于ftp服务器上的一系列操作。 

b) ftpClient类继承自ftp类,增加了上传文件流、下载文件流、获得目录名称和文件名称等一系列操作

 

四.中文问题

下面三行代码必须要,而且不能改变编码格式,否则不能正确下载中文文件

    ftp.setControlEncoding("GBK");

    FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_NT);

conf.setServerLanguageCode("zh");

五、httpftp文件操作的对比

 以下列出了一些两者的不同点:

 

1HTTP协议是用来浏览网站的,而FTP是用来访问和传输文件的,FTP文件传输有点批量上传和维护网站的意思,而HTTP文件传输更多的是为终端用户提供文件传输,比如电影、图片、音乐之类。

 

2HTTP 和 FTP 客户端:通常的HTTP客户端就是浏览器,而FTP服务可以通过命令行或者用户自有的图形界面客户端。

 

3HTTP 头:HTTP 头包含了 metadata ,比如说最后更改的日期、编码方式、服务器名称版本还有其他的一些信息,而这些在FTP中是不存在的。

 

4FTP要比HTTP早出现10年左右。

 

5、数据格式:FTP能传输ACSII数据或者二进制格式的数据,而HTTP只用二进制格式。

 

6HTTP中的流水线:HTTP支持流水线,这就意味着客户端可以在上一个请求处理完之前,发出下一个请求,其结果就是多次请求数据之前省掉了部分服务器客户端往返时延。而FTP并没有这项支持。

 

7HTTP中的动态端口:FTP一个最大的问题就是它使用两个连接,第一个连接用来发送控制指令,当接受或者发送数据的时候,又打开第二个TCP连接。而HTTP在双向传输中使用动态端口。

 

8HTTP中的持久连接:对一个HTTP会话来讲,客户端可以维护一个单个的连接并使用它进行任意数量的数据传输。FTP每次有数据的需要时都创建一个新的连接。重复的创建新的连接带来的体验并不好,因为每次创建连接都必须让双方握手验证,这消耗了很多时间。

 

9HTTP中的压缩算法:HTTP提供了一个在一些压缩算法中客户端和服务器共同协商选择的办法。其中gzip可以说是最有影响力的一种,而FTP中并不存在这种复杂的算法。

 

10HTTP支持代理:HTTP一个很大的特点就是支持代理,这种功能是构建在协议里的,而FTP并不支持。

 

11、而FTP也能脱颖而出的一点是这个协议是直接面向文件级别的。这以为着FTP有例如可以通过命令列出远程服务器上的目录列表,而HTTP没有这个概念。

 

12、速度:可能最通常的问题了:哪一个传输更快?

    什么使FTP服务更快?

    1、没有在发出的数据中加入meta-data,仅传输原二进制文件。

    2、没有过度的分块编码

    什么使HTTP服务更快?

    1、重用已存在的持久连接,从而有更好的TCP表现。

    2、流水线的支持使得从同一个服务器上请求多个文件更快。

    3、自动的压缩机制使得传输的数据更少。

    4、没有命令/应答机制最大限度的减少了往返时延。

总结:当然最终的结果会因具体的情况而异,但我想说的是,单次传输一个静态的文件,很难衡量两者的区别对单个的小文件来说,FTP传输更快,当传输多个文件时,HTTP更快。

六 代码

package com.study;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URLEncoder;


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;

/**
 * @author ljh
 * 
 */
public class FTPUtil {
/**
 * 上传程序方法
 * @param url  ftp服务器地址
 * @param port  ftp端口号默认21
 * @param username  登录用户名
 * @param password	 登录密码
 * @param path			上传的目录
 * @param filename	文件名
 * @param input		输入流
 * @return
 */
	public boolean uploadFile(String url, int port, String username,
			String password, String path, String filename, InputStream input) {
		// filename:要上传的文件
		// path :上传的路径
		// 初始表示上传失败
		boolean success = false;
		// 创建FTPClient对象
		FTPClient ftp = new FTPClient();
		try {
			int reply;
			// 连接FTP服务器
			// 如果采用默认端口,可以使用ftp.connect(url)的方式直接连接FTP服务器
			ftp.connect(url, port);
			// 下面三行代码必须要,而且不能改变编码格式,否则不能正确下载中文文件
			ftp.setControlEncoding("GBK");
			FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_NT);
			conf.setServerLanguageCode("zh");
			// 登录ftp
			ftp.login(username, password);
			// 看返回的值是不是230,如果是,表示登陆成功
			reply = ftp.getReplyCode();
			// 以2开头的返回值就会为真
			if (!FTPReply.isPositiveCompletion(reply)) {
				ftp.disconnect();
				System.out.println("连接服务器失败");
				return success;
			}
			System.out.println("登陆服务器成功");
			ftp.changeWorkingDirectory(path);// 转移到FTP服务器目录
			FTPFile[] fs = ftp.listFiles(); // 得到目录的相应文件列表
			System.out.println(fs.length);
			System.out.println(filename);
			String filename1 = FTPUtil.changeName(filename, fs);

			String filename2 = new String(filename1.getBytes("GBK"),
					"ISO-8859-1");
			String path1 = new String(path.getBytes("GBK"), "ISO-8859-1");
			System.out.println(ftp.mkd(path1)+"ssssssssss");
//			if(ftp.mkd(path1)==501){
//				Boolean b = ftp.makeDirectory(path1);
//				System.out.println(b);
//			}
			// 转到指定上传目录
			ftp.changeWorkingDirectory(path1);
			// 将上传文件存储到指定目录
			// ftp.appendFile(new String(filename.getBytes("GBK"),"ISO-8859-1"),
			// input);
			ftp.setFileType(FTP.BINARY_FILE_TYPE);
			// 如果缺省该句 传输txt正常 但图片和其他格式的文件传输出现乱码
			ftp.storeFile(filename2, input);
			// 关闭输入流
			input.close();
			// 退出ftp
			ftp.logout();
			// 表示上传成功
			success = true;
			System.out.println("上传成功。。。。。。");
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			if (ftp.isConnected()) {
				try {
					ftp.disconnect();
				} catch (IOException ioe) {
				}
			}
		}
		return success;
	}
	
	
	 /**
	  * 删除程序
	  * 
	  */
	 public boolean deleteFile(String url, int port, String username,
	   String password, String path, String filename) {
	  // filename:要上传的文件
	  // path :上传的路径
	  // 初始表示上传失败
	  boolean success = false;
	  // 创建FTPClient对象
	  FTPClient ftp = new FTPClient();
	  try {
	   int reply;
	   // 连接FTP服务器
	   // 如果采用默认端口,可以使用ftp.connect(url)的方式直接连接FTP服务器
	   ftp.connect(url, port);
	   // 下面三行代码必须要,而且不能改变编码格式,否则不能正确下载中文文件
	   ftp.setControlEncoding("GBK");
	   FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_NT);
	   conf.setServerLanguageCode("zh");
	   // 登录ftp
	   ftp.login(username, password);
	   // 看返回的值是不是230,如果是,表示登陆成功
	   reply = ftp.getReplyCode();
	   // 以2开头的返回值就会为真
	   if (!FTPReply.isPositiveCompletion(reply)) {
	    ftp.disconnect();
	    System.out.println("连接服务器失败");
	    return success;
	   }
	   System.out.println("登陆服务器成功");
	   String filename2 = new String(filename.getBytes("GBK"),
	     "ISO-8859-1");
	   String path1 = new String(path.getBytes("GBK"), "ISO-8859-1");
	   // 转到指定上传目录
	   ftp.changeWorkingDirectory(path1);
	   FTPFile[] fs = ftp.listFiles(); // 得到目录的相应文件列表
	   ftp.deleteFile(filename2);
	   System.out.println("删除文件成功。。。");
	   ftp.logout();
	   success=true;
	  } catch (IOException e) {
	System.out.println(e);    
	  } finally {
	   if (ftp.isConnected()) {
	    try {
	     ftp.disconnect();
	    } catch (IOException ioe) {
	    }
	   }
	  }
	  return success;
	 }
	
	
	 /**
	  * 下载程序
	  * 
	  */
	 public static boolean downFile(String ip, int port, String username,
	   String password, String remotePath, String fileName,
	   OutputStream outputStream) {
	  boolean success = false;
	  FTPClient ftp = new FTPClient();
	  try {
	   int reply;
	   ftp.connect(ip, port);
	   // 下面三行代码必须要,而且不能改变编码格式
	   ftp.setControlEncoding("GBK");
	   FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_NT);
	   conf.setServerLanguageCode("zh");
	   // 如果采用默认端口,可以使用ftp.connect(url) 的方式直接连接FTP服务器
	   ftp.login(username, password);// 登录
	   ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
	   reply = ftp.getReplyCode();
	   if (!FTPReply.isPositiveCompletion(reply)) {
	    ftp.disconnect();
	    return success;
	   }
	   System.out.println("登陆成功。。。。");
	   ftp.changeWorkingDirectory(remotePath);// 转移到FTP服务器目录
//	   FTPFile[] fs = ftp.listFiles("./study/study/新.txt");
	   FTPFile[] fs = ftp.listFiles();
	   // 得到目录的相应文件列表
	   // System.out.println(fs.length);//打印列表长度
	   for (int i = 0; i < fs.length; i++) {
	    FTPFile ff = fs[i];
	    if (ff.getName().equals(fileName)) {
	     String filename = fileName;
	     // 这个就就是弹出下载对话框的关键代码
//	     response.setHeader("Content-disposition",
//	       "attachment;filename="
//	         + URLEncoder.encode(filename, "utf-8"));
	     // 将文件保存到输出流outputStream中
	     ftp.retrieveFile(new String(ff.getName().getBytes("GBK"),
	       "ISO-8859-1"), outputStream);
	     outputStream.flush();
	     outputStream.close();
	     System.out.println("下载成功。。。。");
	    }
	   }
	   ftp.logout();
	   success = true;
	  } catch (IOException e) {
	   e.printStackTrace();
	  } finally {
	   if (ftp.isConnected()) {
	    try {
	     ftp.disconnect();
	    } catch (IOException ioe) {
	    }
	   }
	  }
	  return success;
	 }

	// 判断是否有重名方法
	public static boolean isDirExist(String fileName, FTPFile[] fs) {
		for (int i = 0; i < fs.length; i++) {
			FTPFile ff = fs[i];
			if (ff.getName().equals(fileName)) {
				return true; // 如果存在返回 正确信号
			}
		}
		return false; // 如果不存在返回错误信号
	}

	// 根据重名判断的结果 生成新的文件的名称
	public static String changeName(String filename, FTPFile[] fs) {
		int n = 0;
		// 创建一个可变的字符串对象 即StringBuffer对象,把filename值付给该对象
		StringBuffer filename1 = new StringBuffer("");
		filename1 = filename1.append(filename);
		System.out.println(filename1);
		while (isDirExist(filename1.toString(), fs)) {
			n++;
			String a = "[" + n + "]";
			System.out.println("字符串a的值是:" + a);
			int b = filename1.lastIndexOf(".");// 最后一出现小数点的位置
			int c = filename1.lastIndexOf("[");// 最后一次"["出现的位置
			if (c < 0) {
				c = b;
			}
			StringBuffer name = new StringBuffer(filename1.substring(0, c));// 文件的名字
			StringBuffer suffix = new StringBuffer(filename1.substring(b + 1));// 后缀的名称
			filename1 = name.append(a).append(".").append(suffix);
		}
		return filename1.toString();
	}
}


 

 

 

 

 

 

 

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics