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

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 崔红保（[e-mail]）创建
 * @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;
}

}