ftp上传下载

package com.my.ftp;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.SocketException;

import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;

public class myFtp {

/**
* 登陆FTP服务器
* @param hostName
* @param port
* @param userName
* @param password
* @return
*/
public static FTPClient loginFtpServer(String hostName,int port,String userName,String password) {
boolean flag = false;
int reply;
        FTPClient ftpClient = new FTPClient();
        try {
ftpClient.connect(hostName, port);
reply = ftpClient.getReplyCode();          
if(!FTPReply.isPositiveCompletion(reply)){
ftpClient.disconnect();
    System.exit(1);
    System.err.println("FTP服务器拒绝连接！");
    return null;
}
flag=ftpClient.login(userName, password);
if (flag) {
//设置超时时间为5分钟
ftpClient.setDataTimeout(1000*60*5);
//设置当前数据连接模式
ftpClient.enterLocalPassiveMode();
//登陆成功后默认设置文件类型为BINARY，默认是ASCII
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
System.out.println("登陆FTP服务器成功");
}else{
System.err.println("登陆FTP服务器失败！");
return null;
}
} catch (SocketException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
       
        return ftpClient;
}

/**
*
* @param ftpClient FTPClient对象
* @param ftpPath FTP服务器路径
* @param file 要上传的文件
* @param reFileName 重命名文件名
* @param input 文件流
* @return
*/
public static boolean uploadFile(FTPClient ftpClient,String ftpPath,File file,String reFileName,InputStream input){
boolean flag=false;
if (ftpClient!=null && ftpClient.isConnected() && file!=null) {
if (ftpPath==null || ftpPath.isEmpty()) {
ftpPath="/Downloads/";
}
if (reFileName==null || reFileName.isEmpty()) {
reFileName=file.getName();
}
try {
//ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
//设置文件路径可以是相对也可是绝对
ftpClient.changeWorkingDirectory(ftpPath);
//文件的缓冲区大小为1024字节
ftpClient.setBufferSize(1024);
//重命名文件，缓冲区流
ftpClient.storeFile(file.getName(), input);
input.close();
//注销FTP登陆
ftpClient.logout();
flag=true;
} catch (IOException e) {
e.printStackTrace();
}finally{
if (ftpClient.isConnected()) {
try {
ftpClient.disconnect();
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
}

return flag;
}

/**
* 在FTP服务器上删除文件
* @param ftpClient FTPClient对象
* @param pathName  要删除的文件名,须是绝对路径如：/Downloads/testFile.avi
* @return
*/
public static boolean deleteFile(FTPClient ftpClient,String pathName){
boolean flag=false;
if(ftpClient!=null&&ftpClient.isConnected()){
try {
flag=ftpClient.deleteFile(pathName);
if (flag) {
System.out.println("文件删除成功");
}
else {
System.err.println("文件删除失败！");
}
} catch (IOException e) {
e.printStackTrace();
}
}

return flag;
}

//修改文件名
public static boolean updateFile(FTPClient ftpClient,String ftpPath,String fileName,String reFileName){
boolean flag=false;
if(ftpClient!=null&&ftpClient.isConnected()){
if (ftpPath==null || ftpPath.isEmpty()) {
ftpPath="/Downloads/";
}
if(fileName!=null&&!fileName.isEmpty()&&reFileName!=null&&!reFileName.isEmpty()){
try {
//ftpClient.changeWorkingDirectory(ftpPath);
flag=ftpClient.rename(fileName, reFileName);
} catch (IOException e) {
e.printStackTrace();
}
}
}
return flag;
}

//
/**
* 下载文件
* @param ftpClient FTPClient对象
* @param ftpPath FTP服务器上的路径
* @param fileName 要下载的文件名
* @param localPath 下载后保存到本地的路径
* @return
*/
public static boolean downLoadFile(FTPClient ftpClient,String ftpPath,String fileName,String localPath){
boolean status=false;
if (ftpClient!=null && ftpClient.isConnected() && fileName!=null && localPath!=null) {
if (ftpPath==null || ftpPath.isEmpty()) {
ftpPath="/Downloads/";
}
try{
//设置文件路径可以是相对也可是绝对
ftpClient.changeWorkingDirectory(ftpPath);
//设置当前数据连接模式
ftpClient.enterLocalPassiveMode();
//获取到改路径下的文件名集合
FTPFile[] fs=ftpClient.listFiles();
File localFile=null;
for (FTPFile ff : fs) {
if (ff.getName().equals(fileName)) {
localPath+="/"+ff.getName();
localFile = new File(localPath);

}
}
if (localFile!=null) {
BufferedOutputStream out=new BufferedOutputStream(new FileOutputStream(localFile));
ftpClient.retrieveFile(fileName, out);
out.close();
}else {
System.err.println("未找到该文件！");
}
ftpClient.logout();
status=true;
} catch (IOException e) {
e.printStackTrace();
} finally {
if (ftpClient.isConnected()) {
try {
ftpClient.disconnect();
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
}

return status;
}

/**
* 获取FTP服务器指定目录下的文件列表
* @param ftpClient FTPClient对象
* @param ftpPath FTP服务器上的路径
* @return
*/
public static FTPFile[] getFileNameList(FTPClient ftpClient,String ftpPath){
FTPFile[] fileList=null;
if(ftpClient!=null&&ftpClient.isConnected()){
if (ftpPath==null || ftpPath.isEmpty()) {
ftpPath="/Downloads/";
}
//设置文件路径可以是相对也可是绝对
try {
ftpClient.changeWorkingDirectory(ftpPath);
//设置当前数据连接模式
ftpClient.enterLocalPassiveMode();
//获取到改路径下的文件名集合
fileList=ftpClient.listFiles();
} catch (IOException e) {
e.printStackTrace();
}
}

return fileList;
}

    public static void closeFtp(FTPClient ftpClient){
        if(ftpClient!=null&&ftpClient.isConnected()){
            try {
                boolean isLogOut=ftpClient.logout();
                if(isLogOut){
                    System.out.println("已关闭FTP连接");
                }
            } catch (IOException e) {
                e.printStackTrace();
                System.out.println("关闭FTP服务器异常！");
            }finally{
                try {
                    ftpClient.disconnect();
                } catch (IOException e) {
                    e.printStackTrace();
                    System.out.println("关闭服务器连接异常！");
                }
            }
           
        }
    }
   
public static void main(String[] args) throws SocketException, IOException {
FTPClient ftpClient=loginFtpServer("127.0.0.1", 21, "Admin", "123456");
File file=new File("E:/testFile.avi");
//上传文件
if (ftpClient.isConnected()&&ftpClient!=null) {
BufferedInputStream input=new BufferedInputStream(new FileInputStream(file));
boolean flag=uploadFile(ftpClient, "", file, "", input);
System.out.println(flag);
}
//删除文件
if (ftpClient.isConnected()&&ftpClient!=null) {
deleteFile(ftpClient, "/Downloads/testFile.avi");
}
//下载文件
if (ftpClient.isConnected()&&ftpClient!=null) {
downLoadFile(ftpClient, "", file.getName(), "C:/");
}
//查看某个目录下所有文件
if (ftpClient.isConnected()&&ftpClient!=null) {
FTPFile[] fileList=getFileNameList(ftpClient, "");
for (FTPFile ff : fileList) {
System.out.println(new String(ff.getName().getBytes("iso-8859-1"),"GBK"));
}
}
//修改文件名--error
if (ftpClient.isConnected()&&ftpClient!=null) {
boolean flag=updateFile(ftpClient,"","/Downloads/testFile - 副本.avi", "/Downloads/testFile_rename.avi");
System.out.println(flag);
}
closeFtp(ftpClient);
}

}

以上代码复制可用，请下载apache下的common-net.jar，我的版本是common-net-3.3.jar