JAVA中使用FTPClient上传下载 java利用ftp协议上传文件(by me)

阿里云国内75折 回扣 微信号:monov8
阿里云国际,腾讯云国际,低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号:monov8 飞机:@monov6


package com.longboo.fangan;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;

import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import org.junit.Test;
public class UploadFtp {
	public static String url="192.168.1.118";
	public static int port=21;
	public static String username="tao";
	public static String password="";
	public static String rootPath="Product";
//	public static String url="192.168.1.108";
//	public static int port=21;
//	public static String username="public";
//	public static String password="123";
//	public static String rootPath="Product";
	
	/**
	 * Description: 向FTP服务器上传文件
	 * @Version1.0 Jul 27, 2008 4:31:09 PM by 崔红保(cuihongbao@d-heaven.com)创建
	 * @param url FTP服务器hostname
	 * @param port FTP服务器端口
	 * @param username FTP登录账号
	 * @param password FTP登录密码
	 * @param path FTP服务器保存目录
	 * @param filename 上传到FTP服务器上的文件名
	 * @param input 输入流
	 * @return 成功返回true,否则返回false
	 */
	public static boolean uploadFile(String url,int port,String username, String password, String path, String filename, InputStream input) {
		boolean success = false;
		FTPClient ftp = new FTPClient();
		try {
			int reply;
			ftp.connect(url, port);//连接FTP服务器
			//如果采用默认端口,可以使用ftp.connect(url)的方式直接连接FTP服务器
			ftp.login(username, password);//登录
			reply = ftp.getReplyCode();
			if (!FTPReply.isPositiveCompletion(reply)) {
				ftp.disconnect();
				return success;
			}
			boolean flag=ftp.changeWorkingDirectory(path);
			boolean mkdFlag=ftp.makeDirectory(path);
			System.out.println("mkdFlag "+mkdFlag);
			System.out.println("changeWorkingDirectory "+path+"  "+flag);
			ftp.storeFile(filename, input);			
			input.close();
			ftp.logout();
			success = true;
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			if (ftp.isConnected()) {
				try {
					ftp.disconnect();
				} catch (IOException ioe) {
				}
			}
		}
		return success;
	} 
	
	

	public static boolean uploadOne(String path, String filename, InputStream input) {
		boolean success = false;
		FTPClient ftp = new FTPClient();
		try {
			int reply;
			ftp.connect(url, port);//连接FTP服务器
			//如果采用默认端口,可以使用ftp.connect(url)的方式直接连接FTP服务器
			ftp.login(username, password);//登录
			reply = ftp.getReplyCode();
			if (!FTPReply.isPositiveCompletion(reply)) {
				ftp.disconnect();
				return success;
			}
			boolean flag=ftp.changeWorkingDirectory(path);
			
			ftp.setFileType(FTP.BINARY_FILE_TYPE);
			boolean storeFlag=ftp.storeFile(new String(filename.getBytes(),"iso8859-1"), input);			
			System.out.println("storeFlag:"+storeFlag);
			input.close();
			ftp.logout();
			success = true;
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			if (ftp.isConnected()) {
				try {
					ftp.disconnect();
				} catch (IOException ioe) {
				}
			}
		}
		return success;
	} 
	
	
	
	@Test  
	public void uploadToFtpServer(String company,String product){  
//		public void uploadToFtpServer(){  
	    try {  
//			String company="xceedsoftware", product="xceedprofessionalthemesforwpf";
			company=company.toLowerCase();
			company=company.replaceAll(" ", "");
			company=company.replaceAll("[.]", "");
			product=product.toLowerCase();
			product=product.replaceAll(" ", "");
			product=product.replaceAll("[.]", "");
			
	    	String path=rootPath+"/"+company+"/"+product;
	    	boolean existsFlag=existeDir(path);
	    	if(!existsFlag)
	    	{
	    		makeDirs(path);
	    	}
	    	File source=new File("e:/t/"+company+"/"+product);
	    	for(File f:source.listFiles())
	    	{
	    		uploadOne(path, f.getName(), new FileInputStream(f));
	    	}
	    	
	    	
	    } catch (Exception e) {  
	        e.printStackTrace();  
	    }  
	}
	
	public void makeDirs(String path)
	{
		String[] pathes=path.split( "/" );
        for(int i=0;i<pathes.length;i++)
        {
        	String tempPath="";
        	for(int j=0;j<=i;j++){
        		tempPath+="/"+pathes[j];
        	}
        	tempPath=tempPath.substring(1);
        	System.out.println(tempPath);
        	makeDir(tempPath);
        }
	}
	
	
	
	public static boolean makeDir(String path) {
		boolean success = false;
		FTPClient ftp = new FTPClient();
		try {
			int reply;
			ftp.connect(url, port);//连接FTP服务器
			//如果采用默认端口,可以使用ftp.connect(url)的方式直接连接FTP服务器
			ftp.login(username, password);//登录
			reply = ftp.getReplyCode();
			if (!FTPReply.isPositiveCompletion(reply)) {
				ftp.disconnect();
				return success;
			}
			ftp.mkd(path);
			ftp.logout();
			success = true;
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			if (ftp.isConnected()) {
				try {
					ftp.disconnect();
				} catch (IOException ioe) {
				}
			}
		}
		return success;
	} 
	
	public boolean existeDir(String path)
	{
		boolean flag = false;
		FTPClient ftp = new FTPClient();
		try {
			int reply;
			ftp.connect(url, port);//连接FTP服务器
			//如果采用默认端口,可以使用ftp.connect(url)的方式直接连接FTP服务器
			ftp.login(username, password);//登录
			reply = ftp.getReplyCode();
			if (!FTPReply.isPositiveCompletion(reply)) {
				ftp.disconnect();
				return flag;
			}
			flag=ftp.changeWorkingDirectory(path);
			ftp.logout();
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			if (ftp.isConnected()) {
				try {
					ftp.disconnect();
				} catch (IOException ioe) {
				}
			}
		}
		return flag;
	}

}


  

阿里云国内75折 回扣 微信号:monov8
阿里云国际,腾讯云国际,低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号:monov8 飞机:@monov6
标签: Java

“JAVA中使用FTPClient上传下载 java利用ftp协议上传文件(by me)” 的相关文章

本地环境如何运行thinkphp框架 - 编程语言

本篇内容介绍了“本地环境如何运行thinkphp框架”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成! 在本地开发环境中运行ThinkPHP框架...

#yyds干货盘点#聊一聊forEach函数

前端循环中会用到forEach,其实forEach有很多问题:forEach无法终止或者跳出循环forEach()方法不支持使用break或continue语句来跳出循环或跳过某一项。如果需要跳出循环或跳过某一项,应该使用for循环或其他支持break或continue语句的方法。forEach 删...

HDU 4608 I-number (数学&字符串处理)_字符串数学公式解析

I-number http://acm.hdu.edu.cn/showproblem.php?pid=4608 Time Limit: 10000/5000 MS (Java/Others)     Memory Limit: 32768/32768 K...

UVa 10038 / POJ 2575 / ZOJ 1879 Jolly Jumpers (water ver.)

10038 - Jolly JumpersTime limit: 3.000 secondshttp://uva.onlinejudge.org/index.php?option=com_onlinejudge&Itemid=8&category=24&page=show_...

「SQL面试题库」 No

1、专栏介绍 「SQL面试题库」是由 不是西红柿 发起全员免费参与的SQL学习活动。我每天发布1道SQL面试真题从简单到困难涵盖所有SQL知识点我敢保证只要做完这100道题不仅能轻松搞定面试代码能力和工作效率也会有明显提升。 1.1 活动流程 整理题目西红柿每天无论刮风下雨保证...

5种常见的服务器种类是哪些

5种常见的服务器种类是1、文件服务器以文件数据的存储与共享为主要功能的服务器2、数据库服务器主要作用是为应用程序提供数据服务3、邮件服务器4、网页服务器指在互联网中存放各种网站的服务器5、FTP服务器。 5种常见的服务器种类是 一、文件服务器   文件服务器是指在计算机网络中以文件数据的存储与...