FTPUtil - sarasayhi/hello-world GitHub Wiki

import java.io.ByteArrayInputStream; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.text.SimpleDateFormat;

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 org.slf4j.Logger; import org.slf4j.LoggerFactory;

public class FTPUtil { private static Logger logger = LoggerFactory.getLogger(FTPUtil.class); /**
* Description: 向FTP服务器上传文件
* @param host FTP服务器hostname
* @param port FTP服务器端口
* @param username FTP登录账号
* @param password FTP登录密码
* @param basePath FTP服务器基础目录 * @param filePath FTP服务器文件存放路径。例如分日期存放：/2015/01/01。文件的路径为basePath+filePath * @param filename 上传到FTP服务器上的文件名
* @param input 输入流
* @return 成功返回true，否则返回false
*/
public static boolean uploadFile(String host, int port, String username, String password, String basePath,
String filePath, String filename, byte[] input) { boolean result = false;
FTPClient ftp = new FTPClient();
try {
int reply;
ftp.connect(host, port);// 连接FTP服务器
// 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
ftp.login(username, password);// 登录
reply = ftp.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
ftp.disconnect(); return result; }
//切换到上传目录
if (!ftp.changeWorkingDirectory(basePath+filePath)) {
//如果目录不存在创建目录
String[] dirs = filePath.split("/");
String tempPath = basePath;
for (String dir : dirs) {
if (null == dir || "".equals(dir)) continue;
tempPath += "/" + dir;
if (!ftp.changeWorkingDirectory(tempPath)) {
if (!ftp.makeDirectory(tempPath)) { return result; } else {
ftp.changeWorkingDirectory(tempPath);
}
}
}
}
//设置上传文件的类型为二进制类型

		//byte[] input = PictureUtil.getImageFromNetByUrl(url);
		InputStream is = new ByteArrayInputStream(input);
		//上传文件  
		//input = new ByteArrayInputStream(bos.toByteArray());
		ftp.setFileType(FTP.BINARY_FILE_TYPE);  
		if (!ftp.storeFile(filename, is)) {
			return result;
		}
		is.close();
		ftp.logout();  
		result = true;  
	} catch (Exception e) {  
		logger.error("出错", e);
	} finally {  
		if (ftp.isConnected()) {  
			try {  
				ftp.disconnect();  
			} catch (IOException ioe) {  
			}  
		}  
	}  
	return result;  
}  

/**  
 * Description: 从FTP服务器下载文件  
 * @param host FTP服务器hostname  
 * @param port FTP服务器端口  
 * @param username FTP登录账号  
 * @param password FTP登录密码  
 * @param remotePath FTP服务器上的相对路径  
 * @param fileName 要下载的文件名  
 * @param localPath 下载后保存到本地的路径  
 * @return  
 */    
public static boolean downloadFile(String host, int port, String username, String password, String remotePath,  
		String fileName, String localPath) {  
	boolean result = false;  
	FTPClient ftp = new FTPClient();  
	try {  
		int reply;  
		ftp.connect(host, port);  
		// 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器  
		ftp.login(username, password);// 登录  
		reply = ftp.getReplyCode();  
		if (!FTPReply.isPositiveCompletion(reply)) {  
			ftp.disconnect();  
			return result;  
		}  
		ftp.changeWorkingDirectory(remotePath);// 转移到FTP服务器目录  
		FTPFile[] fs = ftp.listFiles();  
		for (FTPFile ff : fs) {  
			if (ff.getName().equals(fileName)) {  
				File localFile = new File(localPath + "/" + ff.getName());  
				
				OutputStream is = new FileOutputStream(localFile);  
				ftp.retrieveFile(ff.getName(), is);  
				is.close();  
			}  
		}  
		
		ftp.logout();  
		result = true;  
	} catch (IOException e) {  
		logger.error("出错", e);
	} finally {  
		if (ftp.isConnected()) {  
			try {  
				ftp.disconnect();  
			} catch (IOException ioe) {  
			}  
		}  
	}  
	return result;  
}  
/*public static void main(String[] args) {
	SimpleDateFormat df = new SimpleDateFormat("yy-MM-dd");
	logger.info(df.format(System.currentTimeMillis()));
	SimpleDateFormat df1 = new SimpleDateFormat("yyMMddHHmmss");
	System.out.println(df.format(System.currentTimeMillis()));
	System.out.println(df1.format(System.currentTimeMillis()));
	long begin = System.currentTimeMillis();
	String picPlate = "http://10.6.134.108:8088/image/vrb2/i2/30d985d0aea84b738640b15b72cfcf7a/00000?key=53d2&offset=1869540224&high=336628";
	try {
		byte[] plate = DownloadImageTool.getBytes(picPlate, "GBK");
		logger.info(plate.toString());//D:\ftpserver  /LocalUser/ftp/
		FTPUtil.uploadFile("10.6.134.13", 21, "test", "12345+", "/base2018", "/20150101/999",new String("11111_998_浙AG7R65_20170512152654_02_11.jpg".getBytes("GBK"), "iso-8859-1"), plate);
	} catch (Exception e) {
		e.printStackTrace();
	}
	long end =System.currentTimeMillis();
	System.out.println("===========================共花费"+(end-begin)+"毫秒");
}*/

}