使用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(); }} </pre>
本文由用戶 mcc 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!