`
itace
  • 浏览: 180919 次
  • 性别: Icon_minigender_1
  • 来自: 北京
文章分类
社区版块
存档分类
最新评论

远程写FTP文件和文件夹

    博客分类:
  • FTP
阅读更多

 

    远程写FTP文件和文件夹,jar包commons-net-3.3.jar

 

 

	/**
	 * 向ftp写文件,可以多个
	 * @param c
	 * @param path :a/pdf/82jf2ijf2fs
	 * @param files
	 * @return
	 */
	public static boolean writeFTPFiles(FTPConnection c,String path,List<File> files){
		FTPClient ftp = new FTPClient();
		try {
			ftp.connect(c.getIp(), c.getPort()); // IP地址和端口 
			// 用户名和密码,匿名登陆的话用户名为anonymous,密码为非空字符串
			boolean bool = ftp.login(c.getUsername(),c.getPassword()); 
			if (!bool) {
				throw new Exception("username or password not correct!");
			}
			System.out.print(ftp.getReplyString());
			int reply = ftp.getReplyCode();

			if (!FTPReply.isPositiveCompletion(reply)) {
				ftp.disconnect();
				throw new Exception("FTP server refused connection.");
			}
			ftp.setFileType(FTPClient.BINARY_FILE_TYPE);  
			ftp.changeWorkingDirectory(c.getDirectory());
			String[]ps = path.split("/");
			for (String p : ps) {
				String[]arr = ftp.listNames();
				List<String> list = Arrays.asList(arr);
				if (!list.contains(p)) {
					ftp.makeDirectory(p);
				}
				ftp.changeWorkingDirectory(p);
			}
//			ftp.changeToParentDirectory()
			for (File file : files) {
//				String text = read(file, "iso-8859-1");
//				InputStream in = new ByteArrayInputStream(text.getBytes("iso-8859-1"));
				InputStream in = new FileInputStream(file);
				ftp.storeFile(new String(file.getName().getBytes("utf-8"),"iso-8859-1"), in);
				in.close();
			}
			ftp.logout();
			return true;
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		}finally{
			if (ftp.isConnected()) {  
				try {  
					ftp.disconnect();  
				} catch (Exception e) {  
					e.printStackTrace();  
				}  
			}  
		}
		
	}
	/**
	 * 复制文件夹及内容到ftp上
	 * @param c
	 * @param path :a/pdf/82jf2ijf2fs
	 * @param directory
	 * @return
	 */
	public static boolean writeFTPDirectory(FTPConnection c,String path,File directory){
		FTPClient ftp = new FTPClient();
		try {
			ftp.connect(c.getIp(), c.getPort()); // IP地址和端口 
			boolean bool = ftp.login(c.getUsername(),c.getPassword()); // 用户名和密码,匿名登陆的话用户名为anonymous,密码为非空字符串
			if (!bool) {
				throw new Exception("username or password not correct!");
			}
			System.out.print(ftp.getReplyString());
			int reply = ftp.getReplyCode();
			
			if (!FTPReply.isPositiveCompletion(reply)) {
				ftp.disconnect();
				throw new Exception("FTP server refused connection.");
			}
			ftp.setFileType(FTPClient.BINARY_FILE_TYPE);  
			ftp.changeWorkingDirectory(c.getDirectory());
			if (StringUtil.toString(path, null)!=null) {
				String[]ps = path.split("/");
				for (String p : ps) {
					String[]arr = ftp.listNames();
					List<String> list = Arrays.asList(arr);
					if (!list.contains(p)) {
						ftp.makeDirectory(p);
					}
					ftp.changeWorkingDirectory(p);
				}
			}
//			ftp.changeToParentDirectory()
			ftp.makeDirectory(directory.getName());
			ftp.changeWorkingDirectory(directory.getName());
			File[] files = directory.listFiles();
			for (File file : files) {
//				String text = read(file, "iso-8859-1");
//				InputStream in = new ByteArrayInputStream(text.getBytes("iso-8859-1"));
				InputStream in = new FileInputStream(file);
				ftp.storeFile(new String(file.getName().getBytes("utf-8"),"iso-8859-1"), in);
				in.close();
			}
			ftp.logout();
			return true;
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		}finally{
			if (ftp.isConnected()) {  
				try {  
					ftp.disconnect();  
				} catch (Exception e) {  
					e.printStackTrace();  
				}  
			}  
		}
		
	}
	/**
	 * 读取ftp文件内容
	 * @param c
	 * @param f
	 * @return
	 */
	public static String readFTPFile(FTPConnection c,String path,String f){
		
		try {
			FTPClient ftp = new FTPClient();
			ftp.setControlKeepAliveTimeout(6000); // set timeout to 6s
			ftp.connect(c.getIp(), c.getPort()); // IP地址和端口 
			boolean bool = ftp.login(c.getUsername(),c.getPassword()); // 用户名和密码,匿名登陆的话用户名为anonymous,密码为非空字符串
			if (!bool) {
				throw new Exception("username or password not correct!");
			}
			System.out.print(ftp.getReplyString());
			int reply = ftp.getReplyCode();

			if (!FTPReply.isPositiveCompletion(reply)) {
				ftp.disconnect();
				throw new Exception("FTP server refused connection.");
			}
			ftp.setFileType(FTPClient.BINARY_FILE_TYPE);  
			ftp.changeWorkingDirectory(c.getDirectory());
			
			String[]ps = path.split("/");
			for (String p : ps) {
				String[]arr = ftp.listNames();
				List<String> list = Arrays.asList(arr);
				if (!list.contains(p)) {
					ftp.makeDirectory(p);
				}
				ftp.changeWorkingDirectory(p);
			}
			
			InputStream in = ftp.retrieveFileStream(f);
			InputStreamReader isr = new InputStreamReader(in,"GBK");
			BufferedReader br =  new BufferedReader(isr);
			StringBuffer sb  = new StringBuffer();
			String str = null;
			while ((str=br.readLine())!=null) {
				sb.append(str);
				sb.append("\n");
			}
			br.close();
			isr.close();
			in.close();
			
			ftp.logout();
			String content = sb.toString();
//			System.out.println(content);
			return content;
		} catch (Exception e) {
			e.printStackTrace();
			return "";
		}
			
		
	}
	/**
	 * 读取ftp文件内容,写到本地
	 * @param c
	 * @param f 文件名
	 * @param localFile 本地文件path
	 * @return
	 */
	public static boolean writeLocalFile(FTPConnection c,String path,String f,String localFile){
		
		try {
			FTPClient ftp = new FTPClient();
			ftp.setControlKeepAliveTimeout(6000); // set timeout to 6s
			ftp.connect(c.getIp(), c.getPort()); // IP地址和端口 
			boolean bool = ftp.login(c.getUsername(),c.getPassword()); // 用户名和密码,匿名登陆的话用户名为anonymous,密码为非空字符串
			if (!bool) {
				throw new Exception("username or password not correct!");
			}
			System.out.print(ftp.getReplyString());
			int reply = ftp.getReplyCode();
			
			if (!FTPReply.isPositiveCompletion(reply)) {
				ftp.disconnect();
				throw new Exception("FTP server refused connection.");
			}
			ftp.setFileType(FTPClient.BINARY_FILE_TYPE);  
			ftp.changeWorkingDirectory(c.getDirectory());
			String[]ps = path.split("/");
			for (String p : ps) {
				String[]arr = ftp.listNames();
				List<String> list = Arrays.asList(arr);
				if (!list.contains(p)) {
					return false;
				}
				ftp.changeWorkingDirectory(p);
			}
			InputStream in = ftp.retrieveFileStream(f);
			if (in==null) {
				return false;
			}
			OutputStream out = new FileOutputStream(localFile);
			int ch = -1;
			while ((ch=in.read())!=-1) {
				out.write(ch);
			}
			in.close();
			out.close();
			File file = new File(localFile);
			if (file.exists()) {
				return true;
			}else{
				return false;
			}
		} catch (Exception e) {
//			e.printStackTrace();
			System.out.println(e.getMessage());
			return false;
		}
		
		
	}
	
	/**
	 * 读取ftp文件内容,写到本地
	 * @param c
	 * @param f 文件名
	 * @param localFile 本地文件path
	 * @return
	 */
	public static boolean existFTPFile(FTPConnection c,String path,String f){
		
		try {
			FTPClient ftp = new FTPClient();
			ftp.setControlKeepAliveTimeout(6000); // set timeout to 6s
			ftp.connect(c.getIp(), c.getPort()); // IP地址和端口 
			boolean bool = ftp.login(c.getUsername(),c.getPassword()); // 用户名和密码,匿名登陆的话用户名为anonymous,密码为非空字符串
			if (!bool) {
				throw new Exception("username or password not correct!");
			}
			System.out.print(ftp.getReplyString());
			int reply = ftp.getReplyCode();
			
			if (!FTPReply.isPositiveCompletion(reply)) {
				ftp.disconnect();
				throw new Exception("FTP server refused connection.");
			}
			ftp.setFileType(FTPClient.BINARY_FILE_TYPE);  
			ftp.changeWorkingDirectory(c.getDirectory());
			String[]ps = path.split("/");
			for (String p : ps) {
				String[]arr = ftp.listNames();
				List<String> list = Arrays.asList(arr);
				if (!list.contains(p)) {
					return false;
				}
				ftp.changeWorkingDirectory(p);
			}
			InputStream in = ftp.retrieveFileStream(f);
			if (in==null) {
				return false;
			}else{
				in.close();
				return true;
			}
			
		} catch (Exception e) {
//			e.printStackTrace();
			System.out.println(e.getMessage());
			return false;
		}
		
		
	}
	
	/**
	 * 
	 * @param c
	 * @param path 父路径
	 * @param file :文件夹名或者文件名
	 * @param type :1-文件夹,2-文件
	 */
	public static void deleteFTPFile(FTPConnection c,String path,String file,int type){
		FTPClient ftp = new FTPClient();
		try {
			ftp.connect(c.getIp(), c.getPort()); // IP地址和端口 
			boolean bool = ftp.login(c.getUsername(),c.getPassword()); // 用户名和密码,匿名登陆的话用户名为anonymous,密码为非空字符串
			if (!bool) {
				throw new Exception("username or password not correct!");
			}
			System.out.print(ftp.getReplyString());
			int reply = ftp.getReplyCode();
			
			if (!FTPReply.isPositiveCompletion(reply)) {
				ftp.disconnect();
				throw new Exception("FTP server refused connection.");
			}
			ftp.setFileType(FTPClient.BINARY_FILE_TYPE);  
			ftp.changeWorkingDirectory(c.getDirectory());
			
			if (StringUtil.toString(path, null)!=null) {
				String[]ps = path.split("/");
				for (String p : ps) {
					String[]arr = ftp.listNames();
					List<String> list = Arrays.asList(arr);
					if (!list.contains(p)) {
						ftp.makeDirectory(p);
					}
					ftp.changeWorkingDirectory(p);
				}
			}
			if (type==1) {
				deleteRecursive(ftp, file);
			}else if (type==2) {
				ftp.deleteFile(file);
			}
			ftp.logout();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			if (ftp.isConnected()) {  
				try {  
					ftp.disconnect();  
				} catch (Exception e) {  
					e.printStackTrace();  
				}  
			}  
		}
		
	}
	/**
	 * 递归删除所有文件
	 * @param ftp
	 * @param file
	 * @throws IOException
	 */
	public static void deleteRecursive(FTPClient ftp,String file) throws IOException{
		ftp.changeWorkingDirectory(file);
		FTPFile[]fs = ftp.listFiles();
		for (FTPFile f : fs) {
			ftp.deleteFile(f.getName());
		}
		FTPFile[]ds = ftp.listDirectories();
		for (FTPFile d : ds) {
			deleteRecursive(ftp,d.getName());
		}
		ftp.changeToParentDirectory();
		ftp.removeDirectory(file);
	}

 

 

public class FTPConnection {

	private String ip;
	private int port;
	private String username;
	private String password;
	private String directory;
}

 

 

分享到:
评论

相关推荐

    java项目实现远程UbuntuFTP下载文件和文件夹

    总之,Java结合Apache Commons Net库可以轻松实现远程Ubuntu服务器的FTP文件和文件夹下载,以及下载文件的SHA256校验。通过理解和实践这些步骤,开发者可以构建自己的FTP客户端工具,满足各种远程数据交换的需求。

    C#实现,遍历ftp上的文件夹,文件名

    本篇文章将深入探讨如何使用C#实现遍历FTP服务器上的文件夹和文件名。 首先,要实现FTP功能,你需要引入`System.Net`命名空间中的`FtpWebRequest`和`FtpWebResponse`类。这两个类提供了与FTP服务器交互的基础接口。...

    Ftp上传文件和文件夹

    总结来说,C#环境下FTP文件上传涉及的关键知识点有:FTP协议,System.Net.FtpWebRequest类的使用,网络凭据的设置,文件读取和流操作,以及可能的递归处理来上传文件夹。在实际项目中,根据需求选择合适的方法和库,...

    FTP远程上传下载文件

    FTP允许用户在本地计算机和远程FTP服务器之间交换文件。它由两部分组成:控制连接和数据连接。控制连接用于发送命令和接收响应,数据连接则用于实际的文件传输。 2. **C# FTP支持**: 在C#中,我们可以使用`...

    使用jsch中的ChannelSftp上传文件和文件夹[参考].pdf

    使用 JSCH 中的 ChannelSftp 上传文件和文件夹 JSCH(Java Secure Channel)是一款自由和开源的 Java 库,提供了安全的通信通道,包括 SSH、SFTP、SCP 等协议。 ChannelSftp 是 JSCH 中的一个实现 SFTP 协议的 ...

    使用jsch中的ChannelSftp上传文件和文件夹.pdf

    ChannelSftp是JSch库中的一部分,用于上传文件和文件夹到远程服务器上。它提供了多种方法来上传文件和文件夹,例如put()方法、get()方法等。 二、上传文件和文件夹的步骤 1. 首先,需要创建一个SFTPUtil对象,用于...

    QT ftp上传下载,创建文件夹,删除目录

    本教程将深入讲解如何使用QT进行FTP(File Transfer Protocol)操作,包括文件的上传、下载、创建文件夹以及删除目录。 FTP是一种基于TCP协议的应用层协议,用于在Internet上进行文件传输。QT库提供了...

    QFTP类实现FTP上传、下载、删除文件及文件夹

    总结,QFTP类为QT4应用提供了强大的FTP功能,包括文件和文件夹的基本操作。尽管在文件夹下载方面存在局限,但在大多数FTP需求场景下,QFTP仍然非常实用。在实际开发中,确保正确处理各种信号和槽,以确保操作的顺利...

    ftp4j 上传文件和文件夹

    FTP4J是一个用Java编写的开源库,专门用于执行FTP(文件传输协议)操作,如上传、下载和管理远程服务器上的文件。在这个场景中,我们主要关注如何利用FTP4J来上传文件和文件夹。FTP4J提供了简洁的API,使得在Java...

    上传本地文件夹的文件到FTP服务器指定目录

    5. 调用FTP上传方法:在主函数中,调用`UploadFiles`方法,传入FTP服务器地址、用户名、密码、本地文件夹路径和远程FTP目录路径,即可批量上传文件。 6. 错误处理与优化:在实际应用中,需要考虑错误处理,例如网络...

    C#下载ftp指定目录下所有文件

    在C#编程中,FTP(File Transfer Protocol)是一种常用的技术,用于在本地计算机与远程服务器之间传输文件。本文将详细讲解如何使用...这为C#开发者提供了一个基本的FTP文件下载模板,可以根据实际需求进行扩展和完善。

    C#FTP在treeview里获取文件夹目录列表

    本篇文章将详细探讨如何在C#中使用FTP来在treeview控件中获取远程服务器的文件夹目录列表。 首先,让我们了解基本概念。TreeView控件是Windows Forms中一个强大的组件,它允许用户以树状结构展示数据,常用于文件...

    C# winform 上传文件夹到指定FTP

    在C# WinForm应用开发中,经常需要实现文件或文件夹的上传功能,尤其是在与远程服务器交互时。...通过理解并实践这些内容,你将能够构建出一个完整的FTP文件上传功能。记得在实际开发中根据具体需求进行调整和完善。

    自己重新封装的C# FTP实现上传,下载,创建文件,文件夹,删除单个文件 MD5校验等

    FTP客户端通常包括上传、下载、创建文件和文件夹、删除文件以及进行MD5校验等多种操作。以下将详细阐述这些知识点。 1. **FTP协议**:FTP是Internet上的标准协议,用于在不同主机之间交换文件。它基于TCP/IP协议栈...

    VC++ 遍历FTP文件目录

    本文将深入探讨如何利用VC++遍历FTP文件目录,结合Socket编程和文件操作SDK来实现这一功能。 首先,FTP是一种用于在网络上进行文件传输的标准协议,它允许用户从远程主机上下载文件或上传文件到远程主机。在VC++中...

    C#Ftp文件目录展示,文件下载

    综上所述,"C#Ftp文件目录展示,文件下载"项目涵盖了C#编程、WPF界面设计、FTP协议的实现等多个关键领域,是一个实用的综合案例,有助于提升开发者在桌面应用开发和网络通信方面的技能。通过学习和实践这样的项目,...

    c#FTP上传文件夹

    本文将深入探讨如何使用C#实现在本地文件夹中的所有文件上传到FTP服务器,并保持本地和FTP上的目录结构一致。 首先,我们需要引入`System.Net`命名空间,因为它包含了处理FTP操作所需的类。在C#中,我们可以使用`...

    FTP中获取文件大小

    本文将深入探讨如何使用Java来获取FTP服务器上的文件大小以及文件夹属性,并简要介绍FTP的一些常用命令。 **Java FTP获取文件大小** 在Java中,我们可以使用`java.net.Socket`和`java.io`库来实现基本的FTP操作,...

    libcurl 实现获取ftp远程 文件大小

    libcurl 实现获取ftp远程 文件大小自己实现得 可以使用 直接可以拿走用

    linux ftp目录迁移

    - 调整新目录的所有权和权限,以便FTP服务能够正确读写文件: ```bash chown -R ftpuser:ftpuser /var/ftp/new chmod -R 755 /var/ftp/new ``` 其中,`ftpuser`是你的FTP服务使用的用户名,根据实际情况进行...

Global site tag (gtag.js) - Google Analytics