使用apache的net包ftp上传文件

import java.io.File;  
import java.io.FileInputStream;  
import java.io.FileNotFoundException;  
import java.io.FileOutputStream;  
import java.io.IOException;  
import java.io.InputStream;  
import java.io.OutputStream;  
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; 

public class JFtpApche  
{  
    privatestatic FTPClient ftpClient = new FTPClient(); 

    privatestatic String encoding = System.getProperty("file.encoding"); 

    publicstatic boolean uploadFile(String url, int port, String username,String password, String path, String filename, InputStream input) 
    { 
       boolean result = false;  
       try  
       {  
           int reply;  
           // 如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器 
           ftpClient.connect(url);  
           // ftp.connect(url, port);// 连接FTP服务器  
           // 登录  
           ftpClient.login(username, password);  
           ftpClient.setControlEncoding(encoding);  
           // 检验是否连接成功  
           reply = ftpClient.getReplyCode();  
           if (!FTPReply.isPositiveCompletion(reply))  
           {  
               System.out.println("连接失败");  
               ftpClient.disconnect();  
               return result;  
           }  
           // 转移工作目录至指定目录下  
           boolean change = ftpClient.changeWorkingDirectory(path); 
           ftpClient.setFileType(FTP.BINARY_FILE_TYPE); 
           if (change)  
           {  
               result = ftpClient.storeFile(newString(filename.getBytes(encoding), "iso-8859-1"), input); 
               if (result)  
               {  
                   System.out.println("上传成功!");  
               }  
           }  
           input.close();  
           ftpClient.logout();  
       } catch (IOException e)  
       {  
           e.printStackTrace();  
       } finally  
       {  
           if (ftpClient.isConnected())  
           {  
               try  
               {  
                   ftpClient.disconnect();  
               } catch (IOException ioe)  
               {  
               }  
           }  
       }  
       return result;  
    } 

    public voidtestUpLoadFromDisk()  
    { 
       try  
       {  
           FileInputStream in = new FileInputStream(newFile("./data/se/1-2015-02-03-14.list"));  
           //boolean flag = uploadFile("127.0.0.1", 21, "zlb", "123", "/","哈哈.txt", in);  
           boolean flag = uploadFile("10.10.2.55", 21, "anonymous", "", "/","1-2015-02-03-14.list", in);  
           System.out.println(flag);  
       } catch (FileNotFoundException e)  
       {  
           e.printStackTrace();  
       }  
    } 

    publicstatic boolean downFile(String url, int port, String username,String password, String remotePath, String fileName, StringlocalPath)  
    { 
       boolean result = false;  
       try  
       {  
           int reply;  
           ftpClient.setControlEncoding(encoding);  

           // FTPClientConfig conf = new  
           // FTPClientConfig(FTPClientConfig.SYST_NT); 
           // conf.setServerLanguageCode("zh");  
           ftpClient.connect(url, port);  
           // 如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器 
           ftpClient.login(username, password);// 登录  
           // 设置文件传输类型为二进制  
           ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); 
           // 获取ftp登录应答代码  
           reply = ftpClient.getReplyCode();  
           // 验证是否登陆成功  
           if (!FTPReply.isPositiveCompletion(reply))  
           {  
               ftpClient.disconnect();  
               System.err.println("FTP server refused connection."); 
               return result;  
           }  
           // 转移到FTP服务器目录至指定的目录下  
           ftpClient.changeWorkingDirectory(newString(remotePath.getBytes(encoding), "iso-8859-1")); 
           // 获取文件列表  
           FTPFile[] fs = ftpClient.listFiles();  
           for (FTPFile ff : fs)  
           {  
               if (ff.getName().equals(fileName))  
               {  
                   File localFile = new File(localPath + "/" + ff.getName()); 
                   OutputStream is = new FileOutputStream(localFile); 
                   ftpClient.retrieveFile(ff.getName(), is);  
                   is.close();  
               }  
           }  
           ftpClient.logout();  
           result = true;  
       } catch (IOException e)  
       {  
           e.printStackTrace();  
       } finally  
       {  
           if (ftpClient.isConnected())  
           {  
               try  
               {  
                   ftpClient.disconnect();  
               } catch (IOException ioe)  
               {  
               }  
           }  
       }  
       return result;  
    } 

    public voidtestDownFile()  
    { 
       try  
       {  
           boolean flag = downFile("127.0.0.1", 21, "zlb", "123", "/","contact.txt", "D:/");  
           System.out.println(flag);  
       } catch (Exception e)  
       {  
           e.printStackTrace();  
       }  
    } 

    publicstatic void main(String[] args)  
    { 
       JFtpApche fa = new JFtpApche();  
       //fa.testDownFile();  
       fa.testUpLoadFromDisk();
    } 

} 

标签： ftp服务器 isp 代码 服务器 连接ftp服务器

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点！
本站所提供的图片等素材，版权归原作者所有，如需使用，请与原作者联系。